1 instantiation of Subscription
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
241subscription = new Subscription(name, applicationKey, subscriptionType, callback, () =>
28 references to Subscription
Aspire.Dashboard (22)
Components\Pages\Metrics.razor.cs (2)
27private Subscription? _applicationsSubscription; 28private Subscription? _metricsSubscription;
Components\Pages\Resources.razor.cs (1)
28private Subscription? _logsSubscription;
Components\Pages\StructuredLogs.razor.cs (2)
38private Subscription? _applicationsSubscription; 39private Subscription? _logsSubscription;
Components\Pages\TraceDetail.razor.cs (1)
26private Subscription? _tracesSubscription;
Components\Pages\Traces.razor.cs (2)
36private Subscription? _applicationsSubscription; 37private Subscription? _tracesSubscription;
Otlp\Storage\TelemetryRepository.cs (14)
29private readonly List<Subscription> _applicationSubscriptions = new(); 30private readonly List<Subscription> _logSubscriptions = new(); 31private readonly List<Subscription> _metricsSubscriptions = new(); 32private readonly List<Subscription> _tracesSubscriptions = new(); 54internal List<Subscription> TracesSubscriptions => _tracesSubscriptions; 218public Subscription OnNewApplications(Func<Task> callback) 223public Subscription OnNewLogs(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 228public Subscription OnNewMetrics(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 233public Subscription OnNewTraces(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 238private Subscription AddSubscription(string name, ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 240Subscription? subscription = null; 257private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 261foreach (var subscription in subscriptions)
Aspire.Dashboard.Tests (6)
TelemetryRepositoryTests\LogTests.cs (6)
277using var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Read, () => Task.CompletedTask); 329using var subscription = repository.OnNewLogs(applicationKey: new ApplicationKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 382using var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Other, () => Task.CompletedTask); 537var subscription = repository.OnNewApplications(() => 577var subscription = repository.OnNewApplications(() => 714var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Read, async () =>