Package io.servicetalk.loadbalancer

Class RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

java.lang.Object

io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C>

Type Parameters:

ResolvedAddress - The resolved address type.

C - The type of connection.

All Implemented Interfaces:

LoadBalancerFactory<ResolvedAddress,C>, ExecutionStrategyInfluencer<ExecutionStrategy>

@Deprecated
public final class RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>
extends Object
implements LoadBalancerFactory<ResolvedAddress,C>

Deprecated.

this class will be made package-private in the future, use RoundRobinLoadBalancers to create RoundRobinLoadBalancerBuilder.

LoadBalancerFactory that creates LoadBalancer instances which use a round-robin strategy for selecting connections from a pool of addresses.

For more information, see javadoc for RoundRobinLoadBalancerBuilder.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	RoundRobinLoadBalancerFactory.Builder<ResolvedAddress,C extends LoadBalancedConnection>	Deprecated. this class will be made package-private in the future, rely on the RoundRobinLoadBalancerBuilder instead.

Method Summary

Modifier and Type	Method	Description
LoadBalancer<C>	newLoadBalancer(Publisher<? extends Collection<? extends ServiceDiscovererEvent<ResolvedAddress>>> eventPublisher, ConnectionFactory<ResolvedAddress,C> connectionFactory, String targetResource)	Deprecated. Create a new LoadBalancer.
<T extends C> LoadBalancer<T>	newLoadBalancer(String targetResource, Publisher<? extends Collection<? extends ServiceDiscovererEvent<ResolvedAddress>>> eventPublisher, ConnectionFactory<ResolvedAddress,T> connectionFactory)	Deprecated.
ExecutionStrategy	requiredOffloads()	Deprecated. 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.LoadBalancerFactory

newLoadBalancer

Method Details

newLoadBalancer

@Deprecated
public <T extends C> LoadBalancer<T> newLoadBalancer(String targetResource,
 Publisher<? extends Collection<? extends ServiceDiscovererEvent<ResolvedAddress>>> eventPublisher,
 ConnectionFactory<ResolvedAddress,T> connectionFactory)

Deprecated.

Description copied from interface: LoadBalancerFactory

Create a new LoadBalancer.

Specified by:

newLoadBalancer in interface LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

Type Parameters:

T - Type of connections created by the passed ConnectionFactory.

Parameters:

targetResource - A String representation of the target resource for which the created instance will perform load balancing. Bear in mind, load balancing is performed over the a collection of hosts provided via the eventPublisher which may not correspond directly to a single unresolved address, but potentially a merged collection.

eventPublisher - A stream of Collection<ServiceDiscovererEvent> which the LoadBalancer can use to connect to physical hosts. Typically generated from ServiceDiscoverer.

connectionFactory - ConnectionFactory that the returned LoadBalancer will use to generate new connections. Returned LoadBalancer will own the responsibility for this ConnectionFactory and hence will call AsyncCloseable.closeAsync() when AsyncCloseable.closeAsync() is called.

Returns:

a new LoadBalancer.

newLoadBalancer

public LoadBalancer<C> newLoadBalancer(Publisher<? extends Collection<? extends ServiceDiscovererEvent<ResolvedAddress>>> eventPublisher,
 ConnectionFactory<ResolvedAddress,C> connectionFactory,
 String targetResource)

Deprecated.

Description copied from interface: LoadBalancerFactory

Create a new LoadBalancer.

Specified by:

newLoadBalancer in interface LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

eventPublisher - A stream of Collection<ServiceDiscovererEvent> which the LoadBalancer can use to connect to physical hosts. Typically generated from ServiceDiscoverer.

connectionFactory - ConnectionFactory that the returned LoadBalancer will use to generate new connections. Returned LoadBalancer will own the responsibility for this ConnectionFactory and hence will call AsyncCloseable.closeAsync() when AsyncCloseable.closeAsync() is called.

targetResource - A String representation of the target resource for which the created instance will perform load balancing. Bear in mind, load balancing is performed over the collection of hosts provided via the eventPublisher which may not correspond directly to a single unresolved address, but potentially a merged collection.

Returns:

a new LoadBalancer.

requiredOffloads

public ExecutionStrategy requiredOffloads()

Deprecated.

Description copied from interface: ExecutionStrategyInfluencer

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

Specified by:

requiredOffloads in interface ExecutionStrategyInfluencer<ResolvedAddress>

Specified by:

requiredOffloads in interface LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

Returns:

the ExecutionStrategy required by the influencer.