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