Package 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 ARequestConcurrencyController
that also allows toReservableRequestConcurrencyController.tryReserve()
a connection for exclusive use.ServiceDiscovererUtils.TwoIntsConsumer Represents an operation that accepts twoint
-valued arguments and returns no result. -
Class Summary Class Description DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> An implementation ofClientGroup
that can be used for partitioned client use-cases wherePartitionAttributes
are discovered throughPartitionedServiceDiscovererEvent
s.IgnoreConsumedEvent<T> AConsumableEvent
which ignoresIgnoreConsumedEvent.eventConsumed()
.RequestConcurrencyControllers Factory for commonRequestConcurrencyController
s.ReservableRequestConcurrencyControllers Factory for commonReservableRequestConcurrencyController
s.ServiceDiscovererUtils A set of utility functions forServiceDiscoverer
. -
Enum Summary Enum Description RequestConcurrencyController.Result Result of theRequestConcurrencyController.tryRequest()
call. -
Exception Summary Exception Description MaxRequestLimitExceededRejectedSubscribeException Exception raised when more concurrent requests have been issued on a connection than is allowed.