Class OpenTelemetryTracingModule.ClientTracer

  • Enclosing class:
    OpenTelemetryTracingModule

    private final class OpenTelemetryTracingModule.ClientTracer
    extends io.grpc.ClientStreamTracer
    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer

        io.grpc.ClientStreamTracer.Factory, io.grpc.ClientStreamTracer.StreamInfo
    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) boolean isPendingStream  
      private io.opentelemetry.api.trace.Span parentSpan  
      (package private) int seqNo  
      private io.opentelemetry.api.trace.Span span  
      • Fields inherited from class io.grpc.ClientStreamTracer

        NAME_RESOLUTION_DELAYED
    • Constructor Summary

      Constructors 
      Constructor Description
      ClientTracer​(io.opentelemetry.api.trace.Span span, io.opentelemetry.api.trace.Span parentSpan)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void createPendingStream()  
      void inboundMessage​(int seqNo)  
      void inboundMessageRead​(int seqNo, long optionalWireSize, long optionalUncompressedSize)  
      void inboundUncompressedSize​(long bytes)  
      void outboundMessageSent​(int seqNo, long optionalWireSize, long optionalUncompressedSize)  
      void streamClosed​(io.grpc.Status status)  
      void streamCreated​(io.grpc.Attributes transportAtts, io.grpc.Metadata headers)  
      • Methods inherited from class io.grpc.ClientStreamTracer

        addOptionalLabel, inboundHeaders, inboundHeaders, inboundTrailers, outboundHeaders
      • Methods inherited from class io.grpc.StreamTracer

        inboundWireSize, outboundMessage, outboundUncompressedSize, outboundWireSize
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • span

        private final io.opentelemetry.api.trace.Span span
      • parentSpan

        private final io.opentelemetry.api.trace.Span parentSpan
      • seqNo

        volatile int seqNo
      • isPendingStream

        boolean isPendingStream
    • Constructor Detail

      • ClientTracer

        ClientTracer​(io.opentelemetry.api.trace.Span span,
                     io.opentelemetry.api.trace.Span parentSpan)
    • Method Detail

      • streamCreated

        public void streamCreated​(io.grpc.Attributes transportAtts,
                                  io.grpc.Metadata headers)
        Overrides:
        streamCreated in class io.grpc.ClientStreamTracer
      • createPendingStream

        public void createPendingStream()
        Overrides:
        createPendingStream in class io.grpc.ClientStreamTracer
      • outboundMessageSent

        public void outboundMessageSent​(int seqNo,
                                        long optionalWireSize,
                                        long optionalUncompressedSize)
        Overrides:
        outboundMessageSent in class io.grpc.StreamTracer
      • inboundMessageRead

        public void inboundMessageRead​(int seqNo,
                                       long optionalWireSize,
                                       long optionalUncompressedSize)
        Overrides:
        inboundMessageRead in class io.grpc.StreamTracer
      • inboundMessage

        public void inboundMessage​(int seqNo)
        Overrides:
        inboundMessage in class io.grpc.StreamTracer
      • inboundUncompressedSize

        public void inboundUncompressedSize​(long bytes)
        Overrides:
        inboundUncompressedSize in class io.grpc.StreamTracer
      • streamClosed

        public void streamClosed​(io.grpc.Status status)
        Overrides:
        streamClosed in class io.grpc.StreamTracer