15 instantiations of Activity
Microsoft.AspNetCore.Diagnostics (1)
Microsoft.AspNetCore.Hosting (1)
Microsoft.AspNetCore.SignalR.Client.Core (1)
Microsoft.AspNetCore.SignalR.Core (1)
Microsoft.Extensions.Telemetry.Tests (9)
System.Diagnostics.DiagnosticSource (1)
System.Net.Http (1)
673 references to Activity
aspire (84)
Aspire.Cli.Tests (12)
Aspire.Components.Common.TestUtilities (11)
Aspire.Confluent.Kafka (15)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (3)
327using Activity? activity = this.StartReceiveActivity(propagationContext, startTime, consumeResult.TopicPartitionOffset, consumeResult.Key);
350private Activity? StartReceiveActivity(PropagationContext propagationContext, DateTimeOffset start, TopicPartitionOffset? topicPartitionOffset, object? key)
360Activity? activity = ConfluentKafkaCommon.ActivitySource.StartActivity(spanName, kind: ActivityKind.Consumer, links: activityLinks, startTime: start, parentContext: default);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (7)
46using Activity? activity = this.StartPublishActivity(start, topic, message);
93using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition);
137using Activity? activity = this.StartPublishActivity(start, topic, message);
178using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition);
325private Activity? StartPublishActivity(DateTimeOffset start, string topic, Message<TKey, TValue> message, int? partition = null)
333var activity = ConfluentKafkaCommon.ActivitySource.StartActivity(name: spanName, kind: ActivityKind.Producer, startTime: start);
360private void InjectActivity(Activity? activity, Message<TKey, TValue> message)
Aspire.Confluent.Kafka.Tests (1)
Aspire.Dashboard (1)
Aspire.NATS.Net.Tests (1)
Aspire.Oracle.EntityFrameworkCore.Tests (1)
Aspire.RabbitMQ.Client (4)
Aspire.StackExchange.Redis (11)
Aspire.StackExchange.Redis.Tests (1)
CatalogDb (1)
DatabaseMigration.MigrationService (1)
dotnet (28)
Microsoft.AspNetCore.Components (14)
Microsoft.AspNetCore.Components.Endpoints (1)
Microsoft.AspNetCore.Components.Server (10)
Microsoft.AspNetCore.Diagnostics (2)
Microsoft.AspNetCore.Hosting (13)
Microsoft.AspNetCore.Http (1)
Microsoft.AspNetCore.Http.Extensions (1)
Microsoft.AspNetCore.Identity.UI (2)
Microsoft.AspNetCore.Mvc.Core (1)
Microsoft.AspNetCore.SignalR.Client.Core (13)
Internal\InvocationRequest.cs (6)
27public Activity? Activity { get; }
29protected InvocationRequest(CancellationToken cancellationToken, Type resultType, string invocationId, ILogger logger, HubConnection hubConnection, Activity? activity)
49public static InvocationRequest Invoke(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out Task<object?> result)
57ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out ChannelReader<object?> result)
90public Streaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity)
178public NonStreaming(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity)
Microsoft.AspNetCore.SignalR.Core (23)
Internal\DefaultHubDispatcher.cs (19)
89Activity? activity = null;
126Activity? activity = null;
173Activity? activity = null;
448var previousActivity = Activity.Current;
451Activity.Current = null;
456var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, logger, connection);
493if (Activity.Current != previousActivity)
495Activity.Current = previousActivity;
594var previousActivity = Activity.Current;
597Activity.Current = null;
600var activity = StartActivity(SignalRServerActivitySource.InvocationIn, ActivityKind.Server, connection.OriginalActivity, scope.ServiceProvider, hubMethodInvocationMessage.Target, hubMethodInvocationMessage.Headers, _logger, connection);
669if (Activity.Current != previousActivity)
671Activity.Current = previousActivity;
930private static Activity? StartActivity(string operationName, ActivityKind kind, Activity? linkedActivity, IServiceProvider serviceProvider, string methodName, IDictionary<string, string>? headers, ILogger logger, HubConnectionContext? connection = null)
960Activity? activity;
995private static void SetActivityError(Activity? activity, Exception ex)
Microsoft.Build.Framework (6)
Microsoft.DotNet.Cli.Utils (2)
Microsoft.Extensions.AI (37)
Microsoft.Extensions.AI.Integration.Tests (10)
Microsoft.Extensions.AI.OpenAI (3)
Microsoft.Extensions.AI.OpenAI.Tests (4)
Microsoft.Extensions.AI.Tests (35)
Microsoft.Extensions.DataIngestion (6)
Microsoft.Extensions.DataIngestion.Tests (7)
Microsoft.Extensions.Diagnostics (7)
Microsoft.Extensions.Diagnostics.Abstractions (15)
Microsoft.Extensions.Logging (7)
Microsoft.Extensions.Logging.EventSource (2)
Microsoft.Extensions.ServiceDiscovery.Dns (1)
Microsoft.Extensions.Telemetry (9)
Microsoft.Extensions.Telemetry.Tests (14)
Microsoft.TemplateEngine.Cli (10)
MSBuild.Coordinator (1)
OrderProcessor (2)
Seq.ApiService (1)
Stress.ApiService (39)
TraceCreator.cs (11)
17private readonly List<Activity> _allActivities = new List<Activity>();
19public Activity? CreateActivity(string name, string? spandId)
21var activity = s_activitySource.StartActivity(name, ActivityKind.Client);
27typeof(Activity).GetField("_spanId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, spandId);
28typeof(Activity).GetField("_traceId", BindingFlags.Instance | BindingFlags.NonPublic)!.SetValue(activity, activity.TraceId.ToString());
37var activityStack = new Stack<Activity>();
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));
93private static void AddEvents(Activity activity)
128var a = _allActivities[Random.Shared.Next(0, _allActivities.Count)];
System.Diagnostics.DiagnosticSource (149)
System\Diagnostics\Activity.cs (45)
19/// Carries the <see cref="Activity.Current"/> changed event data.
23internal ActivityChangedEventArgs(Activity? previous, Activity? current)
30/// Gets <see cref="Activity"/> object before the event.
32public Activity? Previous { get; init; }
35/// Gets <see cref="Activity"/> object after the event.
37public Activity? Current { get; init; }
68private static readonly AsyncLocal<Activity?> s_current = new AsyncLocal<Activity?>();
82/// Event occur when the <see cref="Activity.Current"/> value changes.
120private Activity? _previousActiveActivity;
141public static Activity? Current
163public Activity SetStatus(ActivityStatusCode code, string? description = null)
206public Activity? Parent { get; private set; }
383for (Activity? activity = this; activity != null; activity = activity.Parent)
393static IEnumerable<KeyValuePair<string, string?>> Iterate(Activity? activity)
479public Activity AddTag(string key, string? value) => AddTag(key, (object?)value);
489public Activity AddTag(string key, object? value)
513public Activity SetTag(string key, object? value)
530public Activity AddEvent(ActivityEvent e)
555public Activity AddException(Exception exception, in TagList tags = default, DateTimeOffset timestamp = default)
615public Activity AddLink(ActivityLink link)
634public Activity AddBaggage(string key, string? value)
658public Activity SetBaggage(string key, string? value)
679public Activity SetParentId(string parentId)
709public Activity SetParentId(ActivityTraceId traceId, ActivitySpanId spanId, ActivityTraceFlags activityTraceFlags = ActivityTraceFlags.None)
739public Activity SetStartTime(DateTime startTimeUtc)
759public Activity SetEndTime(DateTime endTimeUtc)
788/// Use <see cref="DiagnosticSource.StartActivity(Activity, object)"/> to start activity and write start event.
790/// <seealso cref="DiagnosticSource.StartActivity(Activity, object)"/>
792public Activity Start()
844/// Use <see cref="DiagnosticSource.StopActivity(Activity, object)"/> to stop activity and write stop event.
846/// <seealso cref="DiagnosticSource.StopActivity(Activity, object)"/>
889for (Activity? activity = this; activity != null; activity = activity.Parent)
1054public Activity SetIdFormat(ActivityIdFormat format)
1183internal static Activity Create(ActivitySource source, string name, ActivityKind kind, string? parentId, ActivityContext parentContext,
1187Activity activity = new Activity(name);
1268private static void SetCurrent(Activity? activity)
1277Activity? previous = s_current.Value;
1439private static bool ValidateSetCurrent(Activity? activity)
1524/// Indicates whether this <see cref="Activity"/> object is stopped
1527/// When subscribing to <see cref="Activity"/> stop event using <see cref="ActivityListener.ActivityStopped"/>, the received <see cref="Activity"/> object in the event callback will have <see cref="IsStopped"/> as true.
2233internal sealed class ActivityDebuggerProxy(Activity activity)
2246public Activity? Parent => activity.Parent;
System\Diagnostics\ActivitySource.cs (39)
138/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise.
142/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns>
144/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it.
146public Activity? CreateActivity(string name, ActivityKind kind)
150/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise.
151/// If the Activity object is created, it will not automatically start. Callers will need to call <see cref="Activity.Start()"/> to start it.
159/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns>
161/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it.
163public Activity? CreateActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown)
167/// Creates a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise.
175/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns>
177/// If the Activity object is created, it will not start automatically. Callers need to call <see cref="Activity.Start()"/> to start it.
179public Activity? CreateActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, ActivityIdFormat idFormat = ActivityIdFormat.Unknown)
183/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity, returns null otherwise.
187/// <returns>The created <see cref="Activity"/> object or null if there is no any event listener.</returns>
188public Activity? StartActivity([CallerMemberName] string name = "", ActivityKind kind = ActivityKind.Internal)
192/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise.
200/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns>
201public Activity? StartActivity(string name, ActivityKind kind, ActivityContext parentContext, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default)
205/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise.
213/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns>
214public Activity? StartActivity(string name, ActivityKind kind, string? parentId, IEnumerable<KeyValuePair<string, object?>>? tags = null, IEnumerable<ActivityLink>? links = null, DateTimeOffset startTime = default)
218/// Creates and starts a new <see cref="Activity"/> object if there is any listener to the Activity events, returns null otherwise.
226/// <returns>The created <see cref="Activity"/> object or null if there is no any listener.</returns>
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,
242Activity? activity = null;
328bool useCurrentActivityContext = context == default && Activity.Current != null;
329var aco = new ActivityCreationOptions<ActivityContext>(this, name, useCurrentActivityContext ? Activity.Current!.Context : context, kind, tags, links, idFormat);
357activity = Activity.Create(this, name, kind, parentId, context, tags, links, startTime, samplerTags, samplingResult, startIt, idFormat, traceState);
381/// Add a listener to the <see cref="Activity"/> starting and stopping events.
383/// <param name="listener"> The <see cref="ActivityListener"/> object to use for listening to the <see cref="Activity"/> events.</param>
410/// Resets source filters for the <see cref="ActivityListener"/> object to start or stop listening to the <see cref="Activity"/> events based on the listener configuration.
518internal void NotifyActivityStart(Activity activity)
527listeners.EnumWithAction((listener, obj) => listener.ActivityStarted?.Invoke((Activity)obj), activity);
531internal void NotifyActivityStop(Activity activity)
540listeners.EnumWithAction((listener, obj) => listener.ActivityStopped?.Invoke((Activity)obj), activity);
544internal void NotifyActivityAddException(Activity activity, Exception exception, ref TagList tags)
650public void EnumWithExceptionNotification(Activity activity, Exception exception, ref TagList tags)
System\Diagnostics\DiagnosticSourceActivity.cs (17)
19/// was started. Consumers could access <see cref="Activity.Current"/>
27/// <seealso cref="Activity"/>
29public Activity StartActivity(Activity activity, object? args)
39public Activity StartActivity<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(Activity activity, T args)
44/// that Activity was stopped. Consumers could access <see cref="Activity.Current"/>
51/// <seealso cref="Activity"/>
53public void StopActivity(Activity activity, object? args)
58activity.SetEndTime(Activity.GetUtcNow());
66public void StopActivity<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(Activity activity, T args)
93public virtual void OnActivityImport(Activity activity, object? payload) { }
119public virtual void OnActivityExport(Activity activity, object? payload) { }
124public override void OnActivityImport(Activity activity, object? payload)
130public override void OnActivityExport(Activity activity, object? payload)
144Action<Activity, object?>? onActivityImport = null, Action<Activity, object?>? onActivityExport = null)
System.Net.Http (33)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (2)
296(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(request, async, isForHttp2: false, cancellationToken).ConfigureAwait(false);
300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (3)
188(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(queueItem.Request, true, isForHttp2: true, cts.Token).ConfigureAwait(false);
247private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
302private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System.Net.NameResolution (4)
System.Net.Security (4)
System.Net.Sockets (12)