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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PeerToPeerClient.Response<T>	Represents a response from a peer node.

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<PeerToPeerClient.Response<T>>	ask(Function<PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub,com.google.common.util.concurrent.ListenableFuture<T>> request)
protected @NotNull Pair<io.grpc.ManagedChannel,PeerToPeerCommunicationServiceGrpc.PeerToPeerCommunicationServiceFutureStub>	createChannelAndStub(@NotNull BambooNodeStatus node)
void	destroy()
void	onNodeBecameLive(@NotNull NodeBecameLiveEvent event)
void	onNodeBecameOffline(@NotNull 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(@NotNull
 @NotNull NodeBecameLiveEvent event)

onNodeBecameOffline

@EventListener
public void onNodeBecameOffline(@NotNull
 @NotNull NodeBecameOfflineEvent event)

ask

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

createChannelAndStub

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