Sha256: b3739cde5e36ed2e6a9d0bfc1a0c79f7f8cee495da8e674f108bd391d6895747
Contents?: true
Size: 837 Bytes
Versions: 32
Compression:
Stored size: 837 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Producers
# Namespace for producers listeners
module Listeners
# Base listener for producer related listeners
class Base
include ::Karafka::Core::Helpers::Time
extend Forwardable
def_delegators :sampler, :track
def_delegators :reporter, :report, :report!
private
# @return [Object] sampler in use
def sampler
@sampler ||= ::Karafka::Web.config.tracking.producers.sampler
end
# @return [Object] reporter in use
def reporter
@reporter ||= ::Karafka::Web.config.tracking.producers.reporter
end
end
end
end
end
end
end
Version data entries
32 entries across 32 versions & 1 rubygems