Package io.servicetalk.loadbalancer

Class DelegatingLoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

java.lang.Object

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

Type Parameters:

ResolvedAddress - The resolved address type.

C - The type of connection.

All Implemented Interfaces:

LoadBalancerBuilder<ResolvedAddress,C>

public class DelegatingLoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>
extends Object
implements LoadBalancerBuilder<ResolvedAddress,C>

A LoadBalancerBuilder that delegates all methods to another LoadBalancerBuilder.

Constructor Summary

Constructors

Constructor	Description
DelegatingLoadBalancerBuilder(LoadBalancerBuilder<ResolvedAddress,C> delegate)	Creates a new builder which delegates to the provided LoadBalancerBuilder.

Method Summary

Modifier and Type	Method	Description
LoadBalancerBuilder<ResolvedAddress,C>	backgroundExecutor(Executor backgroundExecutor)	Set the background Executor to use for determining time and scheduling background tasks such as those associated with outlier detection.
LoadBalancerFactory<ResolvedAddress,C>	build()	Builds the LoadBalancerFactory configured by this builder.
LoadBalancerBuilder<ResolvedAddress,C>	connectionPoolConfig(ConnectionPoolConfig connectionPoolConfig)	Set the ConnectionPoolStrategy to use with this load balancer.
protected final LoadBalancerBuilder<ResolvedAddress,C>	delegate()	Returns the DelegatingLoadBalancerBuilder delegate.
LoadBalancerBuilder<ResolvedAddress,C>	loadBalancerObserver(LoadBalancerObserver loadBalancerObserver)	Set the LoadBalancerObserver to use with this load balancer.
LoadBalancerBuilder<ResolvedAddress,C>	loadBalancingPolicy(LoadBalancingPolicy<ResolvedAddress,C> loadBalancingPolicy)	Set the loadBalancingPolicy to use with this load balancer.
LoadBalancerBuilder<ResolvedAddress,C>	outlierDetectorConfig(OutlierDetectorConfig outlierDetectorConfig)	Set the OutlierDetectorConfig to use with this load balancer.

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingLoadBalancerBuilder

public DelegatingLoadBalancerBuilder(LoadBalancerBuilder<ResolvedAddress,C> delegate)

Creates a new builder which delegates to the provided LoadBalancerBuilder.

Parameters:

delegate - the delegate builder.

Method Details

delegate

protected final LoadBalancerBuilder<ResolvedAddress,C> delegate()

Returns the DelegatingLoadBalancerBuilder delegate.

Returns:

Delegate DelegatingLoadBalancerBuilder.

loadBalancingPolicy

public LoadBalancerBuilder<ResolvedAddress,C> loadBalancingPolicy(LoadBalancingPolicy<ResolvedAddress,C> loadBalancingPolicy)

Description copied from interface: LoadBalancerBuilder

Set the loadBalancingPolicy to use with this load balancer.

Specified by:

loadBalancingPolicy in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

loadBalancingPolicy - the loadBalancingPolicy to use

Returns:

this

loadBalancerObserver

public LoadBalancerBuilder<ResolvedAddress,C> loadBalancerObserver(@Nullable
 LoadBalancerObserver loadBalancerObserver)

Description copied from interface: LoadBalancerBuilder

Set the LoadBalancerObserver to use with this load balancer.

Specified by:

loadBalancerObserver in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

loadBalancerObserver - the LoadBalancerObserver to use, or null to not use an observer.

Returns:

{code this}

outlierDetectorConfig

public LoadBalancerBuilder<ResolvedAddress,C> outlierDetectorConfig(OutlierDetectorConfig outlierDetectorConfig)

Description copied from interface: LoadBalancerBuilder

Set the OutlierDetectorConfig to use with this load balancer. The outlier detection system works in conjunction with the load balancing policy to attempt to avoid hosts that have been determined to be unhealthy or slow. The details of the selection process are determined by the LoadBalancingPolicy while the health status is determined by the outlier detection configuration.

Specified by:

outlierDetectorConfig in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

outlierDetectorConfig - the OutlierDetectorConfig to use, or null to use the default outlier detection.

Returns:

{code this}

See Also:

• LoadBalancerBuilder.loadBalancingPolicy(LoadBalancingPolicy)

backgroundExecutor

public LoadBalancerBuilder<ResolvedAddress,C> backgroundExecutor(Executor backgroundExecutor)

Description copied from interface: LoadBalancerBuilder

Set the background Executor to use for determining time and scheduling background tasks such as those associated with outlier detection.

Specified by:

backgroundExecutor in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

backgroundExecutor - Executor to use as a time source and for scheduling background tasks.

Returns:

this.

connectionPoolConfig

public LoadBalancerBuilder<ResolvedAddress,C> connectionPoolConfig(ConnectionPoolConfig connectionPoolConfig)

Description copied from interface: LoadBalancerBuilder

Set the ConnectionPoolStrategy to use with this load balancer.

Specified by:

connectionPoolConfig in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Parameters:

connectionPoolConfig - the factory of connection pooling strategies to use.

Returns:

this

build

public LoadBalancerFactory<ResolvedAddress,C> build()

Description copied from interface: LoadBalancerBuilder

Builds the LoadBalancerFactory configured by this builder.

Specified by:

build in interface LoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection>

Returns:

a new instance of LoadBalancerFactory with settings from this builder.