@ThreadSafe public abstract class AbstractJobMasterClient extends AbstractMasterClient
AbstractClient.RpcCallable<V>
Modifier and Type | Field and Description |
---|---|
protected InetSocketAddress |
mConfAddress
Address to load configuration, which may differ from
mAddress . |
mAddress, mChannel, mClosed, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
AbstractJobMasterClient(MasterClientContext clientConf)
Creates a new master client base.
|
AbstractJobMasterClient(MasterClientContext clientConf,
InetSocketAddress address,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new master client base.
|
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
getConfAddress() |
getAddress
afterConnect, afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceType, getRemoteServiceVersion, getServiceName, getServiceVersion, isClosed, isConnected, retryRPC, retryRPC
protected InetSocketAddress mConfAddress
mAddress
.public AbstractJobMasterClient(MasterClientContext clientConf)
clientConf
- master client configurationpublic AbstractJobMasterClient(MasterClientContext clientConf, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
clientConf
- master client configurationaddress
- address to connect toretryPolicySupplier
- retry policy to usepublic InetSocketAddress getConfAddress() throws UnavailableException
getConfAddress
in interface Client
getConfAddress
in class AbstractMasterClient
InetSocketAddress
of the configuration remoteUnavailableException
- if the primary address cannot be determinedCopyright © 2023. All Rights Reserved.