2 instantiations of TelemetryRepository
Aspire.Dashboard.Components.Tests (1)
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
239var repository = new TelemetryRepository(NullLoggerFactory.Instance, Options.Create(new DashboardOptions { TelemetryLimits = options }));
Aspire.Dashboard.Tests (1)
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
239var repository = new TelemetryRepository(NullLoggerFactory.Instance, Options.Create(new DashboardOptions { TelemetryLimits = options }));
91 references to TelemetryRepository
Aspire.Dashboard (41)
Components\Dialogs\FilterDialog.razor.cs (1)
27public required TelemetryRepository TelemetryRepository { get; init; }
Components\Pages\Resources.razor.cs (4)
40public required TelemetryRepository TelemetryRepository { get; init; } 164_applicationUnviewedErrorCounts = TelemetryRepository.GetApplicationUnviewedErrorLogsCount(); 171_logsSubscription = TelemetryRepository.OnNewLogs(null, SubscriptionType.Other, async () => 173var newApplicationUnviewedErrorCounts = TelemetryRepository.GetApplicationUnviewedErrorLogsCount();
Components\Pages\StructuredLogs.razor.cs (8)
51public required TelemetryRepository TelemetryRepository { get; init; } 111if (DashboardOptions.Value.TelemetryLimits.MaxLogCount == logs.TotalItemCount && !TelemetryRepository.HasDisplayedMaxLogLimitMessage) 121TelemetryRepository.HasDisplayedMaxLogLimitMessage = true; 128TelemetryRepository.MarkViewedErrorLogs(ViewModel.ApplicationKey); 183_applicationsSubscription = TelemetryRepository.OnNewApplications(() => InvokeAsync(() => 200_applications = TelemetryRepository.GetApplications(); 226_logsSubscription = TelemetryRepository.OnNewLogs(PageViewModel.SelectedApplication.Id?.GetApplicationKey(), SubscriptionType.Read, async () => 272var logPropertyKeys = TelemetryRepository.GetLogPropertyKeys(PageViewModel.SelectedApplication.Id?.GetApplicationKey());
Components\Pages\TraceDetail.razor.cs (5)
41public required TelemetryRepository TelemetryRepository { get; init; } 230_applications = TelemetryRepository.GetApplications(); 236_trace = TelemetryRepository.GetTrace(TraceId); 245_tracesSubscription = TelemetryRepository.OnNewTraces(trace.FirstSpan.Source.ApplicationKey, SubscriptionType.Read, () => InvokeAsync(() => 322trace = TelemetryRepository.GetTrace(traceId);
Components\Pages\Traces.razor.cs (6)
51public required TelemetryRepository TelemetryRepository { get; init; } 112if (DashboardOptions.Value.TelemetryLimits.MaxTraceCount == traces.TotalItemCount && !TelemetryRepository.HasDisplayedMaxTraceLimitMessage) 122TelemetryRepository.HasDisplayedMaxTraceLimitMessage = true; 146_applicationsSubscription = TelemetryRepository.OnNewApplications(callback: () => InvokeAsync(workItem: () => 165_applications = TelemetryRepository.GetApplications(); 185_tracesSubscription = TelemetryRepository.OnNewTraces(selectedApplicationKey, SubscriptionType.Read, async () =>
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (3)
23public required TelemetryRepository TelemetryRepository { get; init; } 39var application = TelemetryRepository.GetApplicationByCompositeName(resource.Name); 50var applications = TelemetryRepository.GetApplications();
DashboardWebApplication.cs (1)
201builder.Services.AddSingleton<TelemetryRepository>();
Model\StructuredLogsViewModel.cs (2)
12private readonly TelemetryRepository _telemetryRepository; 22public StructuredLogsViewModel(TelemetryRepository telemetryRepository)
Model\TracesViewModel.cs (2)
11private readonly TelemetryRepository _telemetryRepository; 19public 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)
10private readonly TelemetryRepository _telemetryRepository; 23public Subscription(string name, ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, TelemetryRepository telemetryRepository)
Otlp\Storage\TelemetryRepository.cs (1)
55_logger = loggerFactory.CreateLogger(typeof(TelemetryRepository));
Aspire.Dashboard.Components.Tests (7)
Pages\MetricsTests.cs (2)
52var telemetryRepository = Services.GetRequiredService<TelemetryRepository>();
Pages\StructuredLogsTests.cs (1)
92Services.AddSingleton<TelemetryRepository>();
Shared\MetricsSetupHelpers.cs (2)
46context.Services.AddSingleton<TelemetryRepository>(); 75context.Services.AddSingleton<TelemetryRepository>();
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
209public static TelemetryRepository CreateRepository( 239var repository = new TelemetryRepository(NullLoggerFactory.Instance, Options.Create(new DashboardOptions { TelemetryLimits = options }));
Aspire.Dashboard.Tests (43)
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 (16)
24var repository = CreateRepository(); 87var repository = CreateRepository(); 149var repository = CreateRepository(); 224var repository = CreateRepository(); 276var repository = CreateRepository(); 329var repository = CreateRepository(); 366var repository = CreateRepository(); 385var repository = CreateRepository(); 398var repository = CreateRepository(); 482var repository = CreateRepository(); 522var repository = CreateRepository(); 567var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 655var repository = CreateRepository(subscriptionMinExecuteInterval: minExecuteInterval); 717var repository = CreateRepository(); 764var repository = CreateRepository(); 863var repository = CreateRepository();
TelemetryRepositoryTests\MetricsTests.cs (6)
26var repository = CreateRepository(); 99var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 213var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16); 318var repository = CreateRepository(); 425var repository = CreateRepository(maxMetricsCount: 3); 504var repository = CreateRepository();
TelemetryRepositoryTests\TraceTests.cs (14)
31var result = TelemetryRepository.ConvertSpanKind(value); 39var repository = CreateRepository(); 95var repository = CreateRepository(); 172var repository = CreateRepository(); 292var repository = CreateRepository(); 344var repository = CreateRepository(); 420var repository = CreateRepository(); 528var repository = CreateRepository(); 586var repository = CreateRepository(maxAttributeCount: 5, maxAttributeLength: 16, maxSpanEventCount: 5); 680var repository = CreateRepository(); 723var repository = CreateRepository(maxTraceCount: MaxTraceCount); 777private static void AddTrace(TelemetryRepository repository, string traceId, DateTime startTime) 833var repository = CreateRepository(); 882var repository = CreateRepository();
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
209public static TelemetryRepository CreateRepository( 239var repository = new TelemetryRepository(NullLoggerFactory.Instance, Options.Create(new DashboardOptions { TelemetryLimits = options }));