Class: GrpcInterceptors::Server::OpenTelemetryTracingInstrument

Inherits:

GRPC::ServerInterceptor

• Object
• GRPC::ServerInterceptor
• GrpcInterceptors::Server::OpenTelemetryTracingInstrument

Defined in:

lib/grpc_interceptors/server/open_telemetry_tracing_instrument.rb

Overview

github.com/grpc/grpc/blob/master/src/ruby/lib/grpc/generic/interceptors.rb

Instance Method Summary

• #request_response(request: nil, call: nil, method: nil) ⇒ Object

Instance Method Details

#request_response(request: nil, call: nil, method: nil) ⇒ Object

# File 'lib/grpc_interceptors/server/open_telemetry_tracing_instrument.rb', line 9

def request_response(request: nil, call: nil, method: nil)
  parent_context = OpenTelemetry.propagation.extract(call.metadata)
  route_name = GrpcHelper.route_name(method)
  attributes = tracing_attributes(method)
  kind = OpenTelemetry::Trace::SpanKind::SERVER
  span = GrpcHelper.tracer.start_span(
    route_name,
    with_parent: parent_context,
    attributes: attributes,
    kind: kind
  )

  yield

  span.finish
rescue StandardError => e
  OpenTelemetry.handle_error(exception: e)

  raise e
ensure
  span.finish if span.recording?
end