Contents

# frozen_string_literal: true

# rubocop:disable Lint/UnusedMethodArgument
require "opentracing"
require "grpc"

module Labkit
  module Tracing
    # GRPCInterceptor is a client-side GRPC interceptor
    # for instrumenting GRPC calls with distributed tracing
    class GRPCInterceptor < GRPC::ClientInterceptor
      include Singleton

      def request_response(request:, call:, method:, metadata:)
        wrap_with_tracing(method, "unary", metadata) { yield }
      end

      def client_streamer(requests:, call:, method:, metadata:)
        wrap_with_tracing(method, "client_stream", metadata) { yield }
      end

      def server_streamer(request:, call:, method:, metadata:)
        wrap_with_tracing(method, "server_stream", metadata) { yield }
      end

      def bidi_streamer(requests:, call:, method:, metadata:)
        wrap_with_tracing(method, "bidi_stream", metadata) { yield }
      end

      private

      def wrap_with_tracing(method, grpc_type, metadata)
        tags = { "component" => "grpc", "span.kind" => "client", "grpc.method" => method, "grpc.type" => grpc_type }

        TracingUtils.with_tracing(operation_name: "grpc:#{method}", tags: tags) do |span|
          OpenTracing.inject(span.context, OpenTracing::FORMAT_TEXT_MAP, metadata)

          yield
        end
      end
    end
  end
end

# rubocop:enable Lint/UnusedMethodArgument

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
gitlab-labkit-0.2.0	lib/labkit/tracing/grpc_interceptor.rb