Class: Jaeger::Client::AsyncReporter
- Inherits:
-
Object
- Object
- Jaeger::Client::AsyncReporter
- Defined in:
- lib/jaeger/client/async_reporter.rb,
lib/jaeger/client/async_reporter/buffer.rb
Defined Under Namespace
Classes: Buffer
Class Method Summary collapse
Instance Method Summary collapse
- #flush ⇒ Object
-
#initialize(sender) ⇒ AsyncReporter
constructor
A new instance of AsyncReporter.
- #report(span) ⇒ Object
Constructor Details
#initialize(sender) ⇒ AsyncReporter
Returns a new instance of AsyncReporter.
24 25 26 27 |
# File 'lib/jaeger/client/async_reporter.rb', line 24 def initialize(sender) @sender = sender @buffer = Buffer.new end |
Class Method Details
.create(sender:, flush_interval:) ⇒ Object
10 11 12 13 14 15 16 17 18 19 20 21 22 |
# File 'lib/jaeger/client/async_reporter.rb', line 10 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 |
Instance Method Details
#flush ⇒ Object
29 30 31 32 33 |
# File 'lib/jaeger/client/async_reporter.rb', line 29 def flush spans = @buffer.retrieve @sender.send_spans(spans) if spans.any? spans end |
#report(span) ⇒ Object
35 36 37 38 |
# File 'lib/jaeger/client/async_reporter.rb', line 35 def report(span) return if !span.context.sampled? && !span.context.debug? @buffer << span end |