29 references to SubscriptionType
Aspire.Dashboard (18)
Components\Dialogs\GenAIVisualizerDialog.razor.cs (2)
84_tracesSubscription = TelemetryRepository.OnNewTraces(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData); 85_logsSubscription = TelemetryRepository.OnNewLogs(Content.Span.Source.ResourceKey, SubscriptionType.Read, UpdateDialogData);
Components\Pages\Metrics.razor.cs (1)
333_metricsSubscription = TelemetryRepository.OnNewMetrics(selectedResourceKey, SubscriptionType.Read, async () =>
Components\Pages\Resources.razor.cs (1)
244_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () =>
Components\Pages\StructuredLogs.razor.cs (1)
281_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedResource.Id?.GetResourceKey(), SubscriptionType.Read, async () =>
Components\Pages\TraceDetail.razor.cs (1)
351_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\ITelemetryRepository.cs (3)
33Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 34Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 35Subscription 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)
29public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewLogs(resourceKey, subscriptionType, callback); 30public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewMetrics(resourceKey, subscriptionType, callback); 31public 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)
31using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 150subscriptionType: SubscriptionType.Read, 187subscriptionType: SubscriptionType.Read,