Package com.atlassian.bamboo.cluster.peertopeer

Class PeerToPeerClient

java.lang.Object

com.atlassian.bamboo.cluster.peertopeer.PeerToPeerClient

public class PeerToPeerClient
extends Object

Client for peer-to-peer gRPC communication between nodes.

Since:

9.5

Field Summary

Fields

Modifier and Type	Field	Description
protected final Executor	clientExecutor

Constructor Summary

Constructors

Constructor	Description
PeerToPeerClient(BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService, com.atlassian.event.api.EventPublisher eventPublisher, GrpcChannelService grpcChannelService)

Method Summary

Modifier and Type	Method	Description
<T> @NotNull List<CompletableFuture<T>>	ask(Function<PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub,com.google.common.util.concurrent.ListenableFuture<T>> request)
protected @NotNull Pair<io.grpc.ManagedChannel,PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub>	createChannelAndStub(BambooNodeStatus node)
void	destroy()
void	onNodeBecameLive(NodeBecameLiveEvent event)
void	onNodeBecameOffline(NodeBecameOfflineEvent event)
void	registerEventPublisher()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

clientExecutor

protected final Executor clientExecutor

Constructor Details

PeerToPeerClient

@Inject
public PeerToPeerClient(BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService,
 com.atlassian.event.api.EventPublisher eventPublisher,
 GrpcChannelService grpcChannelService)

Method Details

registerEventPublisher

@PostConstruct
public void registerEventPublisher()

destroy

@PreDestroy
public void destroy()
             throws Exception

Throws:

Exception

onNodeBecameLive

@EventListener
public void onNodeBecameLive(NodeBecameLiveEvent event)

onNodeBecameOffline

@EventListener
public void onNodeBecameOffline(NodeBecameOfflineEvent event)

ask

@NotNull
public <T> @NotNull List<CompletableFuture<T>> ask(Function<PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub,com.google.common.util.concurrent.ListenableFuture<T>> request)

createChannelAndStub

@NotNull
protected @NotNull Pair<io.grpc.ManagedChannel,PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub> createChannelAndStub(BambooNodeStatus node)