ActivityKind

166 references to ActivityKind

aspire (21)

Certificates\CertificateService.cs (1)

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

Commands\AgentTelemetryCommand.cs (1)

28/// opted out no reported provider is created, so <see cref="AspireTelemetryBase.StartReportedActivity(string, System.Diagnostics.ActivityKind)"/>

DotNet\DotNetCliRunner.cs (1)

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

Program.cs (1)

1389var activity = telemetry.StartReportedActivity(TelemetryConstants.Activities.Main, ActivityKind.Internal);

src\Shared\Telemetry\AspireTelemetryBase.cs (7)

58public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 71public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 85protected Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<ActivityLink> links) 97public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 110public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext)

Telemetry\ProfilingTelemetry.cs (9)

392var activity = StartActivity(Activities.JsonRpcClientCall, ActivityKind.Client); 411var activity = StartActivity(Activities.Process, ActivityKind.Client); 428var activity = StartActivity(Activities.Process, ActivityKind.Client); 437var activity = StartActivity(Activities.Process, ActivityKind.Client, restoreAmbientActivity: true); 462var activity = StartActivity(Activities.Process, ActivityKind.Client); 469var activity = StartActivity(Activities.Process, ActivityKind.Client); 657ActivityKind kind = ActivityKind.Internal, 797var activity = StartActivity(Activities.Process, ActivityKind.Client);

Utils\AppHostHelper.cs (1)

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

Aspire.Cli.Tests (7)

Telemetry\AspireCliTelemetryTests.cs (7)

84using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 88Assert.Equal(ActivityKind.Internal, activity.Kind); 97using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal, parentContext); 129using var activity = fixture.Telemetry.StartDiagnosticActivity("test-client", ActivityKind.Client); 133Assert.Equal(ActivityKind.Client, activity.Kind); 142using var activity = fixture.Telemetry.StartDiagnosticActivity("test-activity", ActivityKind.Internal, parentContext); 267using var activity = fixture.Telemetry.StartReportedActivity("test-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.Dashboard (11)

Model\ResourceOutgoingPeerResolver.cs (1)

75using var activity = _activitySource.StartActivity("Process resource subscription changes", ActivityKind.Consumer);

Model\TelemetryImportService.cs (1)

60using var activity = _activitySource.StartActivity("Import telemetry data", ActivityKind.Internal);

ServiceClient\DashboardClient.cs (1)

611using var activity = _activitySource.StartActivity("Process resource update", ActivityKind.Consumer);

ServiceClient\TracingSqliteConnection.cs (1)

81ActivityKind.Client);

src\Shared\Telemetry\AspireTelemetryBase.cs (7)

Aspire.Dashboard.Components.Tests (1)

Pages\MetricsTests.cs (1)

568Assert.Equal(ActivityKind.Internal, activity.Kind);

Aspire.Dashboard.Tests (9)

Integration\HealthTests.cs (4)

51activity => activity.Source.Name == "Microsoft.AspNetCore" && activity.Kind == ActivityKind.Server); 60Assert.Equal(ActivityKind.Server, activity.Kind); 73using (var activity = activitySource.ActivitySource.StartActivity("Test resource update", ActivityKind.Consumer)) 81Assert.Equal(ActivityKind.Consumer, exported.Kind);

Model\DashboardClientTests.cs (1)

834Assert.Equal(ActivityKind.Consumer, activity.Kind);

Model\DashboardSqliteDatabaseTests.cs (2)

121Assert.Equal(ActivityKind.Client, activity.Kind); 199Assert.Equal(ActivityKind.Client, activity.Kind);

Model\TelemetryImportServiceTests.cs (1)

52Assert.Equal(ActivityKind.Internal, activity.Kind);

ResourceOutgoingPeerResolverTests.cs (1)

429Assert.Equal(ActivityKind.Consumer, activity.Kind);

Aspire.Hosting (10)

Diagnostics\ProfilingTelemetry.cs (10)

230var activity = StartActivity(configuration, Activities.AppHostProcessStartup, ActivityKind.Internal, GetProcessStartTime()); 424var activity = StartActivity(configuration, $"{Activities.ResourceStartup} {resource.Name}", ActivityKind.Internal, startTime); 447var activity = StartActivityFromTraceContext(Activities.JsonRpcServerCall, ActivityKind.Server, traceContext); 490private static ActivityScope StartActivity(IConfiguration? configuration, string name, ActivityKind activityKind = ActivityKind.Internal) 506private static ActivityScope StartActivity(IConfiguration? configuration, string name, ActivityKind activityKind, DateTimeOffset startTime) 534private ActivityScope StartActivity(string name, ActivityKind activityKind = ActivityKind.Internal) 554activity = s_activitySource.StartActivity(name, ActivityKind.Internal, parentContext); 568private ActivityScope StartActivityFromTraceContext(string name, ActivityKind activityKind, BackchannelTraceContext? traceContext)

Aspire.Hosting.RemoteHost (8)

Diagnostics\RemoteHostProfilingTelemetry.cs (8)

152var activity = StartActivity(Activities.JsonRpcServerCall, ActivityKind.Server); 193return StartActivity(Activities.CodeGenerationGetCapabilities, ActivityKind.Server); 198var activity = StartActivity(Activities.CodeGenerationGenerate, ActivityKind.Server); 205return StartActivity(Activities.LanguageDetect, ActivityKind.Server); 210var activity = StartActivity(Activities.LanguageGetRuntimeSpec, ActivityKind.Server); 217var activity = StartActivity(Activities.LanguageScaffold, ActivityKind.Server); 235ActivityKind activityKind = ActivityKind.Internal,

Aspire.Hosting.RemoteHost.Tests (2)

RemoteHostProfilingTelemetryTests.cs (2)

201var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 207using (var jsonRpcActivity = jsonRpcSource.StartActivity("server", ActivityKind.Server, clientContext))

Aspire.Hosting.Tests (5)

Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (2)

2230var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 2236using (var jsonRpcActivity = jsonRpcSource.StartActivity("server", ActivityKind.Server, clientContext))

Backchannel\BackchannelContractTests.cs (3)

251using var clientActivity = source.StartActivity("client", ActivityKind.Client); 304using var processActivity = processSource.StartActivity("process npx.CMD", ActivityKind.Internal); 313using var ambientActivity = ambientSource.StartActivity("hidden ambient", ActivityKind.Internal);

Aspire.RabbitMQ.Client (2)

AspireRabbitMQExtensions.cs (2)

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

Aspire.StackExchange.Redis (1)

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

112ActivityKind.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-aot (4)

parent\dotnet\Telemetry\TelemetryClient.cs (4)

106public static ActivityKind ActivityKind { get; private set; } 268private static ActivityKind GetActivityKind(ActivityContext? parentActivityContext) => 269parentActivityContext 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.Diagnostics.EntityFrameworkCore (1)

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

24ActivityKind kind,

Microsoft.AspNetCore.Hosting (2)

Internal\HostingApplicationDiagnostics.cs (1)

444ActivityKind.Server,

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

24ActivityKind kind,

Microsoft.AspNetCore.SignalR.Client.Core (1)

HubConnection.cs (1)

1381var activity = _activitySource.CreateActivity(ActivityName, ActivityKind.Client);

Microsoft.AspNetCore.SignalR.Core (7)

Internal\DefaultHubDispatcher.cs (6)

96activity = StartActivity(SignalRServerActivitySource.OnConnected, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnConnectedAsync), headers: null, _logger, connection); 132activity = StartActivity(SignalRServerActivitySource.OnDisconnected, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnDisconnectedAsync), headers: null, _logger, connection); 179activity = StartActivity(SignalRServerActivitySource.OnAuthenticationRefreshed, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnAuthenticationRefreshedAsync), headers: null, _logger, connection); 458var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger, connection); 603var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger, connection); 966private 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.DotNet.Cli.Telemetry (4)

Implementation\AzureMonitorTelemetrySerializer.cs (4)

102Type = activity.Kind == ActivityKind.Internal ? "InProc" : null, 262private static bool IsRequest(ActivityKind kind) 263=> kind is ActivityKind.Server or ActivityKind.Consumer;

Microsoft.Extensions.AI (8)

ChatCompletion\OpenTelemetryChatClient.cs (1)

283ActivityKind.Client);

ChatCompletion\OpenTelemetryImageGenerator.cs (1)

141ActivityKind.Client);

Common\FunctionInvocationProcessor.cs (1)

167ActivityKind.Internal,

Embeddings\OpenTelemetryEmbeddingGenerator.cs (1)

145ActivityKind.Client,

Files\OpenTelemetryHostedFileClient.cs (1)

419ActivityKind.Client);

Realtime\OpenTelemetryRealtimeClientSession.cs (1)

671ActivityKind.Client);

SpeechToText\OpenTelemetrySpeechToTextClient.cs (1)

202ActivityKind.Client);

TextToSpeech\OpenTelemetryTextToSpeechClient.cs (1)

201ActivityKind.Client);

Microsoft.Extensions.AI.Tests (5)

Files\OpenTelemetryHostedFileClientTests.cs (5)

55Assert.Equal(ActivityKind.Client, activity.Kind); 107Assert.Equal(ActivityKind.Client, activity.Kind); 147Assert.Equal(ActivityKind.Client, activity.Kind); 205Assert.Equal(ActivityKind.Client, activity.Kind); 243Assert.Equal(ActivityKind.Client, activity.Kind);

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 (20)

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 (4)

21var activity = s_activitySource.StartActivity(name, ActivityKind.Client); 47using var activity = s_activitySource.StartActivity(rootName ?? name, ActivityKind.Client); 96using var activity = s_activitySource.StartActivity(ActivityKind.Client, name: resolvedName, links: distinctLinks); 175var activity = s_activitySource.StartActivity("linked-trace-span", ActivityKind.Internal);

System.Diagnostics.DiagnosticSource (24)

System\Diagnostics\Activity.cs (4)

173public ActivityKind Kind { get; private set; } = ActivityKind.Internal; 1189internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext, 2303public 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)

141/// <param name="kind">The <see cref="ActivityKind"/></param> 146public Activity? CreateActivity(string name, ActivityKind kind) 154/// <param name="kind">The <see cref="ActivityKind"/></param> 171public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 178/// <param name="kind">The <see cref="ActivityKind"/></param> 195public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 202/// <param name="kind">The <see cref="ActivityKind"/></param> 204public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 211/// <param name="kind">The <see cref="ActivityKind"/></param> 225public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 232/// <param name="kind">The <see cref="ActivityKind"/></param> 246public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 252/// <param name="kind">The <see cref="ActivityKind"/></param> 267public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 270private 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);