class Kafka::DecoratingInstrumenter
Public Class Methods
new(backend, extra_payload = {})
click to toggle source
# File lib/kafka/instrumenter.rb, line 29 def initialize(backend, extra_payload = {}) @backend = backend @extra_payload = extra_payload end
Public Instance Methods
instrument(event_name, payload = {}, &block)
click to toggle source
# File lib/kafka/instrumenter.rb, line 34 def instrument(event_name, payload = {}, &block) @backend.instrument(event_name, @extra_payload.merge(payload), &block) end