alluxio.client.journal

Class RetryHandlingJournalMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.AbstractJobMasterClient

alluxio.client.journal.RetryHandlingJournalMasterClient

All Implemented Interfaces:

Client, JournalMasterClient, Closeable, AutoCloseable

public class RetryHandlingJournalMasterClient
extends AbstractJobMasterClient
implements JournalMasterClient

A wrapper for the gRPC client to interact with the journal master, used by alluxio clients. It would talk to both JobMaster and Master, so it should inherit AbstractJobMasterClient

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractJobMasterClient

mConfAddress

Fields inherited from class alluxio.AbstractClient

mAlwaysEnableTLS, mChannel, mClosed, mConnected, mContext, mServerAddress, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
RetryHandlingJournalMasterClient(MasterClientContext conf) Creates a new journal master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect() This method is called after the connection is made to the remote.
GetQuorumInfoPResponse	getQuorumInfo() Quorum information for participating servers in journal.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
GetTransferLeaderMessagePResponse	getTransferLeaderMessage(String transferId) Gets exception messages thrown when transferring the leader.
void	removeQuorumServer(NetAddress serverAddress) Removes a server from journal quorum.
void	resetPriorities() Resets RaftPeer priorities.
String	transferLeadership(NetAddress newLeaderNetAddress) Initiates changing the leading master of the quorum.

Methods inherited from class alluxio.AbstractJobMasterClient

getConfAddress

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, createChannel, disconnect, getRemoteHostName, getRemoteServiceVersion, getRemoteSockAddress, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingJournalMasterClient

public RetryHandlingJournalMasterClient(MasterClientContext conf)

Creates a new journal master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

Returns:

the expected type of remote service

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class AbstractClient

Returns:

a string representing the specific service

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

Returns:

the client service version

afterConnect

protected void afterConnect()

Description copied from class: AbstractClient

This method is called after the connection is made to the remote. Implementations should create internal state to finish the connection process.

Overrides:

afterConnect in class AbstractClient

getQuorumInfo

public GetQuorumInfoPResponse getQuorumInfo()
                                     throws AlluxioStatusException

Description copied from interface: JournalMasterClient

Quorum information for participating servers in journal.

Specified by:

getQuorumInfo in interface JournalMasterClient

Returns:

list of server states in quorum

Throws:

AlluxioStatusException

removeQuorumServer

public void removeQuorumServer(NetAddress serverAddress)
                        throws AlluxioStatusException

Description copied from interface: JournalMasterClient

Removes a server from journal quorum.

Specified by:

removeQuorumServer in interface JournalMasterClient

Parameters:

serverAddress - server address to remove from quorum

Throws:

AlluxioStatusException

transferLeadership

public String transferLeadership(NetAddress newLeaderNetAddress)
                          throws AlluxioStatusException

Description copied from interface: JournalMasterClient

Initiates changing the leading master of the quorum.

Specified by:

transferLeadership in interface JournalMasterClient

Parameters:

newLeaderNetAddress - server address of the prospective new leader

Returns:

the guid of transfer leader command

Throws:

AlluxioStatusException

resetPriorities

public void resetPriorities()
                     throws AlluxioStatusException

Description copied from interface: JournalMasterClient

Resets RaftPeer priorities.

Specified by:

resetPriorities in interface JournalMasterClient

Throws:

AlluxioStatusException

getTransferLeaderMessage

public GetTransferLeaderMessagePResponse getTransferLeaderMessage(String transferId)
                                                           throws AlluxioStatusException

Description copied from interface: JournalMasterClient

Gets exception messages thrown when transferring the leader.

Specified by:

getTransferLeaderMessage in interface JournalMasterClient

Parameters:

transferId - the guid of transferLeader command

Returns:

exception message thrown when transferring the leader

Throws:

AlluxioStatusException