Module: Skylight::Core::Fanout
- Defined in:
- lib/skylight/core/fanout.rb
Class Method Summary collapse
- .broken! ⇒ Object
- .done(spans, meta = nil) ⇒ Object
- .each_trace ⇒ Object
- .endpoint=(endpoint) ⇒ Object
- .instrument(*args) ⇒ Object
- .register(obj) ⇒ Object
- .registered ⇒ Object
- .trace(*args) ⇒ Object
- .unregister(obj) ⇒ Object
Class Method Details
.broken! ⇒ Object
42 43 44 |
# File 'lib/skylight/core/fanout.rb', line 42 def self.broken! registered.each(&:broken!) end |
.done(spans, meta = nil) ⇒ Object
36 37 38 39 40 |
# File 'lib/skylight/core/fanout.rb', line 36 def self.done(spans, = nil) spans.reverse_each do |(target, span)| target.done(span, ) end end |
.each_trace ⇒ Object
50 51 52 53 54 55 56 |
# File 'lib/skylight/core/fanout.rb', line 50 def self.each_trace return to_enum(__method__) unless block_given? registered.each do |r| next unless r.instrumenter && (trace = r.instrumenter.current_trace) yield trace end end |
.endpoint=(endpoint) ⇒ Object
46 47 48 |
# File 'lib/skylight/core/fanout.rb', line 46 def self.endpoint=(endpoint) each_trace { |t| t.endpoint = endpoint } end |
.instrument(*args) ⇒ Object
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'lib/skylight/core/fanout.rb', line 20 def self.instrument(*args) if block_given? spans = instrument(*args) = {} begin yield spans ensure done(spans, ) end else registered.map do |r| [r, r.instrument(*args)] end end end |
.register(obj) ⇒ Object
8 9 10 |
# File 'lib/skylight/core/fanout.rb', line 8 def self.register(obj) registered.push(obj) end |
.registered ⇒ Object
4 5 6 |
# File 'lib/skylight/core/fanout.rb', line 4 def self.registered @registered ||= [] end |
.trace(*args) ⇒ Object
16 17 18 |
# File 'lib/skylight/core/fanout.rb', line 16 def self.trace(*args) registered.map { |r| r.trace(*args) } end |
.unregister(obj) ⇒ Object
12 13 14 |
# File 'lib/skylight/core/fanout.rb', line 12 def self.unregister(obj) registered.delete(obj) end |