alluxio.client.meta

Class RetryHandlingMetaMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.meta.RetryHandlingMetaMasterClient

All Implemented Interfaces:

Client, MetaMasterClient, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public class RetryHandlingMetaMasterClient
extends AbstractMasterClient
implements MetaMasterClient

A wrapper for the gRPC client to interact with the meta master.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

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

Constructor Summary

Constructors

Constructor and Description
RetryHandlingMetaMasterClient(MasterClientContext conf) Creates a new meta master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
BackupStatus	backup(BackupPRequest backupRequest) Takes a backup.
java.lang.String	checkpoint() Creates a checkpoint in the primary master journal system.
BackupStatus	getBackupStatus(java.util.UUID backupId) Queries the status of a backup.
ConfigCheckReport	getConfigReport() Gets the server-side configuration check report.
MasterInfo	getMasterInfo(java.util.Set<MasterInfoField> fields)
protected ServiceType	getRemoteServiceType()
protected java.lang.String	getServiceName()
protected long	getServiceVersion()

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, getConfAddress, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, 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 alluxio.Client

connect, disconnect, getConfAddress, getRemoteHostName, getRemoteSockAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingMetaMasterClient

public RetryHandlingMetaMasterClient(MasterClientContext conf)

Creates a new meta master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

getServiceName

protected java.lang.String getServiceName()

Specified by:

getServiceName in class AbstractClient

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

afterConnect

protected void afterConnect()

Overrides:

afterConnect in class AbstractClient

backup

public BackupStatus backup(BackupPRequest backupRequest)
                    throws java.io.IOException

Description copied from interface: MetaMasterClient

Takes a backup. Note: If backup request ask for async execution, it will return after initiating the backup. Status for the in-progress backup will be returned. MetaMasterClient.getBackupStatus(java.util.UUID) should be called for querying the status of the on-going backup. Note: When leader has no standby in an HA cluster, it will reject backup. This could be allowed by passing "AllowLeader" option in the request.

Specified by:

backup in interface MetaMasterClient

Parameters:

backupRequest - the backup request

Returns:

status of backup

Throws:

java.io.IOException

getBackupStatus

public BackupStatus getBackupStatus(java.util.UUID backupId)
                             throws java.io.IOException

Description copied from interface: MetaMasterClient

Queries the status of a backup.

Specified by:

getBackupStatus in interface MetaMasterClient

Parameters:

backupId - backup id

Returns:

the status of the latest backup

Throws:

java.io.IOException

getConfigReport

public ConfigCheckReport getConfigReport()
                                  throws java.io.IOException

Description copied from interface: MetaMasterClient

Gets the server-side configuration check report.

Specified by:

getConfigReport in interface MetaMasterClient

Returns:

configuration check report

Throws:

java.io.IOException

getMasterInfo

public MasterInfo getMasterInfo(java.util.Set<MasterInfoField> fields)
                         throws java.io.IOException

Specified by:

getMasterInfo in interface MetaMasterClient

Parameters:

fields - optional list of fields to query; if null all fields will be queried

Returns:

the requested master info

Throws:

java.io.IOException

checkpoint

public java.lang.String checkpoint()
                            throws java.io.IOException

Description copied from interface: MetaMasterClient

Creates a checkpoint in the primary master journal system.

Specified by:

checkpoint in interface MetaMasterClient

Returns:

the hostname of the master that did the checkpoint

Throws:

java.io.IOException