Package com.atlassian.bamboo.grpc.receiver

Class BambooCrossNodesEventsReceiverService

java.lang.Object

com.atlassian.bamboo.grpc.BambooCrossNodesEventsServiceGrpc.BambooCrossNodesEventsServiceImplBase

com.atlassian.bamboo.grpc.receiver.BambooCrossNodesEventsReceiverService

All Implemented Interfaces:

BambooCrossNodesEventsServiceGrpc.AsyncService, io.grpc.BindableService

@Internal
public class BambooCrossNodesEventsReceiverService
extends BambooCrossNodesEventsServiceGrpc.BambooCrossNodesEventsServiceImplBase

This class is responsible for receiving and processing event-based gRPC requests from other nodes within the cluster.

This service handles only Bamboo* events.

Since:

10.0

Constructor Summary

Constructors

Constructor

Description

BambooCrossNodesEventsReceiverService(ImmutablePlanCacheService immutablePlanCacheService, CachedRepositoryDefinitionManager cachedRepositoryDefinitionManager, DeadLetterQueue deadLetterQueue, org.springframework.security.core.session.SessionRegistry sessionRegistry, BambooUserManager bambooUserManager, ClusterAwareLifecycleManager clusterAwareLifecycleManager, FileBasedPersister fileBasedPersister, com.atlassian.event.api.EventPublisher eventPublisher, ClusterMessageReceiver clusterMessageReceiver)

Method Summary

Modifier and Type	Method	Description
void	hidePlan(CrossNodesCommunication.HidePlanRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	hideStage(CrossNodesCommunication.HideStageRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	invalidateAllLatestResultSummaries(CrossNodesCommunication.Metadata request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	invalidateBuildNumbersRange(CrossNodesCommunication.InvalidateBuildNumbersRangeRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	invalidateLatestResultSummary(CrossNodesCommunication.InvalidateLatestResultSummaryRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	invalidatePlanCache(CrossNodesCommunication.InvalidatePlanCacheRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	Plan cache related events
void	invalidateRepositoryCache(CrossNodesCommunication.InvalidateRepositoryCacheRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	Repository cache related events
void	invalidateSpecsStateForPlan(CrossNodesCommunication.InvalidateSpecsStateForPlanRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	invalidateUserSessions(CrossNodesCommunication.InvalidateUserSessionsRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	User sessions related events
void	propagateClusterMessage(CrossNodesCommunication.ClusterMessageRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	Cluster messages' events
void	refreshAdministrationConfiguration(CrossNodesCommunication.RefreshAdministrationConfigurationRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	Administration configuration related events
void	refreshClusterLifecycleState(CrossNodesCommunication.RefreshClusterLifecycleStateRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)	Server lifecycle related events

Methods inherited from class com.atlassian.bamboo.grpc.BambooCrossNodesEventsServiceGrpc.BambooCrossNodesEventsServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

BambooCrossNodesEventsReceiverService

public BambooCrossNodesEventsReceiverService(ImmutablePlanCacheService immutablePlanCacheService,
 CachedRepositoryDefinitionManager cachedRepositoryDefinitionManager,
 DeadLetterQueue deadLetterQueue,
 org.springframework.security.core.session.SessionRegistry sessionRegistry,
 BambooUserManager bambooUserManager,
 ClusterAwareLifecycleManager clusterAwareLifecycleManager,
 FileBasedPersister fileBasedPersister,
 com.atlassian.event.api.EventPublisher eventPublisher,
 ClusterMessageReceiver clusterMessageReceiver)

Method Details

invalidatePlanCache

public void invalidatePlanCache(CrossNodesCommunication.InvalidatePlanCacheRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

  Plan cache related events
 

hidePlan

public void hidePlan(CrossNodesCommunication.HidePlanRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

hideStage

public void hideStage(CrossNodesCommunication.HideStageRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

invalidateBuildNumbersRange

public void invalidateBuildNumbersRange(CrossNodesCommunication.InvalidateBuildNumbersRangeRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

invalidateLatestResultSummary

public void invalidateLatestResultSummary(CrossNodesCommunication.InvalidateLatestResultSummaryRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

invalidateAllLatestResultSummaries

public void invalidateAllLatestResultSummaries(CrossNodesCommunication.Metadata request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

invalidateSpecsStateForPlan

public void invalidateSpecsStateForPlan(CrossNodesCommunication.InvalidateSpecsStateForPlanRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

invalidateRepositoryCache

public void invalidateRepositoryCache(CrossNodesCommunication.InvalidateRepositoryCacheRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

 Repository cache related events
 

invalidateUserSessions

public void invalidateUserSessions(CrossNodesCommunication.InvalidateUserSessionsRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

 User sessions related events
 

refreshClusterLifecycleState

public void refreshClusterLifecycleState(CrossNodesCommunication.RefreshClusterLifecycleStateRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

 Server lifecycle related events
 

refreshAdministrationConfiguration

public void refreshAdministrationConfiguration(CrossNodesCommunication.RefreshAdministrationConfigurationRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

 Administration configuration related events
 

propagateClusterMessage

public void propagateClusterMessage(CrossNodesCommunication.ClusterMessageRequest request,
 io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Description copied from interface: BambooCrossNodesEventsServiceGrpc.AsyncService

 Cluster messages' events