Package io.grpc.opentelemetry

Class OpenTelemetryTracingModule.ClientTracer

java.lang.Object
io.grpc.StreamTracer
io.grpc.ClientStreamTracer
io.grpc.opentelemetry.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 final io.opentelemetry.api.trace.Span
    parentSpan
     
    (package private) int
    seqNo
     
    private final 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

    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 Details

    • 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 Details

    • ClientTracer

      ClientTracer(io.opentelemetry.api.trace.Span span, io.opentelemetry.api.trace.Span parentSpan)

  • Method Details

    • 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