3 instantiations of Subscription
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
277subscription = new Subscription(name, resourceKey, subscriptionType, callback, () =>
Aspire.Dashboard.Tests (2)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (2)
146var subscription = new Subscription( 184var 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)
38private 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(); 65internal List<Subscription> TracesSubscriptions => _tracesSubscriptions; 254public Subscription OnNewResources(Func<Task> callback) 259public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 264public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 269public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 274private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 276Subscription? subscription = null; 293private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 297foreach (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)
29using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 146var subscription = new Subscription( 184var subscription = new Subscription(