18 references to SubscriptionType
Aspire.Dashboard (13)
Components\Pages\Metrics.razor.cs (1)
269
_metricsSubscription = TelemetryRepository.OnNewMetrics(selectedApplicationKey,
SubscriptionType
.Read, async () =>
Components\Pages\Resources.razor.cs (1)
171
_logsSubscription = TelemetryRepository.OnNewLogs(null,
SubscriptionType
.Other, async () =>
Components\Pages\StructuredLogs.razor.cs (1)
226
_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedApplication.Id?.GetApplicationKey(),
SubscriptionType
.Read, async () =>
Components\Pages\TraceDetail.razor.cs (1)
245
_tracesSubscription = TelemetryRepository.OnNewTraces(trace.FirstSpan.Source.ApplicationKey,
SubscriptionType
.Read, () => InvokeAsync(() =>
Components\Pages\Traces.razor.cs (1)
185
_tracesSubscription = TelemetryRepository.OnNewTraces(selectedApplicationKey,
SubscriptionType
.Read, async () =>
Otlp\Storage\Subscription.cs (2)
20
public
SubscriptionType
SubscriptionType { get; }
23
public Subscription(string name, ApplicationKey? applicationKey,
SubscriptionType
subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, TelemetryRepository telemetryRepository)
Otlp\Storage\TelemetryRepository.cs (6)
213
return AddSubscription(nameof(OnNewApplications), null,
SubscriptionType
.Read, callback, _applicationSubscriptions);
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)
339
if (!_logSubscriptions.Any(s => s.SubscriptionType ==
SubscriptionType
.Read && (s.ApplicationKey == application.ApplicationKey || s.ApplicationKey == null)))
Aspire.Dashboard.Tests (5)
TelemetryRepositoryTests\LogTests.cs (5)
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);
439
repository.OnNewLogs(applications[0].ApplicationKey,
SubscriptionType
.Read, () =>
660
var subscription = repository.OnNewLogs(applicationKey: null,
SubscriptionType
.Read, () =>