io.servicetalk.client.api.internal

Interface Summary
Interface	Description
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client>	Factory for building partitioned clients.
RequestConcurrencyController	An interface which allows controlling reserving connections which maybe used concurrently.
ReservableRequestConcurrencyController	A `RequestConcurrencyController` that also allows to `ReservableRequestConcurrencyController.tryReserve()` a connection for exclusive use.
ServiceDiscovererUtils.TwoIntsConsumer	Represents an operation that accepts two `int`-valued arguments and returns no result.

Class Summary
Class	Description
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable>	An implementation of `ClientGroup` that can be used for partitioned client use-cases where `PartitionAttributes` are discovered through `PartitionedServiceDiscovererEvent`s.
IgnoreConsumedEvent<T>	A `ConsumableEvent` which ignores `IgnoreConsumedEvent.eventConsumed()`.
RequestConcurrencyControllers	Factory for common `RequestConcurrencyController`s.
ReservableRequestConcurrencyControllers	Factory for common `ReservableRequestConcurrencyController`s.
ServiceDiscovererUtils	A set of utility functions for `ServiceDiscoverer`.

Enum Summary
Enum Description

RequestConcurrencyController.Result
Result of the RequestConcurrencyController.tryRequest() call.
Exception Summary
Exception Description

MaxRequestLimitExceededRejectedSubscribeException
Exception raised when more concurrent requests have been issued on a connection than is allowed.

Package io.servicetalk.client.api.internal