Package io.servicetalk.client.api

@ElementsAreNonnullByDefault package io.servicetalk.client.api

API definitions for Client use cases.

Related Packages

Package	Description
io.servicetalk.client.api.internal	Internal utilities which leverage the Client API package.
io.servicetalk.client.api.partition	Client APIs targeted at partitioned use cases.

Class	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.
ConnectionLimitReachedException	Thrown when the number of connections reached their limit for a given resource (i.e.
ConnectionRejectedException	Thrown when a newly created connection was rejected.
ConnectTimeoutException	Throws when a connect operations failed because of a timeout.
ConsumableEvent<T>	A container for an event that requires acknowledgement when the event is consumed via ConsumableEvent.eventConsumed().
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.
DelegatingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactoryFilter that delegates all methods to another ConnectionFactoryFilter.
GroupKey<Address>	Identifies a client within a group of clients, and provides enough information to create a client if non exist.
LimitingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactory that limits the total number of active connections created using this ConnectionFactory.
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, ContextMap) is not likely to fail.
NoActiveHostException	Thrown when no host is active to establish a new connection.
NoAvailableHostException	Thrown when no host is available but at least one is required.
RequestConcurrencyController	An interface which allows controlling reserving connections which maybe used concurrently.
RequestConcurrencyController.Result	Result of the RequestConcurrencyController.tryRequest() call.
RequestRejectedException	Thrown when a request was rejected before processing by the transport layer.
ReservableRequestConcurrencyController	A RequestConcurrencyController that also allows to ReservableRequestConcurrencyController.tryReserve() a connection for exclusive use.
RetryableConnectException	Throws when a connect operations failed.
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.
ServiceDiscovererEvent.Status	Status provided by the ServiceDiscoverer system that guides the actions of LoadBalancer upon the bound ServiceDiscovererEvent.address() (via ServiceDiscovererEvent).
TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>	A ConnectionFactoryFilter that configures a TransportObserver for new connections.