Package com.atlassian.bamboo.grpc.receiver

Class AtlassianCacheCrossNodesEventsReceiverService

java.lang.Object

com.atlassian.bamboo.grpc.AtlassianCacheCrossNodesEventsServiceGrpc.AtlassianCacheCrossNodesEventsServiceImplBase

com.atlassian.bamboo.grpc.receiver.AtlassianCacheCrossNodesEventsReceiverService

All Implemented Interfaces:

AtlassianCacheCrossNodesEventsServiceGrpc.AsyncService, io.grpc.BindableService

public class AtlassianCacheCrossNodesEventsReceiverService
extends AtlassianCacheCrossNodesEventsServiceGrpc.AtlassianCacheCrossNodesEventsServiceImplBase

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

This service handles only Atlassian Cache related events.

Since:

10.0

Constructor Summary

Constructors

Constructor	Description
AtlassianCacheCrossNodesEventsReceiverService(DeadLetterQueue deadLetterQueue, GrpcBackedCacheManager grpcBackedCacheManager)

Method Summary

Modifier and Type	Method	Description
void	propagateAtlassianCacheBulk(CrossNodesCommunication.AtlassianCacheBulkRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCachedReferenceReset(CrossNodesCommunication.AtlassianCachedReferenceResetRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCachePut(CrossNodesCommunication.AtlassianCachePutRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCachePutIfAbsent(CrossNodesCommunication.AtlassianCachePutIfAbsentRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCacheRemoveAll(CrossNodesCommunication.AtlassianCacheRemoveAllRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCacheRemoveByKey(CrossNodesCommunication.AtlassianCacheRemoveByKeyRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCacheRemoveByKeyAndValue(CrossNodesCommunication.AtlassianCacheRemoveByKeyAndValueRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
void	propagateAtlassianCacheReplace(CrossNodesCommunication.AtlassianCacheReplaceRequest request, io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

Methods inherited from class com.atlassian.bamboo.grpc.AtlassianCacheCrossNodesEventsServiceGrpc.AtlassianCacheCrossNodesEventsServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

AtlassianCacheCrossNodesEventsReceiverService

public AtlassianCacheCrossNodesEventsReceiverService(DeadLetterQueue deadLetterQueue,
 GrpcBackedCacheManager grpcBackedCacheManager)

Method Details

propagateAtlassianCachePut

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

propagateAtlassianCachePutIfAbsent

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

propagateAtlassianCacheRemoveByKey

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

propagateAtlassianCacheRemoveByKeyAndValue

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

propagateAtlassianCacheRemoveAll

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

propagateAtlassianCacheReplace

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

propagateAtlassianCacheBulk

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

propagateAtlassianCachedReferenceReset

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