2 writes to ResourceRepository
Aspire.Dashboard (2)
ServiceClient\DashboardDataSource.cs (2)
123ResourceRepository = historicalDataSourceLease.ResourceRepository; 154ResourceRepository = currentDataSource.ResourceRepository;
30 references to ResourceRepository
Aspire.Dashboard (18)
Components\Controls\PropertyValues\ResourceNameButtonValue.razor.cs (1)
45_resource = DataSource.ResourceRepository.GetResource(Resource.ResourceKey.ToString());
Components\Controls\TerminalDisconnectedBanner.razor.cs (1)
132var (snapshot, updates) = await DataSource.ResourceRepository.SubscribeResourcesAsync(cancellationToken);
Components\Dialogs\ManageDataDialog.razor.cs (2)
154var (snapshot, subscription) = await DataSource.ResourceRepository.SubscribeResourcesAsync(_cts.Token); 566await DataSource.ResourceRepository.ClearConsoleLogsAsync(consoleLogResourceNames, filterDate);
Components\Pages\ConsoleLogs.razor.cs (3)
243var (snapshot, subscription) = await DataSource.ResourceRepository.SubscribeResourcesAsync(_resourceSubscriptionToken); 975? DataSource.ResourceRepository.GetResources().Select(resource => resource.Name).ToList() 978await DataSource.ResourceRepository.ClearConsoleLogsAsync(resourceNames, now);
Components\Pages\Resources.razor.cs (1)
261var (snapshot, subscription) = await DataSource.ResourceRepository.SubscribeResourcesAsync(_cts.Token);
Components\Pages\Terminals.razor.cs (1)
98var (snapshot, updates) = await DataSource.ResourceRepository.SubscribeResourcesAsync(cancellationToken);
Model\ConsoleLogsFetcher.cs (2)
40await foreach (var batch in _dataSource.ResourceRepository.GetConsoleLogs(resourceName, cancellationToken).ConfigureAwait(false)) 69var resources = _dataSource.ResourceRepository.GetResources().Where(r => resourceNames.Contains(r.Name)).ToList();
Model\TelemetryExportService.cs (1)
63var snapshot = _dataSource.ResourceRepository.GetResources();
ServiceClient\SelectedDashboardClient.cs (6)
39public Task<ResourceViewModelSubscription> SubscribeResourcesAsync(CancellationToken cancellationToken) => dataSource.ResourceRepository.SubscribeResourcesAsync(cancellationToken); 40public ResourceViewModel? GetResource(string resourceName) => dataSource.ResourceRepository.GetResource(resourceName); 41public IReadOnlyList<ResourceViewModel> GetResources() => dataSource.ResourceRepository.GetResources(); 44? dataSource.ResourceRepository.SubscribeConsoleLogs(resourceName, cancellationToken) 48? dataSource.ResourceRepository.GetConsoleLogs(resourceName, cancellationToken) 54return dataSource.ResourceRepository.ClearConsoleLogsAsync(resourceNames, clearDate);
Aspire.Dashboard.Tests (12)
Model\DashboardDataSourceTests.cs (12)
219(IResourceRepositoryWriter)dataSource.ResourceRepository); 1355var historicalResourceRepository = dataSource.ResourceRepository; 1361Assert.Same(historicalResourceRepository, dataSource.ResourceRepository); 1368Assert.Same(historicalResourceRepository, dataSource.ResourceRepository); 1447var currentResourceRepository = dataSource.ResourceRepository; 1460Assert.Equal("api", Assert.Single(dataSource.ResourceRepository.GetResources()).Name); 1524var currentResourceRepository = dataSource.ResourceRepository; 1530Assert.Same(currentResourceRepository, dataSource.ResourceRepository); 1560var currentResourceRepository = dataSource.ResourceRepository; 1567Assert.Same(currentResourceRepository, dataSource.ResourceRepository); 1593var currentResourceRepository = dataSource.ResourceRepository; 1600Assert.Same(currentResourceRepository, dataSource.ResourceRepository);