23 references to SubscriptionType
Aspire.Dashboard (15)
Components\Dialogs\GenAIVisualizerDialog.razor.cs (2)
76_tracesSubscription = TelemetryRepository.OnNewTraces(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData); 77_logsSubscription = TelemetryRepository.OnNewLogs(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData);
Components\Pages\Metrics.razor.cs (1)
328_metricsSubscription = TelemetryRepository.OnNewMetrics(selectedResourceKey, SubscriptionType.Read, async () =>
Components\Pages\Resources.razor.cs (1)
279_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () =>
Components\Pages\StructuredLogs.razor.cs (1)
302_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedResource.Id?.GetResourceKey(), SubscriptionType.Read, async () =>
Components\Pages\TraceDetail.razor.cs (1)
349_tracesSubscription = TelemetryRepository.OnNewTraces(_trace.FirstSpan.Source.ResourceKey, SubscriptionType.Read, () => InvokeAsync(async () =>
Components\Pages\Traces.razor.cs (1)
237_tracesSubscription = TelemetryRepository.OnNewTraces(selectedResourceKey, SubscriptionType.Read, async () =>
Otlp\Storage\Subscription.cs (2)
24public SubscriptionType SubscriptionType { get; } 27public Subscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, TelemetryRepository telemetryRepository)
Otlp\Storage\TelemetryRepository.cs (6)
261return AddSubscription(nameof(OnNewResources), null, SubscriptionType.Read, callback, _resourceSubscriptions); 264public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 269public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 274public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 279private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 382if (!_logSubscriptions.Any(s => s.SubscriptionType == SubscriptionType.Read && (s.ResourceKey == resourceView.ResourceKey || s.ResourceKey == null)))
Aspire.Dashboard.Tests (8)
TelemetryRepositoryTests\LogTests.cs (5)
276using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, () => Task.CompletedTask); 328using var subscription = repository.OnNewLogs(resourceKey: new ResourceKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 381using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 490repository.OnNewLogs(resources[0].ResourceKey, SubscriptionType.Read, () => 713var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, async () =>
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (3)
30using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 150subscriptionType: SubscriptionType.Read, 188subscriptionType: SubscriptionType.Read,