5 references to AttributeMessagingOperation
Aspire.Confluent.Kafka (5)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (2)
284
SemanticConventions.
AttributeMessagingOperation
,
369
activity.SetTag(SemanticConventions.
AttributeMessagingOperation
, ConfluentKafkaCommon.ReceiveOperationName);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (2)
282
SemanticConventions.
AttributeMessagingOperation
,
344
activity.SetTag(SemanticConventions.
AttributeMessagingOperation
, ConfluentKafkaCommon.PublishOperationName);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
167
activity.SetTag(SemanticConventions.
AttributeMessagingOperation
, ConfluentKafkaCommon.ProcessOperationName);