28 references to ConfluentKafkaCommon
Aspire.Confluent.Kafka (28)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (9)
285ConfluentKafkaCommon.ReceiveOperationName), 288ConfluentKafkaCommon.KafkaMessagingSystem), 315ConfluentKafkaCommon.ReceiveMessagesCounter.Add(1, in tags); 316ConfluentKafkaCommon.ReceiveDurationHistogram.Record(duration.TotalSeconds, in tags); 353? ConfluentKafkaCommon.ReceiveOperationName 354: string.Concat(topicPartitionOffset!.Topic, " ", ConfluentKafkaCommon.ReceiveOperationName); 360Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, startTime: start, parentContext: default); 363activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 369activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ReceiveOperationName);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (10)
283ConfluentKafkaCommon.PublishOperationName), 286ConfluentKafkaCommon.KafkaMessagingSystem), 313ConfluentKafkaCommon.PublishMessagesCounter.Add(1, in tags); 314ConfluentKafkaCommon.PublishDurationHistogram.Record(duration.TotalSeconds, in tags); 321ConfluentKafkaCommon.PublishMessagesCounter.Add(1, in tags); 322ConfluentKafkaCommon.PublishDurationHistogram.Record(duration.TotalSeconds, in tags); 332var spanName = string.Concat(topic, " ", ConfluentKafkaCommon.PublishOperationName); 333var activity = ConfluentKafkaCommon.ActivitySource.StartActivity(name: spanName, kind: ActivityKind.Producer, startTime: start); 341activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 344activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.PublishOperationName);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Consumer.cs (1)
73.AddMeter(ConfluentKafkaCommon.InstrumentationName)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Producer.cs (1)
73.AddMeter(ConfluentKafkaCommon.InstrumentationName)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (5)
151? ConfluentKafkaCommon.ProcessOperationName 152: string.Concat(topicPartitionOffset!.Topic, " ", ConfluentKafkaCommon.ProcessOperationName); 158Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, parentContext: default); 161activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 167activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ProcessOperationName);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Consumer.cs (1)
73.AddSource(ConfluentKafkaCommon.InstrumentationName)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Producer.cs (1)
73.AddSource(ConfluentKafkaCommon.InstrumentationName)