ActivityKind

91 references to ActivityKind

aspire (9)

Certificates\CertificateService.cs (1)

40using var activity = telemetry.StartDiagnosticActivity(kind: ActivityKind.Client);

DotNet\DotNetCliRunner.cs (1)

492using var activity = telemetry.StartDiagnosticActivity(kind: ActivityKind.Client);

Program.cs (1)

703using var mainActivity = telemetry.StartReportedActivity(name: TelemetryConstants.Activities.Main, kind: ActivityKind.Internal);

Telemetry\AspireCliTelemetry.cs (5)

98public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 110public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 115private Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind)

Utils\AppHostHelper.cs (1)

55using var activity = telemetry.StartDiagnosticActivity(kind: ActivityKind.Client);

Aspire.Cli.Tests (6)

Telemetry\AspireCliTelemetryTests.cs (6)

20using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 24Assert.Equal(ActivityKind.Internal, activity.Kind); 52using var activity = fixture.Telemetry.StartDiagnosticActivity("test-client", ActivityKind.Client); 56Assert.Equal(ActivityKind.Client, activity.Kind); 91using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 145using var reportedActivity = fixture.Telemetry.StartReportedActivity("parent-activity", ActivityKind.Internal);

Aspire.Confluent.Kafka (3)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)

360Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, startTime: start, parentContext: default);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (1)

333var activity = ConfluentKafkaCommon.ActivitySource.StartActivity(name: spanName, kind: ActivityKind.Producer, startTime: start);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)

158Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, parentContext: default);

Aspire.RabbitMQ.Client (2)

src\Components\Aspire.RabbitMQ.Client\AspireRabbitMQExtensions.cs (2)

203using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 209using var connectAttemptActivity = s_activitySource.StartActivity("rabbitmq connect attempt", ActivityKind.Client);

Aspire.StackExchange.Redis (1)

src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\Implementation\RedisProfilerEntryToActivityConverter.cs (1)

86ActivityKind.Client,

CatalogDb (1)

CatalogDbInitializer.cs (1)

18using var activity = _activitySource.StartActivity("Initializing catalog database", ActivityKind.Client);

DatabaseMigration.MigrationService (1)

ApiDbInitializer.cs (1)

22using var activity = s_activitySource.StartActivity("Migrating database", ActivityKind.Client);

dotnet (4)

Telemetry\TelemetryClient.cs (4)

74public static ActivityKind ActivityKind { get; private set; } 184private static ActivityKind GetActivityKind(ActivityContext? parentActivityContext) => 185parentActivityContext is ActivityContext { IsRemote: true } ? ActivityKind.Server : ActivityKind.Internal;

Microsoft.AspNetCore.Components (2)

ComponentsActivitySource.cs (2)

34var activity = ActivitySource.CreateActivity(OnRouteName, ActivityKind.Internal, parentId: null, null, null); 70var activity = ActivitySource.CreateActivity(OnEventName, ActivityKind.Internal, parentId: null, null, null);

Microsoft.AspNetCore.Components.Server (1)

Circuits\CircuitActivitySource.cs (1)

25var activity = ActivitySource.CreateActivity(OnCircuitName, ActivityKind.Internal, parentId: null, null, null);

Microsoft.AspNetCore.Diagnostics (1)

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

24ActivityKind kind,

Microsoft.AspNetCore.Hosting (2)

Internal\HostingApplicationDiagnostics.cs (1)

429ActivityKind.Server,

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

24ActivityKind kind,

Microsoft.AspNetCore.SignalR.Core (6)

Internal\DefaultHubDispatcher.cs (5)

95activity = StartActivity(SignalRServerActivitySource.OnConnected, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnConnectedAsync), headers: null, _logger, connection); 130activity = StartActivity(SignalRServerActivitySource.OnDisconnected, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnDisconnectedAsync), headers: null, _logger, connection); 407var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger, connection); 525var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger, connection); 832private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger, HubConnectionContext? connection = null)

src\aspnetcore\src\Shared\Diagnostics\ActivityCreator.cs (1)

24ActivityKind kind,

Microsoft.Build.Framework (1)

Telemetry\MSBuildActivitySource.cs (1)

48? _source.StartActivity(eventName, ActivityKind.Internal, parentId: Activity.Current.ParentId)

Microsoft.Extensions.AI (5)

ChatCompletion\FunctionInvokingChatClient.cs (1)

1400ActivityKind.Internal,

ChatCompletion\OpenTelemetryChatClient.cs (1)

554ActivityKind.Client);

ChatCompletion\OpenTelemetryImageGenerator.cs (1)

150ActivityKind.Client);

Embeddings\OpenTelemetryEmbeddingGenerator.cs (1)

154ActivityKind.Client,

SpeechToText\OpenTelemetrySpeechToTextClient.cs (1)

208ActivityKind.Client);

Microsoft.Extensions.DataIngestion (1)

IngestionPipeline.cs (1)

143using (Activity? processFileActivity = _activitySource.StartActivity(ProcessFile.ActivityName, ActivityKind.Internal, parentContext: rootActivity?.Context ?? default))

Microsoft.Extensions.ServiceDiscovery.Dns (1)

Resolver\DnsResolver.Telemetry.cs (1)

64_activity = s_activitySource.StartActivity(ActivityName, ActivityKind.Client);

Stress.ApiService (19)

ProducerConsumer.cs (4)

28using var appActivity = s_activitySource.StartActivity("ConsumerApp", ActivityKind.Internal); 38using var activity = s_activitySource.StartActivity($"Consume {item.Id}", ActivityKind.Consumer, parentId: null, links: links); 44using var appActivity = s_activitySource.StartActivity("ProducerApp", ActivityKind.Internal); 51using (var activity = s_activitySource.StartActivity($"Produce {id}", ActivityKind.Producer))

Program.cs (12)

TraceCreator.cs (3)

21var activity = s_activitySource.StartActivity(name, ActivityKind.Client); 47using var activity = s_activitySource.StartActivity(rootName ?? name, ActivityKind.Client); 75using var activity = s_activitySource.StartActivity(ActivityKind.Client, name: name, links: links.DistinctBy(l => l.Context.SpanId));

System.Diagnostics.DiagnosticSource (24)

System\Diagnostics\Activity.cs (4)

173public ActivityKind Kind { get; private set; } = ActivityKind.Internal; 1183internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 2243public ActivityKind Kind => activity.Kind;

System\Diagnostics\ActivityCreationOptions.cs (4)

24/// <param name="kind"><see cref="ActivityKind"/> to create the Activity object with.</param> 28internal ActivityCreationOptions(ActivitySource source, string name, T parent, ActivityKind kind, IEnumerable<KeyValuePair<string, object?>>? tags, IEnumerable<ActivityLink>? links, ActivityIdFormat idFormat) 96/// Retrieve the <see cref="ActivityKind"/> which requested to create the Activity object with. 98public ActivityKind Kind { get; }

System\Diagnostics\ActivitySource.cs (16)

115/// <param name="kind">The <see cref="ActivityKind"/></param> 120public Activity? CreateActivity(string name, ActivityKind kind) 128/// <param name="kind">The <see cref="ActivityKind"/></param> 137public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 144/// <param name="kind">The <see cref="ActivityKind"/></param> 153public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 160/// <param name="kind">The <see cref="ActivityKind"/></param> 162public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 169/// <param name="kind">The <see cref="ActivityKind"/></param> 175public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 182/// <param name="kind">The <see cref="ActivityKind"/></param> 188public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 194/// <param name="kind">The <see cref="ActivityKind"/></param> 201public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 204private Activity? CreateActivity(string name, ActivityKind kind, ActivityContext context, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags,

System.Net.Http (1)

System\Net\Http\DiagnosticsHandler.cs (1)

63activity = s_activitySource.StartActivity(DiagnosticsHandlerLoggingStrings.RequestActivityName, ActivityKind.Client);