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