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.

use LoadBalancers to create LoadBalancerFactory instances. 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. rely on the LoadBalancers.builder(String) 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.
String	toString()	Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object