46 references to SemanticConventions
Aspire.Confluent.Kafka (46)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\ConfluentKafkaCommon.cs (4)
22internal static readonly Counter<long> ReceiveMessagesCounter = Meter.CreateCounter<long>(SemanticConventions.MetricMessagingReceiveMessages); 23internal static readonly Histogram<double> ReceiveDurationHistogram = Meter.CreateHistogram<double>(SemanticConventions.MetricMessagingReceiveDuration); 24internal static readonly Counter<long> PublishMessagesCounter = Meter.CreateCounter<long>(SemanticConventions.MetricMessagingPublishMessages); 25internal static readonly Histogram<double> PublishDurationHistogram = Meter.CreateHistogram<double>(SemanticConventions.MetricMessagingPublishDuration);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (14)
284SemanticConventions.AttributeMessagingOperation, 287SemanticConventions.AttributeMessagingSystem, 290SemanticConventions.AttributeMessagingDestinationName, 298SemanticConventions.AttributeMessagingKafkaDestinationPartition, 306SemanticConventions.AttributeErrorType, 335activity.SetTag(SemanticConventions.AttributeErrorType, errorType); 363activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 364activity.SetTag(SemanticConventions.AttributeMessagingClientId, this.Name); 365activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic); 366activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value); 367activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageOffset, topicPartitionOffset?.Offset.Value); 368activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, this.GroupId); 369activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ReceiveOperationName); 372activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (19)
61activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 68activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 108activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 115activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 151activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 158activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 192activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 199activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 282SemanticConventions.AttributeMessagingOperation, 285SemanticConventions.AttributeMessagingSystem, 288SemanticConventions.AttributeMessagingDestinationName, 296SemanticConventions.AttributeMessagingKafkaDestinationPartition, 304SemanticConventions.AttributeErrorType, 341activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 342activity.SetTag(SemanticConventions.AttributeMessagingClientId, this.Name); 343activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topic); 344activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.PublishOperationName); 348activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, message.Key); 353activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, partition);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (9)
135processActivity?.SetTag(SemanticConventions.AttributeErrorType, ex.GetType().FullName); 161activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 162activity.SetTag(SemanticConventions.AttributeMessagingClientId, clientId); 163activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic); 164activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value); 165activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageOffset, topicPartitionOffset?.Offset.Value); 166activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, groupId); 167activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ProcessOperationName); 170activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);