Package io.grpc.protobuf.services

Class HealthCheckingLoadBalancerFactory

java.lang.Object

io.grpc.LoadBalancer.Factory

io.grpc.protobuf.services.HealthCheckingLoadBalancerFactory

final class HealthCheckingLoadBalancerFactory
extends LoadBalancer.Factory

Wraps a LoadBalancer and implements the client-side health-checking (https://github.com/grpc/proposal/blob/master/A17-client-side-health-checking.md). The Subchannel received by the states wrapped LoadBalancer will be determined by health-checking.

Note the original LoadBalancer must call Helper.createSubchannel() from the SynchronizationContext, or it will throw.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	HealthCheckingLoadBalancerFactory.HealthCheckingLoadBalancer
private final class	HealthCheckingLoadBalancerFactory.HealthCheckState
private final class	HealthCheckingLoadBalancerFactory.HelperImpl
(package private) static final class	HealthCheckingLoadBalancerFactory.SubchannelImpl

Field Summary

Fields

Modifier and Type	Field	Description
private final BackoffPolicy.Provider	backoffPolicyProvider
private final LoadBalancer.Factory	delegateFactory
private static final Logger	logger
private final com.google.common.base.Supplier<com.google.common.base.Stopwatch>	stopwatchSupplier

Constructor Summary

Constructors

Constructor	Description
HealthCheckingLoadBalancerFactory(LoadBalancer.Factory delegateFactory, BackoffPolicy.Provider backoffPolicyProvider, com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier)

Method Summary

Modifier and Type	Method	Description
LoadBalancer	newLoadBalancer(LoadBalancer.Helper helper)	Creates a LoadBalancer that will be used inside a channel.

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final Logger logger

delegateFactory

private final LoadBalancer.Factory delegateFactory

backoffPolicyProvider

private final BackoffPolicy.Provider backoffPolicyProvider

stopwatchSupplier

private final com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier

Constructor Details

HealthCheckingLoadBalancerFactory

public HealthCheckingLoadBalancerFactory(LoadBalancer.Factory delegateFactory,
 BackoffPolicy.Provider backoffPolicyProvider,
 com.google.common.base.Supplier<com.google.common.base.Stopwatch> stopwatchSupplier)

Method Details

newLoadBalancer

public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper)

Description copied from class: LoadBalancer.Factory

Creates a LoadBalancer that will be used inside a channel.

Specified by:

newLoadBalancer in class LoadBalancer.Factory