Contents

# frozen_string_literal: true

# Copyright The OpenTelemetry Authors
#
# SPDX-License-Identifier: Apache-2.0

require_relative 'events/connection/request'
require_relative 'events/consumer_group/heartbeat'
require_relative 'events/consumer_group/join_group'
require_relative 'events/consumer_group/leave_group'
require_relative 'events/consumer_group/sync_group'
require_relative 'events/produce_operation/send_messages'
require_relative 'events/producer/deliver_messages'

module OpenTelemetry
  module Instrumentation
    module RubyKafka
      module Events
        ALL = [
          Events::Connection::Request,
          Events::ConsumerGroup::Heartbeat,
          Events::ConsumerGroup::JoinGroup,
          Events::ConsumerGroup::LeaveGroup,
          Events::ConsumerGroup::SyncGroup,
          Events::ProduceOperation::SendMessages,
          Events::Producer::DeliverMessages
        ].freeze
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
opentelemetry-instrumentation-ruby_kafka-0.12.0	lib/opentelemetry/instrumentation/ruby_kafka/events.rb