@ThreadSafe public interface ControlClientPool
InstructionRequestHandlers
.
Incoming instruction handlers usually come from the control plane gRPC service. Typical use:
// Within owner of the pool, who may or may not own the control plane server as well ControlClientPool pool = ... FnApiControlClientPoolService service = FnApiControlClientPoolService.offeringClientsToSink(pool.getSink(), headerAccessor) // Incoming gRPC control connections will now be added to the client pool. // Within code that interacts with the instruction handler. The get call blocks until an // incoming client is available: ControlClientSource clientSource = ... InstructionRequestHandler instructionHandler = clientSource.get("worker-id");
All ControlClientPool
implementations must be thread-safe.
Modifier and Type | Interface and Description |
---|---|
static interface |
ControlClientPool.Sink
A sink for
InstructionRequestHandlers keyed by worker id. |
static interface |
ControlClientPool.Source
A source of
InstructionRequestHandlers . |
Modifier and Type | Method and Description |
---|---|
ControlClientPool.Sink |
getSink()
Sink for control clients.
|
ControlClientPool.Source |
getSource()
Source of control clients.
|
ControlClientPool.Sink getSink()
ControlClientPool.Source getSource()