Package io.grpc.opentelemetry

Class OpenTelemetryTracingModule.ServerTracer

  • Enclosing class:
    OpenTelemetryTracingModule
    private final class OpenTelemetryTracingModule.ServerTracer
extends io.grpc.ServerStreamTracer

    • Nested Class Summary

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

        io.grpc.ServerStreamTracer.Factory, io.grpc.ServerStreamTracer.ServerCallInfo<ReqT extends java.lang.Object,​RespT extends java.lang.Object>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private int seqNo  
      private io.opentelemetry.api.trace.Span span  
      (package private) int streamClosed  

    • Constructor Summary

      Constructors 
      Constructor Description
      ServerTracer​(java.lang.String fullMethodName, io.opentelemetry.api.trace.Span remoteSpan)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.grpc.Context filterContext​(io.grpc.Context context)  
      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)
      Record a finished stream and mark the current time as the end time.

      • Methods inherited from class io.grpc.ServerStreamTracer

        serverCallStarted, serverCallStarted

      • 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

      • streamClosed

        volatile int streamClosed

      • seqNo

        private int seqNo

    • Constructor Detail

      • ServerTracer

        ServerTracer​(java.lang.String fullMethodName,
             @Nullable
             io.opentelemetry.api.trace.Span remoteSpan)

    • Method Detail

      • streamClosed

        public void streamClosed​(io.grpc.Status status)
        Record a finished stream and mark the current time as the end time.

        Can be called from any thread without synchronization. Calling it the second time or more is a no-op.

        Overrides:
        streamClosed in class io.grpc.StreamTracer

      • filterContext

        public io.grpc.Context filterContext​(io.grpc.Context context)
        Overrides:
        filterContext in class io.grpc.ServerStreamTracer

      • 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