| Interface | Description |
|---|---|
| DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> |
Factory for building partitioned clients.
|
| LoadBalancerReadyEvent |
A hint from
LoadBalancer.eventStream() that the internal state of the LoadBalancer is ready such
LoadBalancer.selectConnection(Predicate) is not likely to fail. |
| 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. |
| 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 PartitionedServiceDiscovererEvents. |
| IgnoreConsumedEvent<T> |
A
ConsumableEvent which ignores IgnoreConsumedEvent.eventConsumed(). |
| RequestConcurrencyControllers |
Factory for common
RequestConcurrencyControllers. |
| ReservableRequestConcurrencyControllers |
Factory for common
ReservableRequestConcurrencyControllers. |
| ServiceDiscovererUtils |
A set of utility functions for
ServiceDiscoverer. |
| Enum | Description |
|---|---|
| RequestConcurrencyController.Result |
Result of the
RequestConcurrencyController.tryRequest() call. |
| Exception | Description |
|---|---|
| MaxRequestLimitExceededRejectedSubscribeException |
Exception raised when more concurrent requests have been issued on a connection than is allowed.
|