feat: migrate gRPC instrumentation from standardrb to Rubocop (#1341)

* fix: migrate grpc instrumentation from standardrb to rubocop

* remove standardrb

* fix: remove conflicting CODE_OF_CONDUCT

* fix: remove rbs

* include the gRPC instrumentation in the general CI

* fix(grpc instrumentation): skip JRuby tests since gRPC is not compatible with JRuby

reference grpc/grpc#6705

---------

Co-authored-by: Ariel Valentin <[email protected]>

Author: michal-kazmierczak

.github/workflows/ci-instrumentation.yml

@@ -39,6 +39,7 @@ jobs:
           - faraday
           - grape
           - graphql
+          - grpc
           - gruf
           - http
           - http_client
@@ -102,6 +103,7 @@ jobs:
           [[ "${{ matrix.gem }}" == "lmdb"                     ]] && echo "skip=true" >> $GITHUB_OUTPUT
           [[ "${{ matrix.gem }}" == "rack"                     ]] && echo "skip=true" >> $GITHUB_OUTPUT
           [[ "${{ matrix.gem }}" == "rails"                    ]] && echo "skip=true" >> $GITHUB_OUTPUT
+          [[ "${{ matrix.gem }}" == "grpc"                     ]] && echo "skip=true" >> $GITHUB_OUTPUT
           [[ "${{ matrix.gem }}" == "gruf"                     ]] && echo "skip=true" >> $GITHUB_OUTPUT
           # This is essentially a bash script getting evaluated, so we need to return true or the whole job fails.
           true

instrumentation/grpc/.rubocop.yml

@@ -0,0 +1,5 @@
+inherit_from: ../../.rubocop.yml
+
+AllCops:
+  Exclude:
+    - 'test/support/proto/*.rb'

instrumentation/grpc/.standard.yml

@@ -4,7 +4,7 @@
 #
 # SPDX-License-Identifier: Apache-2.0
 
-source "https://rubygems.org"
+source 'https://rubygems.org'
 
 # Specify your gem's dependencies in opentelemetry-instrumentation-grpc.gemspec
 gemspec

instrumentation/grpc/CODE_OF_CONDUCT.md

@@ -4,4 +4,4 @@
 #
 # SPDX-License-Identifier: Apache-2.0
 
-require_relative "opentelemetry/instrumentation"
+require_relative 'opentelemetry/instrumentation'

instrumentation/grpc/Gemfile

@@ -4,9 +4,19 @@
 #
 # SPDX-License-Identifier: Apache-2.0
 
+# OpenTelemetry is an open source observability framework, providing a
+# general-purpose API, SDK, and related tools required for the instrumentation
+# of cloud-native software, frameworks, and libraries.
+#
+# The OpenTelemetry module provides global accessors for telemetry objects.
+# See the documentation for the `opentelemetry-api` gem for details.
 module OpenTelemetry
+  # "Instrumentation" are specified by
+  # https://github.com/open-telemetry/opentelemetry-specification/blob/784635d01d8690c8f5fcd1f55bdbc8a13cf2f4f2/specification/glossary.md#instrumentation-library
+  #
+  # Instrumentation should be able to handle the case when the library is not installed on a user's system.
   module Instrumentation
   end
 end
 
-require_relative "instrumentation/grpc"
+require_relative 'instrumentation/grpc'

instrumentation/grpc/lib/opentelemetry-instrumentation-grpc.rb

@@ -4,8 +4,8 @@
 #
 # SPDX-License-Identifier: Apache-2.0
 
-require "opentelemetry"
-require "opentelemetry-instrumentation-base"
+require 'opentelemetry'
+require 'opentelemetry-instrumentation-base'
 
 module OpenTelemetry
   module Instrumentation
@@ -16,6 +16,6 @@ class Error < StandardError; end
   end
 end
 
-require_relative "grpc/instrumentation"
-require_relative "grpc/version"
+require_relative 'grpc/instrumentation'
+require_relative 'grpc/version'
 require_relative 'grpc/interceptors/client_tracer'

instrumentation/grpc/lib/opentelemetry/instrumentation.rb

@@ -11,45 +11,45 @@ module Interceptors
         # ClientTracer is a gRPC client interceptor which instrument gRPC calls with OpenTelemetry tracing
         class ClientTracer < ::GRPC::ClientInterceptor
           def request_response(request: nil, call: nil, method: nil, metadata: nil, &blk)
-            call(type: "request_response", requests: [request], call: call, method: method, metadata: metadata, &blk)
+            call(type: 'request_response', requests: [request], call: call, method: method, metadata: metadata, &blk)
           end
 
           def client_streamer(requests: nil, call: nil, method: nil, metadata: nil, &blk)
-            call(type: "client_streamer", requests: requests, call: call, method: method, metadata: metadata, &blk)
+            call(type: 'client_streamer', requests: requests, call: call, method: method, metadata: metadata, &blk)
           end
 
           def server_streamer(request: nil, call: nil, method: nil, metadata: nil, &blk)
-            call(type: "server_streamer", requests: [request], call: call, method: method, metadata: metadata, &blk)
+            call(type: 'server_streamer', requests: [request], call: call, method: method, metadata: metadata, &blk)
           end
 
           def bidi_streamer(requests: nil, call: nil, method: nil, metadata: nil, &blk)
-            call(type: "client_streamer", requests: requests, call: call, method: method, metadata: metadata, &blk)
+            call(type: 'client_streamer', requests: requests, call: call, method: method, metadata: metadata, &blk)
           end
 
           private
 
           def call(type:, requests: nil, call: nil, method: nil, metadata: nil)
             return yield if instrumentation_config.empty?
 
-            method_parts = method.to_s.split("/")
+            method_parts = method.to_s.split('/')
             service = method_parts[1]
             method_name = method_parts.last
 
             attributes = {
-              OpenTelemetry::SemanticConventions::Trace::RPC_SYSTEM => "grpc",
+              OpenTelemetry::SemanticConventions::Trace::RPC_SYSTEM => 'grpc',
               OpenTelemetry::SemanticConventions::Trace::RPC_SERVICE => service,
               OpenTelemetry::SemanticConventions::Trace::RPC_METHOD => method_name,
               OpenTelemetry::SemanticConventions::Trace::PEER_SERVICE => instrumentation_config[:peer_service],
-              "rpc.type" => type,
-              "net.sock.peer.addr" => call.instance_variable_get(:@wrapped)&.peer
+              'rpc.type' => type,
+              'net.sock.peer.addr' => call.instance_variable_get(:@wrapped)&.peer
             }.compact
 
             attributes.merge!(allowed_metadata_headers(metadata.transform_keys(&:to_s)))
 
             instrumentation_tracer.in_span(
               # The specification requires there be no leading slash
               # https://github.com/open-telemetry/semantic-conventions/blob/5a2836bbea0b6e105b98370f331a7661bcf19540/docs/rpc/rpc-spans.md?plain=1#L63-L69
-              method.to_s.delete_prefix("/"),
+              method.to_s.delete_prefix('/'),
               attributes: attributes,
               kind: OpenTelemetry::Trace::SpanKind::CLIENT
             ) do |span|

instrumentation/grpc/lib/opentelemetry/instrumentation/grpc.rb

@@ -13,9 +13,7 @@ module Patches
         module ClientStub
           def initialize(host, creds, **args)
             interceptors = args[:interceptors] || []
-            interceptors.unshift(Interceptors::ClientTracer.new) unless interceptors.any? do |interceptor|
-              interceptor.is_a?(Interceptors::ClientTracer)
-            end
+            interceptors.unshift(Interceptors::ClientTracer.new) unless interceptors.any?(Interceptors::ClientTracer)
             args[:interceptors] = interceptors
 
             super