alluxio.grpc

Interface JournalMasterClientServiceGrpc.AsyncService

All Known Implementing Classes:

JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase, JournalMasterClientServiceHandler

Enclosing class:

JournalMasterClientServiceGrpc

public static interface JournalMasterClientServiceGrpc.AsyncService

 This interface contains journal master service endpoints for Alluxio clients.
 

Method Summary

Modifier and Type	Method and Description
default void	getNodeState(GetNodeStatePRequest request, io.grpc.stub.StreamObserver<GetNodeStatePResponse> responseObserver) Gets the state of the current node and returns whether it is primary or standby.
default void	getQuorumInfo(GetQuorumInfoPRequest request, io.grpc.stub.StreamObserver<GetQuorumInfoPResponse> responseObserver) Gets list of server states in an embedded journal quorum.
default void	getTransferLeaderMessage(GetTransferLeaderMessagePRequest request, io.grpc.stub.StreamObserver<GetTransferLeaderMessagePResponse> responseObserver) Gets exception message throwing when transfer leader.
default void	removeQuorumServer(RemoveQuorumServerPRequest request, io.grpc.stub.StreamObserver<RemoveQuorumServerPResponse> responseObserver) Removes a server from embedded journal quorum.
default void	resetPriorities(ResetPrioritiesPRequest request, io.grpc.stub.StreamObserver<ResetPrioritiesPResponse> responseObserver) Reset all the RaftPeer priorities.
default void	transferLeadership(TransferLeadershipPRequest request, io.grpc.stub.StreamObserver<TransferLeadershipPResponse> responseObserver) Transfers the leadership from the current leader to another designated leader.

Method Detail

getQuorumInfo

default void getQuorumInfo(GetQuorumInfoPRequest request,
                           io.grpc.stub.StreamObserver<GetQuorumInfoPResponse> responseObserver)

 Gets list of server states in an embedded journal quorum.
 

removeQuorumServer

default void removeQuorumServer(RemoveQuorumServerPRequest request,
                                io.grpc.stub.StreamObserver<RemoveQuorumServerPResponse> responseObserver)

 Removes a server from embedded journal quorum.
 

transferLeadership

default void transferLeadership(TransferLeadershipPRequest request,
                                io.grpc.stub.StreamObserver<TransferLeadershipPResponse> responseObserver)

 Transfers the leadership from the current leader to another designated leader.
 

resetPriorities

default void resetPriorities(ResetPrioritiesPRequest request,
                             io.grpc.stub.StreamObserver<ResetPrioritiesPResponse> responseObserver)

 Reset all the RaftPeer priorities.
 

getTransferLeaderMessage

default void getTransferLeaderMessage(GetTransferLeaderMessagePRequest request,
                                      io.grpc.stub.StreamObserver<GetTransferLeaderMessagePResponse> responseObserver)

 Gets exception message throwing when transfer leader.
 

getNodeState

default void getNodeState(GetNodeStatePRequest request,
                          io.grpc.stub.StreamObserver<GetNodeStatePResponse> responseObserver)

 Gets the state of the current node and returns whether it is primary or standby.