Sha256: 84693c70b1c1e2c4c9b153de54ceba323364f835310176e7972b21dd9512d977
Contents?: true
Size: 484 Bytes
Versions: 26
Compression:
Stored size: 484 Bytes
Contents
# frozen_string_literal: true
module Datadog
module Tracing
module Contrib
module Kafka
# Defines basic behaviors for an event for a consumer.
module ConsumerEvent
def process(span, _event, _id, payload)
super
span.set_tag(Ext::TAG_GROUP, payload[:group_id])
span.set_tag(Tracing::Metadata::Ext::TAG_KIND, Tracing::Metadata::Ext::SpanKind::TAG_CONSUMER)
end
end
end
end
end
end
Version data entries
26 entries across 26 versions & 2 rubygems