1 instantiation of Subscription
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
276subscription = new Subscription(name, resourceKey, subscriptionType, callback, () =>
29 references to Subscription
Aspire.Dashboard (22)
Components\Pages\Metrics.razor.cs (2)
30private Subscription? _resourcesSubscription; 31private Subscription? _metricsSubscription;
Components\Pages\Resources.razor.cs (1)
36private Subscription? _logsSubscription;
Components\Pages\StructuredLogs.razor.cs (2)
39private Subscription? _resourcesSubscription; 40private Subscription? _logsSubscription;
Components\Pages\TraceDetail.razor.cs (1)
29private Subscription? _tracesSubscription;
Components\Pages\Traces.razor.cs (2)
37private Subscription? _resourcesSubscription; 38private Subscription? _tracesSubscription;
Otlp\Storage\TelemetryRepository.cs (14)
35private readonly List<Subscription> _resourceSubscriptions = new(); 36private readonly List<Subscription> _logSubscriptions = new(); 37private readonly List<Subscription> _metricsSubscriptions = new(); 38private readonly List<Subscription> _tracesSubscriptions = new(); 64internal List<Subscription> TracesSubscriptions => _tracesSubscriptions; 253public Subscription OnNewResources(Func<Task> callback) 258public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 263public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 268public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 273private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 275Subscription? subscription = null; 292private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 296foreach (var subscription in subscriptions)
Aspire.Dashboard.Tests (7)
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 (1)
25using var subscription = repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask);