class Zipkin::AsyncReporter

Public Class Methods

create(sender:, flush_interval:) click to toggle source
# File lib/zipkin/async_reporter.rb, line 9
def self.create(sender:, flush_interval:)
  reporter = new(sender)

  # start flush thread
  Thread.new do
    loop do
      reporter.flush
      sleep(flush_interval)
    end
  end

  reporter
end
new(sender) click to toggle source
# File lib/zipkin/async_reporter.rb, line 23
def initialize(sender)
  @sender = sender
  @buffer = Buffer.new
end

Public Instance Methods

flush() click to toggle source
# File lib/zipkin/async_reporter.rb, line 28
def flush
  spans = @buffer.retrieve
  @sender.send_spans(spans) if spans.any?
  spans
end
report(span) click to toggle source
# File lib/zipkin/async_reporter.rb, line 34
def report(span)
  return unless span.context.sampled?
  @buffer << span
end