Searched refs:StreamTracer (Results 1 – 12 of 12) sorted by relevance
29 import io.grpc.StreamTracer;41 public static final StatsTraceContext NOOP = new StatsTraceContext(new StreamTracer[0]);43 private final StreamTracer[] tracers;56 StreamTracer[] tracers = new StreamTracer[factories.size()]; in newClientContext()71 StreamTracer[] tracers = new StreamTracer[factories.size()]; in newServerContext()79 StatsTraceContext(StreamTracer[] tracers) { in StatsTraceContext()87 public List<StreamTracer> getTracersForTest() { in getTracersForTest()97 for (StreamTracer tracer : tracers) { in clientOutboundHeaders()108 for (StreamTracer tracer : tracers) { in clientInboundHeaders()120 for (StreamTracer tracer : tracers) { in serverFilterContext()[all …]
34 import io.grpc.StreamTracer;
38 import io.grpc.StreamTracer;
20 import io.grpc.StreamTracer;88 public static class TestBaseStreamTracer extends StreamTracer implements TestStreamTracer {
80 return new StreamTracer(); in newClientStreamTracer()128 private class StreamTracer extends ClientStreamTracer { class in GrpclbClientLoadRecorder
26 public abstract class ClientStreamTracer extends StreamTracer {
28 public abstract class StreamTracer { class
27 public abstract class ServerStreamTracer extends StreamTracer {
40 import io.grpc.StreamTracer;93 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer});330 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer});
42 import io.grpc.StreamTracer;379 StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); in getRequest()412 StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[] {tracer}); in writeMessage_closesStream()
30 import io.grpc.StreamTracer;73 statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); in setUp()
60 import io.grpc.StreamTracer;236 List<StreamTracer> tracers = statsTraceCtx.getTracersForTest(); in streamTracerCreated()