3 instantiations of Subscription
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
282subscription = new Subscription(name, resourceKey, subscriptionType, callback, () =>
Aspire.Dashboard.Tests (2)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (2)
147var subscription = new Subscription( 185var subscription = new Subscription(
35 references to Subscription
Aspire.Dashboard (26)
Components\Dialogs\GenAIVisualizerDialog.razor.cs (3)
29private Subscription? _resourcesSubscription; 30private Subscription? _tracesSubscription; 31private Subscription? _logsSubscription;
Components\Dialogs\ManageDataDialog.razor.cs (1)
73private Subscription? _resourcesSubscription;
Components\Pages\Metrics.razor.cs (2)
30private Subscription? _resourcesSubscription; 31private Subscription? _metricsSubscription;
Components\Pages\Resources.razor.cs (1)
40private Subscription? _logsSubscription;
Components\Pages\StructuredLogs.razor.cs (2)
44private Subscription? _resourcesSubscription; 45private Subscription? _logsSubscription;
Components\Pages\TraceDetail.razor.cs (1)
36private Subscription? _tracesSubscription;
Components\Pages\Traces.razor.cs (2)
42private Subscription? _resourcesSubscription; 43private Subscription? _tracesSubscription;
Otlp\Storage\TelemetryRepository.cs (14)
36private readonly List<Subscription> _resourceSubscriptions = new(); 37private readonly List<Subscription> _logSubscriptions = new(); 38private readonly List<Subscription> _metricsSubscriptions = new(); 39private readonly List<Subscription> _tracesSubscriptions = new(); 70internal List<Subscription> TracesSubscriptions => _tracesSubscriptions; 259public Subscription OnNewResources(Func<Task> callback) 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) 281Subscription? subscription = null; 298private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 302foreach (var subscription in subscriptions)
Aspire.Dashboard.Tests (9)
TelemetryRepositoryTests\LogTests.cs (6)
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); 536var subscription = repository.OnNewResources(() => 576var subscription = repository.OnNewResources(() => 713var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, async () =>
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (3)
30using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 147var subscription = new Subscription( 185var subscription = new Subscription(