Package io.servicetalk.client.api

Class TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

java.lang.Object

io.servicetalk.client.api.TransportObserverConnectionFactoryFilter<ResolvedAddress,C>

Type Parameters:

ResolvedAddress - The type of a resolved address that can be used for connecting.

C - The type of connections created by the ConnectionFactory decorated by this filter.

All Implemented Interfaces:

ConnectionFactoryFilter<ResolvedAddress,C>, ExecutionStrategyInfluencer<ExecutionStrategy>

public final class TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>
extends Object
implements ConnectionFactoryFilter<ResolvedAddress,C>

A ConnectionFactoryFilter that configures a TransportObserver for new connections.

Constructor Summary

Constructors

Constructor	Description
TransportObserverConnectionFactoryFilter(TransportObserver observer)	Creates a new instance.
TransportObserverConnectionFactoryFilter(Function<ResolvedAddress,TransportObserver> observerFactory)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
ConnectionFactory<ResolvedAddress,C>	create(ConnectionFactory<ResolvedAddress,C> original)	Decorates the passed original ConnectionFactory to add the filtering logic.
ExecutionStrategy	requiredOffloads()	Return an ExecutionStrategy that describes the offloads required by the influencer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.servicetalk.client.api.ConnectionFactoryFilter

append

Constructor Details

TransportObserverConnectionFactoryFilter

public TransportObserverConnectionFactoryFilter(TransportObserver observer)

Creates a new instance.

Parameters:

observer - TransportObserver to use for new connections

TransportObserverConnectionFactoryFilter

public TransportObserverConnectionFactoryFilter(Function<ResolvedAddress,TransportObserver> observerFactory)

Creates a new instance.

Parameters:

observerFactory - a factory to create a TransportObserver for new connections per TransportObserverConnectionFactoryFilter. May return null to avoid configuring TransportObserver for some addresses.

Method Details

create

public ConnectionFactory<ResolvedAddress,C> create(ConnectionFactory<ResolvedAddress,C> original)

Description copied from interface: ConnectionFactoryFilter

Decorates the passed original ConnectionFactory to add the filtering logic.

Specified by:

create in interface ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

Parameters:

original - ConnectionFactory to filter.

Returns:

Decorated ConnectionFactory that contains the filtering logic.

requiredOffloads

public ExecutionStrategy requiredOffloads()

Description copied from interface: ConnectionFactoryFilter

Return an ExecutionStrategy that describes the offloads required by the influencer.

If the returned strategy extends ConnectExecutionStrategy then the connection creation or accept may be offloaded.

If the returned strategy extends HttpExecutionStrategy then the HTTP execution strategy will be applied to the connections created.

A utility class provides the ability to combine connect and HTTP execution strategies, io.servicetalk.http.api.ConnectAndHttpExecutionStrategy.

Specified by:

requiredOffloads in interface ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable>

Specified by:

requiredOffloads in interface ExecutionStrategyInfluencer<ResolvedAddress>

Returns:

the ExecutionStrategy required by the influencer.