@ThreadSafe public class RetryHandlingMetaMasterClient extends AbstractMasterClient implements MetaMasterClient
AbstractClient.RpcCallable<V>
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
RetryHandlingMetaMasterClient(MasterClientContext conf)
Creates a new meta master client.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect()
This method is called after the connection is made to the remote.
|
BackupStatus |
backup(BackupPRequest backupRequest)
Takes a backup.
|
String |
checkpoint()
Creates a checkpoint in the primary master journal system.
|
BackupStatus |
getBackupStatus(UUID backupId)
Queries the status of a backup.
|
ConfigCheckReport |
getConfigReport()
Gets the server-side configuration check report.
|
MasterInfo |
getMasterInfo(Set<MasterInfoField> fields) |
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC
public RetryHandlingMetaMasterClient(MasterClientContext conf)
conf
- master client configurationprotected ServiceType getRemoteServiceType()
getRemoteServiceType
in class AbstractClient
protected String getServiceName()
getServiceName
in class AbstractClient
protected long getServiceVersion()
getServiceVersion
in class AbstractClient
protected void afterConnect()
AbstractClient
afterConnect
in class AbstractClient
public BackupStatus backup(BackupPRequest backupRequest) throws IOException
MetaMasterClient
MetaMasterClient.getBackupStatus(java.util.UUID)
should
be called for querying the status of the on-going backup.
Note: When leader has no secondary in an HA cluster, it will reject backup. This could
be allowed by passing "AllowLeader" option in the request.backup
in interface MetaMasterClient
backupRequest
- the backup requestIOException
public BackupStatus getBackupStatus(UUID backupId) throws IOException
MetaMasterClient
getBackupStatus
in interface MetaMasterClient
backupId
- backup idIOException
public ConfigCheckReport getConfigReport() throws IOException
MetaMasterClient
getConfigReport
in interface MetaMasterClient
IOException
public MasterInfo getMasterInfo(Set<MasterInfoField> fields) throws IOException
getMasterInfo
in interface MetaMasterClient
fields
- optional list of fields to query; if null all fields will be queriedIOException
public String checkpoint() throws IOException
MetaMasterClient
checkpoint
in interface MetaMasterClient
IOException
Copyright © 2023. All Rights Reserved.