Sha256: fc479fe25b9b699657c0ef64aafd4304c06fa948106e54a40072112e791c365a
Contents?: true
Size: 850 Bytes
Versions: 45
Compression:
Stored size: 850 Bytes
Contents
module Kafka
class Instrumenter
NAMESPACE = "kafka"
def initialize(default_payload = {})
@default_payload = default_payload
if defined?(ActiveSupport::Notifications)
@backend = ActiveSupport::Notifications
else
@backend = nil
end
end
def instrument(event_name, payload = {}, &block)
if @backend
payload.update(@default_payload)
@backend.instrument("#{event_name}.#{NAMESPACE}", payload, &block)
else
block.call(payload) if block
end
end
end
class DecoratingInstrumenter
def initialize(backend, extra_payload = {})
@backend = backend
@extra_payload = extra_payload
end
def instrument(event_name, payload = {}, &block)
@backend.instrument(event_name, @extra_payload.merge(payload), &block)
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems