Contents

# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.

module NewRelic
  module Agent
    module DistributedTraceTransportType
      extend self

      UNKNOWN = 'Unknown'.freeze

      ALLOWABLE_TRANSPORT_TYPES = Set.new(%w[
        Unknown
        HTTP
        HTTPS
        Kafka
        JMS
        IronMQ
        AMQP
        Queue
        Other
      ]).freeze

      URL_SCHEMES = {
        'http'  => 'HTTP'.freeze,
        'https' => 'HTTPS'.freeze
      }

      RACK_URL_SCHEME = 'rack.url_scheme'.freeze

      def from value
        return value if ALLOWABLE_TRANSPORT_TYPES.include?(value)

        UNKNOWN
      end


      def for_rack_request request
        URL_SCHEMES[request[RACK_URL_SCHEME]]
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
newrelic_rpm-6.8.0.360	lib/new_relic/agent/distributed_trace_transport_type.rb