Constructor and Description |
---|
KvStateClientProxyHandler(KvStateClientProxyImpl proxy,
int queryExecutorThreads,
MessageSerializer<KvStateRequest,KvStateResponse> serializer,
KvStateRequestStats stats)
Create the handler used by the
KvStateClientProxyImpl . |
KvStateClientProxyImpl(InetAddress bindAddress,
Iterator<Integer> bindPortIterator,
Integer numEventLoopThreads,
Integer numQueryThreads,
KvStateRequestStats stats)
Creates the Queryable State Client Proxy.
|
Constructor and Description |
---|
AbstractServerHandler(AbstractServerBase<REQ,RESP> server,
MessageSerializer<REQ,RESP> serializer,
KvStateRequestStats stats)
Create the handler.
|
Client(String clientName,
int numEventLoopThreads,
MessageSerializer<REQ,RESP> serializer,
KvStateRequestStats stats)
Creates a client with the specified number of event loop threads.
|
Modifier and Type | Class and Description |
---|---|
class |
AtomicKvStateRequestStats
Atomic
KvStateRequestStats implementation. |
class |
DisabledKvStateRequestStats
Disabled
KvStateRequestStats implementation. |
Constructor and Description |
---|
KvStateServerHandler(KvStateServerImpl server,
KvStateRegistry kvStateRegistry,
MessageSerializer<KvStateInternalRequest,KvStateResponse> serializer,
KvStateRequestStats stats)
Create the handler used by the
KvStateServerImpl . |
KvStateServerImpl(InetAddress bindAddress,
Iterator<Integer> bindPortIterator,
Integer numEventLoopThreads,
Integer numQueryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Creates the state server.
|
Modifier and Type | Method and Description |
---|---|
static KvStateClientProxy |
QueryableStateUtils.createKvStateClientProxy(InetAddress 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 |
QueryableStateUtils.createKvStateServer(InetAddress 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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.