alluxio.master.journal

Class JournalMasterClientServiceHandler

java.lang.Object

alluxio.grpc.JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

alluxio.master.journal.JournalMasterClientServiceHandler

All Implemented Interfaces:

JournalMasterClientServiceGrpc.AsyncService, io.grpc.BindableService

public class JournalMasterClientServiceHandler
extends JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

This class is a gRPC handler for journal master RPCs invoked by an Alluxio client.

Constructor Summary

Constructors

Constructor and Description
JournalMasterClientServiceHandler(JournalMaster journalMaster) Creates gRPC service handler for JobMaster service.

Method Summary

Modifier and Type	Method and Description
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.
void	getQuorumInfo(GetQuorumInfoPRequest request, io.grpc.stub.StreamObserver<GetQuorumInfoPResponse> responseObserver) Gets list of server states in an embedded journal quorum.
void	getTransferLeaderMessage(GetTransferLeaderMessagePRequest request, io.grpc.stub.StreamObserver<GetTransferLeaderMessagePResponse> responseObserver) Gets exception message throwing when transfer leader.
void	removeQuorumServer(RemoveQuorumServerPRequest request, io.grpc.stub.StreamObserver<RemoveQuorumServerPResponse> responseObserver) Removes a server from embedded journal quorum.
void	resetPriorities(ResetPrioritiesPRequest request, io.grpc.stub.StreamObserver<ResetPrioritiesPResponse> responseObserver) Reset all the RaftPeer priorities.
void	transferLeadership(TransferLeadershipPRequest request, io.grpc.stub.StreamObserver<TransferLeadershipPResponse> responseObserver) Transfers the leadership from the current leader to another designated leader.

Methods inherited from class alluxio.grpc.JournalMasterClientServiceGrpc.JournalMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalMasterClientServiceHandler

public JournalMasterClientServiceHandler(JournalMaster journalMaster)

Creates gRPC service handler for JobMaster service.

Parameters:

journalMaster - the journal master

Method Detail

getQuorumInfo

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

 Gets list of server states in an embedded journal quorum.
 

removeQuorumServer

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

 Removes a server from embedded journal quorum.
 

transferLeadership

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

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

resetPriorities

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

 Reset all the RaftPeer priorities.
 

getTransferLeaderMessage

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

 Gets exception message throwing when transfer leader.
 

getNodeState

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

Description copied from interface: JournalMasterClientServiceGrpc.AsyncService

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