3 instantiations of Subscription
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
145subscription = new Subscription(name, resourceKey, subscriptionType, callback, () =>
Aspire.Dashboard.Tests (2)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (2)
147var subscription = new Subscription( 184var subscription = new Subscription(
44 references to Subscription
Aspire.Dashboard (31)
Api\TelemetryApiService.cs (1)
529using var subscription = telemetryRepository.OnNewResources(() =>
Components\Dialogs\GenAIVisualizerDialog.razor.cs (3)
31private Subscription? _resourcesSubscription; 32private Subscription? _tracesSubscription; 33private Subscription? _logsSubscription;
Components\Dialogs\ManageDataDialog.razor.cs (1)
76private Subscription? _resourcesSubscription;
Components\Pages\Metrics.razor.cs (2)
30private Subscription? _resourcesSubscription; 31private Subscription? _metricsSubscription;
Components\Pages\Resources.razor.cs (1)
39private Subscription? _logsSubscription;
Components\Pages\StructuredLogs.razor.cs (2)
43private Subscription? _resourcesSubscription; 44private Subscription? _logsSubscription;
Components\Pages\TraceDetail.razor.cs (1)
37private Subscription? _tracesSubscription;
Components\Pages\Traces.razor.cs (2)
43private Subscription? _resourcesSubscription; 44private Subscription? _tracesSubscription;
Otlp\Storage\ITelemetryRepository.cs (4)
32Subscription OnNewResources(Func<Task> callback); 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 (14)
17private readonly List<Subscription> _resourceSubscriptions = []; 18private readonly List<Subscription> _logSubscriptions = []; 19private readonly List<Subscription> _metricsSubscriptions = []; 20private readonly List<Subscription> _tracesSubscriptions = []; 125public Subscription OnNewResources(Func<Task> callback) => 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) => 137private Subscription AddSubscription( 142List<Subscription> subscriptions) 144Subscription? subscription = null; 161private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 163Subscription[] snapshot; 169foreach (var subscription in snapshot)
Aspire.Dashboard.Components.Tests (4)
Shared\TestTelemetryRepository.cs (4)
28public Subscription OnNewResources(Func<Task> callback) => inner.OnNewResources(callback); 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 (9)
TelemetryRepositoryTests\LogTests.cs (6)
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); 790var subscription = repositoryContext.Repository.OnNewResources(() => 830var subscription = repositoryContext.Repository.OnNewResources(() => 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); 147var subscription = new Subscription( 184var subscription = new Subscription(