Class ClusterImplLoadBalancer.CountingStreamTracerFactory

java.lang.Object

io.grpc.ClientStreamTracer.Factory

io.grpc.xds.ClusterImplLoadBalancer.CountingStreamTracerFactory

Enclosing class:

ClusterImplLoadBalancer

private static final class ClusterImplLoadBalancer.CountingStreamTracerFactory
extends io.grpc.ClientStreamTracer.Factory

Field Summary

Fields

Modifier and Type	Field	Description
private final io.grpc.ClientStreamTracer.Factory	delegate
private final AtomicLong	inFlights
private final LoadStatsManager2.ClusterLocalityStats	stats

Constructor Summary

Constructors

Modifier	Constructor	Description
private	CountingStreamTracerFactory(LoadStatsManager2.ClusterLocalityStats stats, AtomicLong inFlights, io.grpc.ClientStreamTracer.Factory delegate)

Method Summary

Modifier and Type	Method	Description
io.grpc.ClientStreamTracer	newClientStreamTracer(io.grpc.ClientStreamTracer.StreamInfo info, io.grpc.Metadata headers)

Methods inherited from class Object

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

Field Details

stats

private final LoadStatsManager2.ClusterLocalityStats stats

inFlights

private final AtomicLong inFlights

delegate

@Nullable
private final io.grpc.ClientStreamTracer.Factory delegate

Constructor Details

CountingStreamTracerFactory

private CountingStreamTracerFactory(LoadStatsManager2.ClusterLocalityStats stats,
 AtomicLong inFlights,
 @Nullable
 io.grpc.ClientStreamTracer.Factory delegate)

Method Details

newClientStreamTracer

public io.grpc.ClientStreamTracer newClientStreamTracer(io.grpc.ClientStreamTracer.StreamInfo info,
 io.grpc.Metadata headers)

Overrides:

newClientStreamTracer in class io.grpc.ClientStreamTracer.Factory