@ElementsAreNonnullByDefault

Package io.servicetalk.client.api

Interface Summary

Interface	Description
AutoRetryStrategyProvider	A provider for AutoRetryStrategyProvider.AutoRetryStrategy.
AutoRetryStrategyProvider.AutoRetryStrategy	A strategy to use for automatic retries.
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.
LoadBalancerReadyEvent	A hint from LoadBalancer.eventStream() that the internal state of the LoadBalancer is ready such LoadBalancer.selectConnection(Predicate) is not likely to fail.
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.

Class Summary

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.
DefaultAutoRetryStrategyProvider	Default implementation for AutoRetryStrategyProvider.
DefaultAutoRetryStrategyProvider.Builder	A builder for DefaultAutoRetryStrategyProvider.
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.
TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactoryFilter that configures a TransportObserver for new connections.

Exception Summary

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.