42 references to SubscriptionType
Aspire.Dashboard (31)
Components\Controls\ApplicationSummary.razor.cs (3)
151_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, OnTelemetryChanged); 152_tracesSubscription = TelemetryRepository.OnNewTraces(null, SubscriptionType.Other, OnTelemetryChanged); 153_metricsSubscription = TelemetryRepository.OnNewMetrics(null, SubscriptionType.Other, OnTelemetryChanged);
Components\Dialogs\GenAIVisualizerDialog.razor.cs (2)
83_tracesSubscription = TelemetryRepository.OnNewTraces(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData); 84_logsSubscription = TelemetryRepository.OnNewLogs(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData);
Components\Layout\ResourcesLayout.razor.cs (2)
343_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () => 370_paneActivitySubscription = TelemetryRepository.OnNewTraces(null, SubscriptionType.Other, () =>
Components\Legacy\Pages\Metrics.razor.cs (1)
340_metricsSubscription = TelemetryRepository.OnNewMetrics(selectedResourceKey, SubscriptionType.Read, async () =>
Components\Legacy\Pages\Resources.razor.cs (1)
247_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () =>
Components\Legacy\Pages\StructuredLogs.razor.cs (1)
277_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedResource.Id?.GetResourceKey(), SubscriptionType.Read, async () =>
Components\Legacy\Pages\TraceDetail.razor.cs (1)
369_tracesSubscription = TelemetryRepository.OnNewTraces(_trace.FirstSpan.Source.ResourceKey, SubscriptionType.Read, () => InvokeAsync(async () =>
Components\Legacy\Pages\Traces.razor.cs (1)
236_tracesSubscription = TelemetryRepository.OnNewTraces(selectedResourceKey, SubscriptionType.Read, async () =>
Components\Pages\Metrics.razor.cs (1)
911_metricsSubscription = TelemetryRepository.OnNewMetrics(selectedResourceKey, SubscriptionType.Read, async () =>
Components\Pages\ResourceOverview.razor.cs (3)
246_logsSubscription = TelemetryRepository.OnNewLogs(key, SubscriptionType.Other, OnTelemetryChangedAsync); 247_tracesSubscription = TelemetryRepository.OnNewTraces(key, SubscriptionType.Other, OnTelemetryChangedAsync); 248_metricsSubscription = TelemetryRepository.OnNewMetrics(key, SubscriptionType.Other, OnTelemetryChangedAsync);
Components\Pages\Resources.razor.cs (1)
248_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () =>
Components\Pages\StructuredLogs.razor.cs (1)
320_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedResource.Id?.GetResourceKey(), SubscriptionType.Read, async () =>
Components\Pages\TraceDetail.razor.cs (1)
378_tracesSubscription = TelemetryRepository.OnNewTraces(_trace.FirstSpan.Source.ResourceKey, SubscriptionType.Read, () => InvokeAsync(async () =>
Components\Pages\Traces.razor.cs (1)
233_tracesSubscription = TelemetryRepository.OnNewTraces(selectedResourceKey, SubscriptionType.Read, async () =>
Otlp\Storage\ITelemetryRepository.cs (3)
36Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 37Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 38Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (6)
126AddSubscription(nameof(OnNewResources), null, SubscriptionType.Read, callback, _resourceSubscriptions); 128public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 131public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 134public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 140SubscriptionType subscriptionType, 182subscription.SubscriptionType == SubscriptionType.Read &&
Otlp\Storage\Subscription.cs (2)
24public SubscriptionType SubscriptionType { get; } 27public Subscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, ILogger logger, TimeSpan minExecuteInterval)
Aspire.Dashboard.Components.Tests (3)
Shared\TestTelemetryRepository.cs (3)
39public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 44public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewMetrics(resourceKey, subscriptionType, callback); 45public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewTraces(resourceKey, subscriptionType, callback);
Aspire.Dashboard.Tests (8)
TelemetryRepositoryTests\LogTests.cs (5)
530using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, () => Task.CompletedTask); 582using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: new ResourceKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 635using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 744repositoryContext.Repository.OnNewLogs(resources[0].ResourceKey, SubscriptionType.Read, () => 967var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, async () =>
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (3)
33using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 152subscriptionType: SubscriptionType.Read, 189subscriptionType: SubscriptionType.Read,