10 references to Consumer
Aspire.Confluent.Kafka (2)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
360
Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.
Consumer
, links: activityLinks, startTime: start, parentContext: default);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
158
Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.
Consumer
, links: activityLinks, parentContext: default);
Aspire.Dashboard (2)
Model\ResourceOutgoingPeerResolver.cs (1)
75
using var activity = _activitySource.StartActivity("Process resource subscription changes", ActivityKind.
Consumer
);
ServiceClient\DashboardClient.cs (1)
570
using var activity = _activitySource.StartActivity("Process resource update", ActivityKind.
Consumer
);
Aspire.Dashboard.Tests (4)
Integration\HealthTests.cs (2)
72
using (var activity = activitySource.ActivitySource.StartActivity("Test resource update", ActivityKind.
Consumer
))
80
Assert.Equal(ActivityKind.
Consumer
, exported.Kind);
Model\DashboardClientTests.cs (1)
333
Assert.Equal(ActivityKind.
Consumer
, activity.Kind);
ResourceOutgoingPeerResolverTests.cs (1)
429
Assert.Equal(ActivityKind.
Consumer
, activity.Kind);
Microsoft.DotNet.Cli.Telemetry (1)
Implementation\AzureMonitorTelemetrySerializer.cs (1)
263
=> kind is ActivityKind.Server or ActivityKind.
Consumer
;
Stress.ApiService (1)
ProducerConsumer.cs (1)
38
using var activity = s_activitySource.StartActivity($"Consume {item.Id}", ActivityKind.
Consumer
, parentId: null, links: links);