public class LeaderRetrievalUtils extends Object
LeaderRetrievalService
class.Modifier and Type | Class and Description |
---|---|
static class |
LeaderRetrievalUtils.LeaderInformationListener
Helper class which is used by the retrieveLeaderInformation method to retrieve the leader's
rpc URL and the current leader session ID.
|
Modifier and Type | Method and Description |
---|---|
static InetAddress |
findConnectingAddress(LeaderRetrievalService leaderRetrievalService,
java.time.Duration timeout,
RpcSystemUtils rpcSystemUtils) |
static LeaderInformation |
retrieveLeaderInformation(LeaderRetrievalService leaderRetrievalService,
java.time.Duration timeout)
Retrieves the leader pekko url and the current leader session ID.
|
public static LeaderInformation retrieveLeaderInformation(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout) throws LeaderRetrievalException
LeaderInformation
instance.leaderRetrievalService
- Leader retrieval service to retrieve the leader connection
informationtimeout
- Timeout when to give up looking for the leaderLeaderRetrievalException
public static InetAddress findConnectingAddress(LeaderRetrievalService leaderRetrievalService, java.time.Duration timeout, RpcSystemUtils rpcSystemUtils) throws LeaderRetrievalException
LeaderRetrievalException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.