ActivityKind

161 references to ActivityKind

aspire (22)

Certificates\CertificateService.cs (1)

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

Commands\AgentTelemetryCommand.cs (1)

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

DotNet\DotNetCliRunner.cs (1)

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

Program.cs (1)

1135: telemetry.StartReportedActivity(TelemetryConstants.Activities.Main, ActivityKind.Internal);

Telemetry\AspireCliTelemetry.cs (8)

143public Activity? StartReportedActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 151public Activity? StartReportedActivity(string name, ActivityKind kind, ActivityContext parentContext) 163public Activity? StartDiagnosticActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 171public Activity? StartDiagnosticActivity(string name, ActivityKind kind, ActivityContext parentContext) 176private static Activity? StartActivityCore(ActivitySource source, string name, ActivityKind kind) 181private static Activity? StartActivityCore(ActivitySource source, 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 (8)

Telemetry\AspireCliTelemetryTests.cs (8)

23using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 27Assert.Equal(ActivityKind.Internal, activity.Kind); 36using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal, parentContext); 68using var activity = fixture.Telemetry.StartDiagnosticActivity("test-client", ActivityKind.Client); 72Assert.Equal(ActivityKind.Client, activity.Kind); 81using var activity = fixture.Telemetry.StartDiagnosticActivity("test-activity", ActivityKind.Internal, parentContext); 120using var activity = fixture.Telemetry.StartReportedActivity("test-activity", ActivityKind.Internal); 176using 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.Dashboard (4)

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)

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

ServiceClient\TracingSqliteConnection.cs (1)

81ActivityKind.Client);

Aspire.Dashboard.Components.Tests (1)

Pages\MetricsTests.cs (1)

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

Aspire.Dashboard.Tests (9)

Integration\HealthTests.cs (4)

50activity => activity.Source.Name == "Microsoft.AspNetCore" && activity.Kind == ActivityKind.Server); 59Assert.Equal(ActivityKind.Server, activity.Kind); 72using (var activity = activitySource.ActivitySource.StartActivity("Test resource update", ActivityKind.Consumer)) 80Assert.Equal(ActivityKind.Consumer, exported.Kind);

Model\DashboardClientTests.cs (1)

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

Model\DashboardSqliteDatabaseTests.cs (2)

114Assert.Equal(ActivityKind.Client, activity.Kind); 192Assert.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)

146var activity = StartActivity(Activities.JsonRpcServerCall, ActivityKind.Server); 187return StartActivity(Activities.CodeGenerationGetCapabilities, ActivityKind.Server); 192var activity = StartActivity(Activities.CodeGenerationGenerate, ActivityKind.Server); 199return StartActivity(Activities.LanguageDetect, ActivityKind.Server); 204var activity = StartActivity(Activities.LanguageGetRuntimeSpec, ActivityKind.Server); 211var activity = StartActivity(Activities.LanguageScaffold, ActivityKind.Server); 218ActivityKind activityKind = ActivityKind.Internal,

Aspire.Hosting.RemoteHost.Tests (2)

RemoteHostProfilingTelemetryTests.cs (2)

167var clientActivity = clientSource.StartActivity("client", ActivityKind.Client); 173using (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)

203using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 225using 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)

104public static ActivityKind ActivityKind { get; private set; } 257private static ActivityKind GetActivityKind(ActivityContext? parentActivityContext) => 258parentActivityContext 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); 950private 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)

162ActivityKind.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, 2277public 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> 163public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 170/// <param name="kind">The <see cref="ActivityKind"/></param> 179public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 186/// <param name="kind">The <see cref="ActivityKind"/></param> 188public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 195/// <param name="kind">The <see cref="ActivityKind"/></param> 201public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 208/// <param name="kind">The <see cref="ActivityKind"/></param> 214public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 220/// <param name="kind">The <see cref="ActivityKind"/></param> 227public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 230private 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);