public final class QueryableStateUtils extends Object
Constructor and Description |
---|
QueryableStateUtils() |
Modifier and Type | Method and Description |
---|---|
static KvStateClientProxy |
createKvStateClientProxy(String address,
Iterator<Integer> ports,
int eventLoopThreads,
int queryThreads,
KvStateRequestStats stats)
Initializes the
client proxy responsible for receiving requests
from the external (to the cluster) client and forwarding them internally. |
static KvStateServer |
createKvStateServer(String address,
Iterator<Integer> ports,
int eventLoopThreads,
int queryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Initializes the
server responsible for sending the requested internal
state to the client proxy . |
public static KvStateClientProxy createKvStateClientProxy(String address, Iterator<Integer> ports, int eventLoopThreads, int queryThreads, KvStateRequestStats stats)
client proxy
responsible for receiving requests
from the external (to the cluster) client and forwarding them internally.address
- the address to bind to.ports
- the range of ports the proxy will attempt to listen to (see QueryableStateOptions.PROXY_PORT_RANGE
).eventLoopThreads
- the number of threads to be used to process incoming requests.queryThreads
- the number of threads to be used to send the actual state.stats
- statistics to be gathered about the incoming requests.client proxy
.public static KvStateServer createKvStateServer(String address, Iterator<Integer> ports, int eventLoopThreads, int queryThreads, KvStateRegistry kvStateRegistry, KvStateRequestStats stats)
server
responsible for sending the requested internal
state to the client proxy
.address
- the address to bind to.ports
- the range of ports the state server will attempt to listen to (see QueryableStateOptions.SERVER_PORT_RANGE
).eventLoopThreads
- the number of threads to be used to process incoming requests.queryThreads
- the number of threads to be used to send the actual state.kvStateRegistry
- the registry with the queryable state.stats
- statistics to be gathered about the incoming requests.state server
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.