Modifier and Type | Method and Description |
---|---|
void |
DefaultLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
LeaderRetrievalService.start(LeaderRetrievalListener listener)
Starts the leader retrieval service with the given listener to listen for new leaders.
|
void |
StandaloneLeaderRetrievalService.start(LeaderRetrievalListener listener) |
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionUtils.LeaderConnectingAddressListener
A
LeaderRetrievalListener that allows retrieving an InetAddress for the
current leader. |
Modifier and Type | Class and Description |
---|---|
static class |
LeaderRetrievalUtils.LeaderConnectionInfoListener
Helper class which is used by the retrieveLeaderConnectionInfo method to retrieve the
leader's akka URL and the current leader session ID.
|
Modifier and Type | Class and Description |
---|---|
class |
LeaderGatewayRetriever<T extends RpcGateway>
Retrieves and stores the leading
RpcGateway . |
class |
LeaderRetriever
Retrieves and stores the current leader address.
|
Modifier and Type | Class and Description |
---|---|
class |
RpcGatewayRetriever<F extends Serializable,T extends FencedRpcGateway<F>>
LeaderGatewayRetriever implementation using the RpcService . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.