module NewRelic::Agent::Instrumentation::GRPC::Server::Chain

Public Class Methods

instrument!() click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 11
def self.instrument!
  # BEGIN RpcServer
  ::GRPC::RpcServer.class_eval do
    include NewRelic::Agent::Instrumentation::GRPC::Server

    def add_http2_port_with_newrelic_trace(*args)
      add_http2_port_with_tracing(*args) { add_http2_port_without_newrelic_trace(*args) }
    end

    alias add_http2_port_without_newrelic_trace add_http2_port
    alias add_http2_port add_http2_port_with_newrelic_trace

    def run_with_newrelic_trace(*args)
      run_with_tracing(*args) { run_without_newrelic_trace(*args) }
    end

    alias run_without_newrelic_trace run
    alias run run_with_newrelic_trace
    # END RpcServer
  end

  # BEGIN RpcDesc
  ::GRPC::RpcDesc.class_eval do
    include NewRelic::Agent::Instrumentation::GRPC::Server

    def handle_request_response_with_newrelic_trace(active_call, mth, inter_ctx)
      handle_with_tracing(:request_response, active_call, mth, inter_ctx) { handle_request_response_without_newrelic_trace(active_call, mth, inter_ctx) }
    end

    alias handle_request_response_without_newrelic_trace handle_request_response
    alias handle_request_response handle_request_response_with_newrelic_trace

    def handle_client_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
      handle_with_tracing(:client_streamer, active_call, mth, inter_ctx) { handle_client_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
    end

    alias handle_client_streamer_without_newrelic_trace handle_client_streamer
    alias handle_client_streamer handle_client_streamer_with_newrelic_trace

    def handle_server_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
      handle_with_tracing(:server_streamer, active_call, mth, inter_ctx) { handle_server_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
    end

    alias handle_server_streamer_without_newrelic_trace handle_server_streamer
    alias handle_server_streamer handle_server_streamer_with_newrelic_trace

    def handle_bidi_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
      handle_with_tracing(:bidi_streamer, active_call, mth, inter_ctx) { handle_bidi_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
    end

    alias handle_bidi_streamer_without_newrelic_trace handle_bidi_streamer
    alias handle_bidi_streamer handle_bidi_streamer_with_newrelic_trace
    # END RpcDesc
  end
end

Public Instance Methods

add_http2_port_with_newrelic_trace(*args) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 16
def add_http2_port_with_newrelic_trace(*args)
  add_http2_port_with_tracing(*args) { add_http2_port_without_newrelic_trace(*args) }
end
handle_bidi_streamer_with_newrelic_trace(active_call, mth, inter_ctx) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 57
def handle_bidi_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
  handle_with_tracing(:bidi_streamer, active_call, mth, inter_ctx) { handle_bidi_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
end
handle_client_streamer_with_newrelic_trace(active_call, mth, inter_ctx) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 43
def handle_client_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
  handle_with_tracing(:client_streamer, active_call, mth, inter_ctx) { handle_client_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
end
handle_request_response_with_newrelic_trace(active_call, mth, inter_ctx) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 36
def handle_request_response_with_newrelic_trace(active_call, mth, inter_ctx)
  handle_with_tracing(:request_response, active_call, mth, inter_ctx) { handle_request_response_without_newrelic_trace(active_call, mth, inter_ctx) }
end
handle_server_streamer_with_newrelic_trace(active_call, mth, inter_ctx) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 50
def handle_server_streamer_with_newrelic_trace(active_call, mth, inter_ctx)
  handle_with_tracing(:server_streamer, active_call, mth, inter_ctx) { handle_server_streamer_without_newrelic_trace(active_call, mth, inter_ctx) }
end
run_with_newrelic_trace(*args) click to toggle source
# File lib/new_relic/agent/instrumentation/grpc/server/chain.rb, line 23
def run_with_newrelic_trace(*args)
  run_with_tracing(*args) { run_without_newrelic_trace(*args) }
end