253IsEnabled(configuration) ? new(Activity.Current, configuration, ownsActivity: false) : default; 322var scope = new ActivityScope(activity); 503return new ActivityScope(activity, configuration); 531return new ActivityScope(activity, configuration); 565return new ActivityScope(activity, _configuration); 599return new ActivityScope(activity, _configuration);

144using var activity = ProfilingTelemetry.StartResourceWaitForDependency(Configuration, resource, dependency, WaitType.WaitUntilHealthy, waitBehavior); 300using var activity = ProfilingTelemetry.StartResourceWaitForDependency(Configuration, resource, dependency, WaitType.WaitForCompletion, waitBehavior: null); 450using var activity = ProfilingTelemetry.StartResourceWaitForDependency(Configuration, resource, dependency, WaitType.WaitUntilStarted, waitBehavior); 489using var activity = ProfilingTelemetry.StartResourceWaitForDependencies(Configuration, resource, waitAnnotationList.Length); 665var activity = ProfilingTelemetry.CurrentActivity(Configuration); 1052using var activity = ProfilingTelemetry.StartResourceStartup(configuration, resource, resourceId, readySnapshot, firstObservedAt); 1057using var activity = ProfilingTelemetry.StartResourceStartup(configuration, resource, resourceId, readySnapshot, firstObservedAt); 1064ProfilingTelemetry.ActivityScope activity,

180using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetDashboardUrlsAsync), streaming: false); 211using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetCapabilitiesAsync), streaming: false); 293using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetPipelineStepsAsync), streaming: false, request?.TraceContext);

49using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetCapabilitiesAsync), streaming: false, request?.TraceContext); 65using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetAppHostInfoAsync), streaming: false, request?.TraceContext); 88using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetDashboardInfoAsync), streaming: false, request?.TraceContext); 119using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetResourcesAsync), streaming: false, request?.TraceContext); 143using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(WatchResourcesAsync), streaming: true, request?.TraceContext); 223using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(CallMcpToolAsync), streaming: false, request.TraceContext); 256using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(StopAsync), streaming: false, request?.TraceContext); 270using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(ExecuteResourceCommandAsync), streaming: false, request.TraceContext); 630using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(WaitForResourceAsync), streaming: false, request.TraceContext); 918using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(GetDashboardUrlsAsync), streaming: false); 941using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(WaitForAppHostReadyAsync), streaming: false, request?.TraceContext); 1575using var activity = profilingTelemetry.StartJsonRpcServerCall(rpcMethodName, streaming: true, traceContext);

48using var activity = profilingTelemetry.StartBackchannelStartup(unixSocketPath);

48using var activity = profilingTelemetry.StartDashboardGetConnectionInfo(); 52using (var waitActivity = profilingTelemetry.StartDashboardWaitHealthy()) 88using (var resolveActivity = profilingTelemetry.StartDashboardResolveUrls())

142using var activity = ProfilingTelemetry.StartDcpRunApplication(_configuration, _model.Resources.Count); 160using (var prepareServicesActivity = ProfilingTelemetry.StartDcpPrepareServices(_configuration)) 175using (var prepareResourcesActivity = ProfilingTelemetry.StartDcpPrepareResources(_configuration)) 483using var activity = ProfilingTelemetry.StartDcpAllocateServiceAddresses(_configuration, initialServiceCount); 627using var currentActivity = ProfilingTelemetry.CurrentActivity(_configuration); 929using var activity = ProfilingTelemetry.StartResourceCreate(_configuration, modelResource, resourceType, replicas.Length); 1131using var activity = ProfilingTelemetry.StartResourceStop(_configuration, resourceReference.ModelResource, appResource.DcpResourceKind, appResource.DcpResourceName); 1199using var activity = ProfilingTelemetry.StartResourceStart(_configuration, resourceReference.ModelResource, appResource.DcpResourceKind, appResource.DcpResourceName, resourceType);

192using var activity = ProfilingTelemetry.StartDcpPrepareTlsCertificate(_configuration);

531using var activity = _profilingTelemetry.StartDcpResourceObserved(

474using var activity = ProfilingTelemetry.StartDcpKubernetesApi(configuration, operationType, resourceType); 508ProfilingTelemetry.ActivityScope activity, 591using var activity = ProfilingTelemetry.StartDcpEnsureKubernetesClient(configuration, File.Exists(locations.DcpKubeconfigPath));

223public static ActivityScope StartAppHostProcessStartup(IConfiguration? configuration) 230var activity = StartActivity(configuration, Activities.AppHostProcessStartup, ActivityKind.Internal, GetProcessStartTime()); 237using var activity = StartAppHostProcessStartup(configuration); 252public static ActivityScope CurrentActivity(IConfiguration? configuration) => 264public static ActivityScope StartDcpRunApplication(IConfiguration? configuration, int resourceCount) 266var activity = StartActivity(configuration, Activities.DcpRunApplication); 271public static ActivityScope StartDcpPrepareTlsCertificate(IConfiguration? configuration) 273var activity = StartActivity(configuration, Activities.DcpPrepareTlsCertificate); 278public static ActivityScope StartAppHostStart(IConfiguration? configuration, string entryPoint) 280var activity = StartActivity(configuration, Activities.AppHostStart); 285public static ActivityScope StartAppHostBeforeStart(IConfiguration? configuration) 290public static ActivityScope StartAppHostEventingSubscribers(IConfiguration? configuration, int subscriberCount) 292var activity = StartActivity(configuration, Activities.AppHostEventingSubscribers); 297public static ActivityScope StartAppHostEventingSubscriber(IConfiguration? configuration, Type subscriberType) 299var activity = StartActivity(configuration, Activities.AppHostEventingSubscriber); 304public static ActivityScope StartAppHostPublishEvent(IConfiguration? configuration, Type eventType) 306var activity = StartActivity(configuration, Activities.AppHostPublishEvent); 311public static ActivityScope StartAppHostEventCallback(Type eventType, string dispatchBehavior) 322var scope = new ActivityScope(activity); 327public static ActivityScope StartAppHostLifecycleHooks(IConfiguration? configuration, int lifecycleHookCount) 329var activity = StartActivity(configuration, Activities.AppHostLifecycleHooks); 334public static ActivityScope StartAppHostLifecycleHook(IConfiguration? configuration, Type lifecycleHookType) 336var activity = StartActivity(configuration, Activities.AppHostLifecycleHook); 341public static ActivityScope StartAppHostBeforeStartPipeline(IConfiguration? configuration, string pipelineStep) 343var activity = StartActivity(configuration, Activities.AppHostBeforeStartPipeline); 348public ActivityScope StartAppHostHostStartup() 353public static ActivityScope StartDcpPrepareServices(IConfiguration? configuration) 358public static ActivityScope StartDcpPrepareResources(IConfiguration? configuration) 363public static ActivityScope StartDcpAllocateServiceAddresses(IConfiguration? configuration, int serviceCount) 365var activity = StartActivity(configuration, Activities.DcpAllocateServiceAddresses); 370public static ActivityScope StartDcpEnsureKubernetesClient(IConfiguration? configuration, bool kubeconfigExists) 372var activity = StartActivity(configuration, Activities.DcpEnsureKubernetesClient); 377public static ActivityScope StartDcpKubernetesApi(IConfiguration? configuration, DcpApiOperationType operationType, string resourceType) 379var activity = StartActivity(configuration, Activities.DcpKubernetesApi); 384public ActivityScope StartDcpResourceObserved( 395var activity = StartActivityFromTraceAnnotations(Activities.DcpResourceObserved, annotations); 402public static ActivityScope StartResourceBeforeStartWait(IConfiguration? configuration, IResource resource) 404var activity = StartActivity(configuration, Activities.ResourceBeforeStartWait); 409public static ActivityScope StartResourceCreate(IConfiguration? configuration, IResource resource, string resourceKind, int replicaCount) 411var activity = StartActivity(configuration, Activities.ResourceCreate); 417public static ActivityScope StartResourceStartup( 424var activity = StartActivity(configuration, $"{Activities.ResourceStartup} {resource.Name}", ActivityKind.Internal, startTime); 429public static ActivityScope StartResourceStart(IConfiguration? configuration, IResource resource, string resourceKind, string resourceName, string resourceType) 431var activity = StartActivity(configuration, Activities.ResourceStart); 438public ActivityScope StartBackchannelStartup(string socketPath) 440var activity = StartActivity(Activities.BackchannelStartup); 445public ActivityScope StartJsonRpcServerCall(string methodName, bool streaming, BackchannelTraceContext? traceContext = null) 447var activity = StartActivityFromTraceContext(Activities.JsonRpcServerCall, ActivityKind.Server, traceContext); 452public ActivityScope StartDashboardGetConnectionInfo() 457public ActivityScope StartDashboardWaitHealthy() 462public ActivityScope StartDashboardResolveUrls() 467public static ActivityScope StartResourceStop(IConfiguration? configuration, IResource resource, string resourceKind, string resourceName) 469var activity = StartActivity(configuration, Activities.ResourceStop); 475public static ActivityScope StartResourceWaitForDependencies(IConfiguration? configuration, IResource resource, int dependencyCount) 477var activity = StartActivity(configuration, Activities.ResourceWaitForDependencies); 483public static ActivityScope StartResourceWaitForDependency(IConfiguration? configuration, IResource resource, IResource dependency, WaitType waitType, WaitBehavior? waitBehavior) 485var activity = StartActivity(configuration, Activities.ResourceWaitForDependency); 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) 539private ActivityScope StartActivityFromTraceAnnotations(string name, IDictionary<string, string>? annotations) 568private ActivityScope StartActivityFromTraceContext(string name, ActivityKind activityKind, BackchannelTraceContext? traceContext)

456using var appHostStartActivity = ProfilingTelemetry.StartAppHostStart(configuration, nameof(StartAsync)); 529using (var appHostStartActivity = ProfilingTelemetry.StartAppHostStart(configuration, nameof(RunAsync))) 596using var beforeStartActivity = ProfilingTelemetry.StartAppHostBeforeStart(configuration); 603using (var eventSubscribersActivity = ProfilingTelemetry.StartAppHostEventingSubscribers(configuration, eventSubscribers.Length)) 607using var eventSubscriberActivity = ProfilingTelemetry.StartAppHostEventingSubscriber(configuration, subscriber.GetType()); 630using (var publishEventActivity = ProfilingTelemetry.StartAppHostPublishEvent(configuration, typeof(BeforeStartEvent))) 648using (var lifecycleHooksActivity = ProfilingTelemetry.StartAppHostLifecycleHooks(configuration, lifecycleHooks.Length)) 652using var lifecycleHookActivity = ProfilingTelemetry.StartAppHostLifecycleHook(configuration, lifecycleHook.GetType()); 698using (var pipelineActivity = ProfilingTelemetry.StartAppHostBeforeStartPipeline(configuration, WellKnownPipelineSteps.BeforeStart))

19private ProfilingTelemetry.ActivityScope _hostStartupActivity;

83var activity = ProfilingTelemetry.StartAppHostEventCallback(typeof(T), dispatchBehavior.ToString()); 102static async Task AwaitSubscriptionCallbackAsync(Task callbackTask, ProfilingTelemetry.ActivityScope activity)

116using var activity = ProfilingTelemetry.StartResourceBeforeStartWait(Configuration, @event.Resource);

2238using var activity = profilingTelemetry.StartJsonRpcServerCall(nameof(AuxiliaryBackchannelRpcTarget.GetDashboardUrlsAsync), streaming: false);

279using var activity = telemetry.StartJsonRpcServerCall( 321using var activity = ProfilingTelemetry.StartDcpRunApplication(configuration, resourceCount: 1);