75 references to ActivityKind
aspire (5)
Certificates\CertificatesHelper.cs (1)
20using var activity = _activitySource.StartActivity(nameof(EnsureCertificatesTrustedAsync), ActivityKind.Client);
Commands\PublishCommand.cs (2)
95ActivityKind.Client); 157ActivityKind.Internal);
DotNetCliRunner.cs (1)
190using var activity = _activitySource.StartActivity(nameof(InstallTemplateAsync), ActivityKind.Client);
Utils\AppHostHelper.cs (1)
52using var activity = s_activitySource.StartActivity(nameof(GetAppHostInformationAsync), ActivityKind.Client);
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.Microsoft.Data.SqlClient (1)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (1)
58ActivityKind.Client,
Aspire.Microsoft.EntityFrameworkCore.SqlServer (1)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (1)
58ActivityKind.Client,
Aspire.RabbitMQ.Client (2)
src\Components\Aspire.RabbitMQ.Client\AspireRabbitMQExtensions.cs (2)
193using var activity = s_activitySource.StartActivity("rabbitmq connect", ActivityKind.Client); 215using 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);
Microsoft.AspNetCore.Diagnostics (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
19ActivityKind kind,
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (1)
src\Shared\Diagnostics\ActivityCreator.cs (1)
19ActivityKind kind,
Microsoft.AspNetCore.Hosting (2)
Internal\HostingApplicationDiagnostics.cs (1)
404ActivityKind.Server,
src\Shared\Diagnostics\ActivityCreator.cs (1)
19ActivityKind kind,
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1110var activity = _activitySource.CreateActivity(ActivityName, ActivityKind.Client);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (14)
HubConnectionTests.Tracing.cs (14)
146Assert.Equal(ActivityKind.Internal, a.Kind); 156Assert.Equal(ActivityKind.Server, a.Kind); 168Assert.Equal(ActivityKind.Server, a.Kind); 180Assert.Equal(ActivityKind.Internal, a.Kind); 189Assert.Equal(ActivityKind.Client, clientActivity1.Kind); 206Assert.Equal(ActivityKind.Client, clientActivity2.Kind); 317Assert.Equal(ActivityKind.Internal, a.Kind); 327Assert.Equal(ActivityKind.Server, a.Kind); 340Assert.Equal(ActivityKind.Internal, a.Kind); 349Assert.Equal(ActivityKind.Client, clientActivity.Kind); 455Assert.Equal(ActivityKind.Client, clientActivity.Kind); 552Assert.Equal(ActivityKind.Client, clientActivity.Kind); 648Assert.Equal(ActivityKind.Client, clientActivity.Kind); 744Assert.Equal(ActivityKind.Client, clientActivity.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); 130activity = StartActivity(SignalRServerActivitySource.OnDisconnected, ActivityKind.Internal, linkedActivity: null, scope.ServiceProvider, nameof(hub.OnDisconnectedAsync), headers: null, _logger); 407var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger); 525var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger); 834private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger)
src\Shared\Diagnostics\ActivityCreator.cs (1)
19ActivityKind kind,
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTestUtils\Hubs.cs (1)
376var activity = testActivitySource.ActivitySource.StartActivity("inner", ActivityKind.Server);
Microsoft.Build.Framework (1)
Telemetry\MSBuildActivitySource.cs (1)
29? _source.StartActivity($"{TelemetryConstants.EventPrefix}{name}", ActivityKind.Internal, parentId: Activity.Current.ParentId)
Microsoft.Extensions.AI (2)
ChatCompletion\OpenTelemetryChatClient.cs (1)
232ActivityKind.Client);
Embeddings\OpenTelemetryEmbeddingGenerator.cs (1)
144ActivityKind.Client,
Stress.ApiService (7)
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))
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 (23)
System\Diagnostics\Activity.cs (3)
170public ActivityKind Kind { get; private set; } = ActivityKind.Internal; 1178internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext,
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)
114/// <param name="kind">The <see cref="ActivityKind"/></param> 119public Activity? CreateActivity(string name, ActivityKind kind) 127/// <param name="kind">The <see cref="ActivityKind"/></param> 136public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 143/// <param name="kind">The <see cref="ActivityKind"/></param> 152public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown) 159/// <param name="kind">The <see cref="ActivityKind"/></param> 161public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal) 168/// <param name="kind">The <see cref="ActivityKind"/></param> 174public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 181/// <param name="kind">The <see cref="ActivityKind"/></param> 187public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default) 193/// <param name="kind">The <see cref="ActivityKind"/></param> 200public Activity? StartActivity(ActivityKind kind, ActivityContext parentContext = default, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default, [CallerMemberName] string name = "") 203private 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)
61activity = s_activitySource.StartActivity(DiagnosticsHandlerLoggingStrings.RequestActivityName, ActivityKind.Client);