Modifier and Type | Method and Description |
---|---|
protected HighAvailabilityServices |
ClusterEntrypoint.createHaServices(Configuration configuration,
Executor executor,
RpcSystemUtils rpcSystemUtils) |
protected MetricRegistryImpl |
ClusterEntrypoint.createMetricRegistry(Configuration configuration,
PluginManager pluginManager,
RpcSystemUtils rpcSystemUtils) |
Modifier and Type | Method and Description |
---|---|
static HighAvailabilityServices |
HighAvailabilityServicesUtils.createHighAvailabilityServices(Configuration configuration,
Executor executor,
AddressResolution addressResolution,
RpcSystemUtils rpcSystemUtils,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
LeaderConnectingAddressListener(RpcSystemUtils rpcSystemUtils) |
Modifier and Type | Interface and Description |
---|---|
interface |
RpcSystem
This interface serves as a factory interface for RPC services, with some additional utilities
that are reliant on implementation details of the RPC service.
|
Modifier and Type | Class and Description |
---|---|
class |
AkkaRpcSystem
RpcSystem implementation based on Akka. |
Modifier and Type | Method and Description |
---|---|
static InetAddress |
LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService,
java.time.Duration timeout,
RpcSystemUtils rpcSystemUtils) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.