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