Package io.grpc.xds

Class ClusterImplLoadBalancer.CountingStreamTracerFactory

  • Enclosing class:
    ClusterImplLoadBalancer

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

      • inFlights

        private final java.util.concurrent.atomic.AtomicLong inFlights
      • delegate

        @Nullable
        private final io.grpc.ClientStreamTracer.Factory delegate
    • Constructor Detail

      • CountingStreamTracerFactory

        private CountingStreamTracerFactory​(LoadStatsManager2.ClusterLocalityStats stats,
                                            java.util.concurrent.atomic.AtomicLong inFlights,
                                            @Nullable
                                            io.grpc.ClientStreamTracer.Factory delegate)
    • Method Detail

      • newClientStreamTracer

        public io.grpc.ClientStreamTracer newClientStreamTracer​(io.grpc.ClientStreamTracer.StreamInfo info,
                                                                io.grpc.Metadata headers)
        Overrides:
        newClientStreamTracer in class io.grpc.ClientStreamTracer.Factory