Package io.grpc.opentelemetry

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