Class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState

java.lang.Object

io.grpc.xds.orca.OrcaOobUtil.OrcaReportingHelper.OrcaReportingState

All Implemented Interfaces:

io.grpc.LoadBalancer.SubchannelStateListener

Enclosing class:

OrcaOobUtil.OrcaReportingHelper

private final class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState
extends Object
implements io.grpc.LoadBalancer.SubchannelStateListener

An OrcaOobUtil.OrcaReportingHelper.OrcaReportingState is a client of ORCA service running on a single backend.

All methods are run from syncContext.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream

Field Summary

Fields

Modifier and Type	Field	Description
private io.grpc.internal.BackoffPolicy	backoffPolicy
private final Map<OrcaOobUtil.OrcaOobReportListener, OrcaOobUtil.OrcaReportingConfig>	configs
private boolean	disabled
private OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream	orcaRpc
private OrcaOobUtil.OrcaReportingConfig	overallConfig
private final Runnable	retryTask
private io.grpc.SynchronizationContext.ScheduledHandle	retryTimer
private boolean	started
private io.grpc.ConnectivityStateInfo	state
private io.grpc.LoadBalancer.SubchannelStateListener	stateListener
private io.grpc.LoadBalancer.Subchannel	subchannel
private io.grpc.ChannelLogger	subchannelLogger
private final io.grpc.SynchronizationContext	syncContext
private final ScheduledExecutorService	timeService

Constructor Summary

Constructors

Constructor	Description
OrcaReportingState(io.grpc.SynchronizationContext syncContext, ScheduledExecutorService timeService)

Method Summary

Modifier and Type	Method	Description
(package private) void	adjustOrcaReporting()
(package private) void	init(io.grpc.LoadBalancer.Subchannel subchannel, io.grpc.LoadBalancer.SubchannelStateListener stateListener)
(package private) boolean	isRetryTimerPending()
void	onSubchannelState(io.grpc.ConnectivityStateInfo newState)
(package private) void	setListener(OrcaOobUtil.SubchannelImpl orcaSubchannel, OrcaOobUtil.OrcaOobReportListener listener, OrcaOobUtil.OrcaReportingConfig config)
private void	setReportingConfig(OrcaOobUtil.OrcaReportingConfig config)
(package private) void	startRpc()
(package private) void	stopRpc(String msg)
String	toString()

Methods inherited from class Object

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

Field Details

syncContext

private final io.grpc.SynchronizationContext syncContext

timeService

private final ScheduledExecutorService timeService

configs

private final Map<OrcaOobUtil.OrcaOobReportListener, OrcaOobUtil.OrcaReportingConfig> configs

subchannel

@Nullable
private io.grpc.LoadBalancer.Subchannel subchannel

subchannelLogger

@Nullable
private io.grpc.ChannelLogger subchannelLogger

stateListener

@Nullable
private io.grpc.LoadBalancer.SubchannelStateListener stateListener

backoffPolicy

@Nullable
private io.grpc.internal.BackoffPolicy backoffPolicy

orcaRpc

@Nullable
private OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream orcaRpc

retryTimer

@Nullable
private io.grpc.SynchronizationContext.ScheduledHandle retryTimer

overallConfig

@Nullable
private OrcaOobUtil.OrcaReportingConfig overallConfig

retryTask

private final Runnable retryTask

state

private io.grpc.ConnectivityStateInfo state

disabled

private boolean disabled

started

private boolean started

Constructor Details

OrcaReportingState

OrcaReportingState(io.grpc.SynchronizationContext syncContext,
 ScheduledExecutorService timeService)

Method Details

init

void init(io.grpc.LoadBalancer.Subchannel subchannel,
 io.grpc.LoadBalancer.SubchannelStateListener stateListener)

setListener

void setListener(OrcaOobUtil.SubchannelImpl orcaSubchannel,
 OrcaOobUtil.OrcaOobReportListener listener,
 OrcaOobUtil.OrcaReportingConfig config)

setReportingConfig

private void setReportingConfig(OrcaOobUtil.OrcaReportingConfig config)

onSubchannelState

public void onSubchannelState(io.grpc.ConnectivityStateInfo newState)

Specified by:

onSubchannelState in interface io.grpc.LoadBalancer.SubchannelStateListener

adjustOrcaReporting

void adjustOrcaReporting()

startRpc

void startRpc()

stopRpc

void stopRpc(String msg)

isRetryTimerPending

boolean isRetryTimerPending()

toString

public String toString()

Overrides:

toString in class Object