| Interface | Description |
|---|---|
| ClientGroup<Key,Client extends ListenableAsyncCloseable> |
A data-structure capable of holding arbitrary number of clients and bridging lifecycle events across all clients
managed by the group.
|
| ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> |
A factory for creating new connections.
|
| ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> |
A contract to decorate
ConnectionFactory instances for the purpose of filtering. |
| ConsumableEvent<T> |
A container for an event that requires acknowledgement when the event is consumed via
ConsumableEvent.eventConsumed(). |
| GroupKey<Address> |
Identifies a client within a group of clients, and provides enough information to create a client if non exist.
|
| LimitingConnectionFactoryFilter.ConnectionLimiter<ResolvedAddress,C extends ListenableAsyncCloseable> |
A contract to limit number of connections created by
LimitingConnectionFactoryFilter. |
| LoadBalancedAddress<C extends LoadBalancedConnection> |
An address managed by a
LoadBalancer. |
| LoadBalancedConnection |
A connection managed by a
LoadBalancer. |
| LoadBalancer<C extends LoadBalancedConnection> |
Given multiple
SocketAddresses select the most desired SocketAddress to use. |
| LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection> |
A factory for creating
LoadBalancer instances. |
| ScoreSupplier |
Enables components to expose a score.
|
| ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> |
Represents the interaction pattern with a service discovery system.
|
| ServiceDiscovererEvent<ResolvedAddress> |
Notification from the Service Discovery system that availability for an address has changed.
|
| ServiceDiscovererFilterFactory<UnresolvedAddress,ResolvedAddress,Event extends ServiceDiscovererEvent<ResolvedAddress>> |
A factory for
ServiceDiscovererFilter. |
| Class | Description |
|---|---|
| AbstractRetryingFilterBuilder<Builder extends AbstractRetryingFilterBuilder<Builder,Filter,Meta>,Filter,Meta> |
An abstract builder for retrying filters.
|
| AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta> |
A read-only settings for retryable filters.
|
| DefaultGroupKey<Address> |
A default implementation of
GroupKey. |
| DefaultServiceDiscovererEvent<T> |
Default implementation of
ServiceDiscovererEvent. |
| DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> |
A
ConnectionFactory that delegates all methods to another ConnectionFactory. |
| LimitingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> |
A
ConnectionFactory that limits the total number of active connections created using this
ConnectionFactory. |
| ServiceDiscovererFilter<UnresolvedAddress,ResolvedAddress,Event extends ServiceDiscovererEvent<ResolvedAddress>> |
A
ServiceDiscoverer that delegates all methods to a different ServiceDiscoverer. |
| Exception | Description |
|---|---|
| ConnectionClosedException |
Thrown when the connection is no longer available.
|
| ConnectionRejectedException |
Thrown when a newly created connection was rejected.
|
| ConnectTimeoutException |
Throws when a connect operations failed because of a timeout.
|
| MaxRequestLimitExceededException |
Exception raised when more concurrent requests have been issued on a connection than is allowed.
|
| NoAvailableHostException |
Thrown when no host is available but at least one is required.
|
| RetryableConnectException |
Throws when a connect operations failed.
|