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