Sha256: 20a1849f2e37fd8912997c97c042467498b46f031e71f32e2af99bd414d710a7
Contents?: true
Size: 1.99 KB
Versions: 15
Compression:
Stored size: 1.99 KB
Contents
module Datadog
module Contrib
module Kafka
# Kafka integration constants
module Ext
APP = 'kafka'.freeze
ENV_ENABLED = 'DD_TRACE_KAFKA_ENABLED'.freeze
ENV_ANALYTICS_ENABLED = 'DD_TRACE_KAFKA_ANALYTICS_ENABLED'.freeze
ENV_ANALYTICS_ENABLED_OLD = 'DD_KAFKA_ANALYTICS_ENABLED'.freeze
ENV_ANALYTICS_SAMPLE_RATE = 'DD_TRACE_KAFKA_ANALYTICS_SAMPLE_RATE'.freeze
ENV_ANALYTICS_SAMPLE_RATE_OLD = 'DD_KAFKA_ANALYTICS_SAMPLE_RATE'.freeze
SERVICE_NAME = 'kafka'.freeze
SPAN_CONNECTION_REQUEST = 'kafka.connection.request'.freeze
SPAN_CONSUMER_HEARTBEAT = 'kafka.consumer.heartbeat'.freeze
SPAN_CONSUMER_JOIN_GROUP = 'kafka.consumer.join_group'.freeze
SPAN_CONSUMER_LEAVE_GROUP = 'kafka.consumer.leave_group'.freeze
SPAN_CONSUMER_SYNC_GROUP = 'kafka.consumer.sync_group'.freeze
SPAN_DELIVER_MESSAGES = 'kafka.producer.deliver_messages'.freeze
SPAN_PROCESS_BATCH = 'kafka.consumer.process_batch'.freeze
SPAN_PROCESS_MESSAGE = 'kafka.consumer.process_message'.freeze
SPAN_SEND_MESSAGES = 'kafka.producer.send_messages'.freeze
TAG_ATTEMPTS = 'kafka.attempts'.freeze
TAG_API = 'kafka.api'.freeze
TAG_CLIENT = 'kafka.client'.freeze
TAG_GROUP = 'kafka.group'.freeze
TAG_HIGHWATER_MARK_OFFSET = 'kafka.highwater_mark_offset'.freeze
TAG_MESSAGE_COUNT = 'kafka.message_count'.freeze
TAG_MESSAGE_KEY = 'kafka.message_key'.freeze
TAG_DELIVERED_MESSAGE_COUNT = 'kafka.delivered_message_count'.freeze
TAG_OFFSET = 'kafka.offset'.freeze
TAG_OFFSET_LAG = 'kafka.offset_lag'.freeze
TAG_PARTITION = 'kafka.partition'.freeze
TAG_REQUEST_SIZE = 'kafka.request_size'.freeze
TAG_RESPONSE_SIZE = 'kafka.response_size'.freeze
TAG_SENT_MESSAGE_COUNT = 'kafka.sent_message_count'.freeze
TAG_TOPIC = 'kafka.topic'.freeze
TAG_TOPIC_PARTITIONS = 'kafka.topic_partitions'.freeze
end
end
end
end
Version data entries
15 entries across 15 versions & 2 rubygems