Sha256: 46585403445a7fbfa5c275691d18511cafa229d3d686389e74d6f87852fc6e68

Contents?: true

Size: 687 Bytes

Versions: 4

Compression:

Stored size: 687 Bytes

Contents

# frozen_string_literal: true

module OpenTracing
  module Instrumentation
    module Thrift
      # Tags builder for TracedProcessor
      class TracedProcessorTagsBuilder < TracedProtocolTagsBuilder
        DEFAULT_STATIC_TAGS = {
          'span.kind' => 'server',
          'component' => 'thrift',
        }.freeze

        def initialize(static_tags: DEFAULT_STATIC_TAGS)
          @static_tags = static_tags
        end

        def build_tags(protocol, name, type)
          static_tags
            .merge(build_protocol_tags(protocol))
            .merge(build_message_tags(name, type))
        end

        private

        attr_reader :static_tags
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
opentracing-instrumentation-0.1.18 lib/opentracing/instrumentation/thrift/traced_processor_tags_builder.rb
opentracing-instrumentation-0.1.17 lib/opentracing/instrumentation/thrift/traced_processor_tags_builder.rb
opentracing-instrumentation-0.1.16 lib/opentracing/instrumentation/thrift/traced_processor_tags_builder.rb
opentracing-instrumentation-0.1.15 lib/opentracing/instrumentation/thrift/traced_processor_tags_builder.rb