Contents

# frozen_string_literal: true

$LOAD_PATH.push(File.dirname(__FILE__) + '/../../thrift/gen-rb')

require 'opentracing'
require 'jaeger/thrift/agent'
require 'logger'

require_relative 'client/tracer'
require_relative 'client/span'
require_relative 'client/span_context'
require_relative 'client/scope'
require_relative 'client/scope_manager'
require_relative 'client/carrier'
require_relative 'client/trace_id'
require_relative 'client/udp_sender'
require_relative 'client/async_reporter'
require_relative 'client/version'
require_relative 'client/samplers'
require_relative 'client/encoders/thrift_encoder'
require_relative 'client/injectors'
require_relative 'client/extractors'

module Jaeger
  module Client
    DEFAULT_FLUSH_INTERVAL = 10

    def self.build(host: '127.0.0.1',
                   port: 6831,
                   service_name:,
                   flush_interval: DEFAULT_FLUSH_INTERVAL,
                   sampler: Samplers::Const.new(true),
                   logger: Logger.new(STDOUT),
                   sender: nil,
                   injectors: {},
                   extractors: {})
      encoder = Encoders::ThriftEncoder.new(service_name: service_name)

      if sender.nil?
        sender = UdpSender.new(host: host, port: port, encoder: encoder, logger: logger)
      end

      reporter = AsyncReporter.create(sender: sender, flush_interval: flush_interval)

      Tracer.new(
        reporter: reporter,
        sampler: sampler,
        injectors: Injectors.prepare(injectors),
        extractors: Extractors.prepare(extractors)
      )
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
jaeger-client-0.8.0	lib/jaeger/client.rb
jaeger-client-0.7.1	lib/jaeger/client.rb
jaeger-client-0.7.0	lib/jaeger/client.rb