alluxio.master.journal.raft

Class RaftJournalServiceClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.master.journal.raft.RaftJournalServiceClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

public class RaftJournalServiceClient
extends AbstractMasterClient

A client for raft journal service.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

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

Constructor Summary

Constructors

Constructor and Description
RaftJournalServiceClient(MasterSelectionPolicy selectionPolicy, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Create a client that talks to a specific master.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect() This method is called after the connection is made to the remote.
protected void	beforeConnect() This method is called before the connection is connected.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
Iterator<SnapshotData>	requestLatestSnapshotData(SnapshotMetadata request) Receive snapshot data from specified follower.
SnapshotMetadata	requestLatestSnapshotInfo()

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, getConfAddress, 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

Constructor Detail

RaftJournalServiceClient

public RaftJournalServiceClient(MasterSelectionPolicy selectionPolicy,
                                java.util.function.Supplier<RetryPolicy> retryPolicySupplier)

Create a client that talks to a specific master.

Parameters:

selectionPolicy - specifies which master is targeted

retryPolicySupplier - the retry policy to use when connecting to another master

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

beforeConnect

protected void beforeConnect()

Description copied from class: AbstractClient

This method is called before the connection is connected. Implementations should add any additional operations before the connection is connected. loading the cluster defaults

Overrides:

beforeConnect in class AbstractMasterClient

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

requestLatestSnapshotInfo

public SnapshotMetadata requestLatestSnapshotInfo()

Returns:

SnapshotMetadata from specified master

requestLatestSnapshotData

public Iterator<SnapshotData> requestLatestSnapshotData(SnapshotMetadata request)

Receive snapshot data from specified follower.

Parameters:

request - the request detailing which file to download

Returns:

an iterator containing the snapshot data