2 instantiations of TelemetryRepository
Aspire.Dashboard.Components.Tests (1)
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
254var repository = new TelemetryRepository(
Aspire.Dashboard.Tests (1)
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
254var repository = new TelemetryRepository(
144 references to TelemetryRepository
Aspire.Dashboard (57)
Components\Controls\ResourceActions.razor.cs (1)
30public required TelemetryRepository TelemetryRepository { get; set; }
Components\Controls\TreeMetricSelector.razor.cs (1)
22public required TelemetryRepository TelemetryRepository { get; init; }
Components\Dialogs\FilterDialog.razor.cs (1)
27public required TelemetryRepository TelemetryRepository { get; init; }
Components\Dialogs\SettingsDialog.razor.cs (2)
25public required TelemetryRepository TelemetryRepository { get; init; } 90TelemetryRepository.ClearAllSignals();
Components\Pages\Resources.razor.cs (4)
42public required TelemetryRepository TelemetryRepository { get; init; } 182_applicationUnviewedErrorCounts = TelemetryRepository.GetApplicationUnviewedErrorLogsCount(); 205_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () => 207var newApplicationUnviewedErrorCounts = TelemetryRepository.GetApplicationUnviewedErrorLogsCount();
Components\Pages\StructuredLogs.razor.cs (13)
56public required TelemetryRepository TelemetryRepository { get; init; } 119if (logs.IsFull && !TelemetryRepository.HasDisplayedMaxLogLimitMessage) 121TelemetryRepository.MaxLogLimitMessage = await DashboardUIHelpers.DisplayMaxLimitMessageAsync( 125() => TelemetryRepository.MaxLogLimitMessage = null); 127TelemetryRepository.HasDisplayedMaxLogLimitMessage = true; 129else if (!logs.IsFull && TelemetryRepository.MaxLogLimitMessage is { } message) 140TelemetryRepository.MarkViewedErrorLogs(ViewModel.ApplicationKey); 197_applicationsSubscription = TelemetryRepository.OnNewApplications(() => InvokeAsync(() => 217_applications = TelemetryRepository.GetApplications(); 243_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedApplication.Id?.GetApplicationKey(), SubscriptionType.Read, async () => 303PropertyKeys = TelemetryRepository.GetLogPropertyKeys(PageViewModel.SelectedApplication.Id?.GetApplicationKey()), 305GetFieldValues = TelemetryRepository.GetLogsFieldValues 468TelemetryRepository.ClearStructuredLogs(key);
Components\Pages\TraceDetail.razor.cs (5)
49public required TelemetryRepository TelemetryRepository { get; init; } 171_applications = TelemetryRepository.GetApplications(); 174_trace = (TraceId != null) ? TelemetryRepository.GetTrace(TraceId) : null; 208_tracesSubscription = TelemetryRepository.OnNewTraces(_trace.FirstSpan.Source.ApplicationKey, SubscriptionType.Read, () => InvokeAsync(async () => 285trace ??= TelemetryRepository.GetTrace(traceId);
Components\Pages\Traces.razor.cs (12)
55public required TelemetryRepository TelemetryRepository { get; init; } 123if (traces.IsFull && !TelemetryRepository.HasDisplayedMaxTraceLimitMessage) 125TelemetryRepository.MaxTraceLimitMessage = await DashboardUIHelpers.DisplayMaxLimitMessageAsync( 129() => TelemetryRepository.MaxTraceLimitMessage = null); 131TelemetryRepository.HasDisplayedMaxTraceLimitMessage = true; 133else if (!traces.IsFull && TelemetryRepository.MaxTraceLimitMessage is { } message) 163_applicationsSubscription = TelemetryRepository.OnNewApplications(callback: () => InvokeAsync(workItem: () => 190_applications = TelemetryRepository.GetApplications(); 211_tracesSubscription = TelemetryRepository.OnNewTraces(selectedApplicationKey, SubscriptionType.Read, async () => 326PropertyKeys = TelemetryRepository.GetTracePropertyKeys(PageViewModel.SelectedApplication.Id?.GetApplicationKey()), 328GetFieldValues = TelemetryRepository.GetTraceFieldValues 360TelemetryRepository.ClearTraces(key);
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (3)
22public required TelemetryRepository TelemetryRepository { get; init; } 36var application = TelemetryRepository.GetApplicationByCompositeName(resource.Name); 47var applications = TelemetryRepository.GetApplications();
DashboardWebApplication.cs (1)
239builder.Services.AddSingleton<TelemetryRepository>();
Model\ResourceMenuItems.cs (1)
27TelemetryRepository telemetryRepository,
Model\StructuredLogsViewModel.cs (2)
12private readonly TelemetryRepository _telemetryRepository; 22public StructuredLogsViewModel(TelemetryRepository telemetryRepository)
Model\TracesViewModel.cs (2)
12private readonly TelemetryRepository _telemetryRepository; 21public TracesViewModel(TelemetryRepository telemetryRepository)
Otlp\OtlpLogsService.cs (2)
13private readonly TelemetryRepository _telemetryRepository; 15public OtlpLogsService(ILogger<OtlpLogsService> logger, TelemetryRepository telemetryRepository)
Otlp\OtlpMetricsService.cs (2)
13private readonly TelemetryRepository _telemetryRepository; 15public OtlpMetricsService(ILogger<OtlpMetricsService> logger, TelemetryRepository telemetryRepository)
Otlp\OtlpTraceService.cs (2)
13private readonly TelemetryRepository _telemetryRepository; 15public OtlpTraceService(ILogger<OtlpTraceService> logger, TelemetryRepository telemetryRepository)
Otlp\Storage\Subscription.cs (2)
15private readonly TelemetryRepository _telemetryRepository; 30public Subscription(string name, ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, TelemetryRepository telemetryRepository)
Otlp\Storage\TelemetryRepository.cs (1)
67_logger = loggerFactory.CreateLogger(typeof(TelemetryRepository));
Aspire.Dashboard.Components.Tests (21)
Pages\ConsoleLogsTests.cs (1)
542Services.AddSingleton<TelemetryRepository>();
Pages\MetricsTests.cs (6)
86var telemetryRepository = Services.GetRequiredService<TelemetryRepository>(); 129var telemetryRepository = Services.GetRequiredService<TelemetryRepository>(); 227var telemetryRepository = Services.GetRequiredService<TelemetryRepository>();
Pages\StructuredLogsTests.cs (1)
181Services.AddSingleton<TelemetryRepository>();
Pages\TraceDetailsTests.cs (6)
51var telemetryRepository = Services.GetRequiredService<TelemetryRepository>(); 83Assert.Equal(nameof(TelemetryRepository.OnNewTraces), t.Name); 105var telemetryRepository = Services.GetRequiredService<TelemetryRepository>(); 195Services.AddSingleton<TelemetryRepository>();
Shared\MetricsSetupHelpers.cs (2)
43context.Services.AddSingleton<TelemetryRepository>(); 83context.Services.AddSingleton<TelemetryRepository>();
Shared\ResourceSetupHelpers.cs (2)
27context.Services.AddSingleton<TelemetryRepository>(); 97context.Services.AddSingleton<TelemetryRepository>();
Shared\StructuredLogsSetupHelpers.cs (1)
19context.Services.AddSingleton<TelemetryRepository>();
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
222public static TelemetryRepository CreateRepository( 254var repository = new TelemetryRepository(
Aspire.Dashboard.Tests (66)
TelemetryRepositoryTests\ApplicationTests.cs (5)
19var repository = CreateRepository(); 61var repository = CreateRepository(); 99var repository = CreateRepository(); 131var repository = CreateRepository(); 149private static void AddResource(TelemetryRepository repository, string name, string? instanceId = null)
TelemetryRepositoryTests\LogTests.cs (21)
34var repository = CreateRepository(); 97var repository = CreateRepository(); 138var repository = CreateRepository(); 200var repository = CreateRepository(); 275var repository = CreateRepository(); 327var repository = CreateRepository(); 380var repository = CreateRepository(); 417var repository = CreateRepository(); 436var repository = CreateRepository(); 449var repository = CreateRepository(); 533var repository = CreateRepository(); 573var repository = CreateRepository(); 618var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 708var repository = CreateRepository(subscriptionMinExecuteInterval: minExecuteInterval, loggerFactory: loggerFactory); 782var repository = CreateRepository(); 829var repository = CreateRepository(); 928var repository = CreateRepository(); 1017var repository = CreateRepository(); 1082var repository = CreateRepository(); 1156var repository = CreateRepository(); 1222var repository = CreateRepository();
TelemetryRepositoryTests\MetricsTests.cs (12)
26var repository = CreateRepository(); 107var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 221var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 326var repository = CreateRepository(); 434var repository = CreateRepository(maxMetricsCount: 3); 513var repository = CreateRepository(); 632var repository = CreateRepository(); 707var repository = CreateRepository(); 865var repository = CreateRepository(); 1005var repository = CreateRepository(); 1049var repository = CreateRepository(); 1136var repository = CreateRepository();
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (1)
24var repository = CreateRepository(pauseManager: pauseManager);
TelemetryRepositoryTests\TraceTests.cs (25)
34var result = TelemetryRepository.ConvertSpanKind(value); 42var repository = CreateRepository(); 102var repository = CreateRepository(loggerFactory: factory); 155var repository = CreateRepository(); 210var repository = CreateRepository(); 265var repository = CreateRepository(); 343var repository = CreateRepository(); 465var repository = CreateRepository(); 518var repository = CreateRepository(); 595var repository = CreateRepository(); 704var repository = CreateRepository(); 764var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16, maxSpanEventCount: 5); 859var repository = CreateRepository(); 903var repository = CreateRepository(maxTraceCount: MaxTraceCount); 958private static void AddTrace(TelemetryRepository repository, string traceId, DateTime startTime) 1014var repository = CreateRepository(); 1064var repository = CreateRepository(); 1140var repository = CreateRepository(); 1240var repository = CreateRepository(); 1304var repository = CreateRepository(); 1420var repository = CreateRepository(); 1565var repository = CreateRepository(); 1644var repository = CreateRepository(); 1750var repository = CreateRepository(); 1839var repository = CreateRepository();
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
222public static TelemetryRepository CreateRepository( 254var repository = new TelemetryRepository(