1 instantiation of Subscription
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
234subscription = new Subscription(name, applicationKey, subscriptionType, callback, () =>
27 references to Subscription
Aspire.Dashboard (21)
Components\Pages\Metrics.razor.cs (2)
26private Subscription? _applicationsSubscription; 27private Subscription? _metricsSubscription;
Components\Pages\Resources.razor.cs (1)
34private Subscription? _logsSubscription;
Components\Pages\StructuredLogs.razor.cs (2)
37private Subscription? _applicationsSubscription; 38private Subscription? _logsSubscription;
Components\Pages\TraceDetail.razor.cs (1)
25private Subscription? _tracesSubscription;
Components\Pages\Traces.razor.cs (2)
35private Subscription? _applicationsSubscription; 36private Subscription? _tracesSubscription;
Otlp\Storage\TelemetryRepository.cs (13)
28private readonly List<Subscription> _applicationSubscriptions = new(); 29private readonly List<Subscription> _logSubscriptions = new(); 30private readonly List<Subscription> _metricsSubscriptions = new(); 31private readonly List<Subscription> _tracesSubscriptions = new(); 211public Subscription OnNewApplications(Func<Task> callback) 216public Subscription OnNewLogs(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 221public Subscription OnNewMetrics(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 226public Subscription OnNewTraces(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback) 231private Subscription AddSubscription(string name, ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 233Subscription? subscription = null; 250private void RaiseSubscriptionChanged(List<Subscription> subscriptions) 254foreach (var subscription in subscriptions)
Aspire.Dashboard.Tests (6)
TelemetryRepositoryTests\LogTests.cs (6)
225using var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Read, () => Task.CompletedTask); 277using var subscription = repository.OnNewLogs(applicationKey: new ApplicationKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 330using var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Other, () => Task.CompletedTask); 485var subscription = repository.OnNewApplications(() => 525var subscription = repository.OnNewApplications(() => 660var subscription = repository.OnNewLogs(applicationKey: null, SubscriptionType.Read, () =>