220using var runStore = new DashboardRunStore( 387using var runStore = new DashboardRunStore( 414using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 459using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 827using var pruningRunStore = new DashboardRunStore( 838using var nextPruningRunStore = new DashboardRunStore( 947using var currentRunStore = new DashboardRunStore( 1330return new DashboardRunStore(options, NullLogger<DashboardRunStore>.Instance, timeProvider ?? TimeProvider.System);

325builder.Services.AddSingleton<DashboardRunStore>(); 326builder.Services.AddSingleton<IDashboardRunStore>(services => services.GetRequiredService<DashboardRunStore>());

14var isDashboardSqlite = string.Equals(attributes.GetValue(OtlpSpan.PeerServiceAttributeKey), DashboardRunStore.DatabaseFileName, StringComparison.Ordinal) && 16string.Equals(attributes.GetValue("db.namespace"), DashboardRunStore.DatabaseFileName, StringComparison.Ordinal); 18name = isDashboardSqlite ? DashboardRunStore.DatabaseFileName : null;

85private readonly ILogger<DashboardRunStore> _logger; 92public DashboardRunStore(IOptions<DashboardOptions> options, ILogger<DashboardRunStore> logger, TimeProvider timeProvider) 99ILogger<DashboardRunStore> logger, 614private sealed class RunLease(DashboardRunStore owner, DashboardRunDescriptor run, FileLock runLock) : IDisposable

277SchemaVersion: DashboardRunStore.SchemaVersion, 288SchemaVersion: DashboardRunStore.SchemaVersion, 323SchemaVersion: DashboardRunStore.SchemaVersion, 357SchemaVersion: DashboardRunStore.SchemaVersion, 368SchemaVersion: DashboardRunStore.SchemaVersion, 535SchemaVersion: DashboardRunStore.SchemaVersion, 544SchemaVersion: DashboardRunStore.SchemaVersion, 597SchemaVersion: DashboardRunStore.SchemaVersion, 606SchemaVersion: DashboardRunStore.SchemaVersion, 650SchemaVersion: DashboardRunStore.SchemaVersion, 659new DashboardRunDescriptor("unpinned-b", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 12, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 660new DashboardRunDescriptor("pinned-b", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 11, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 661new DashboardRunDescriptor("unpinned-a", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 9, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 662new DashboardRunDescriptor("pinned-a", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 10, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false) 713SchemaVersion: DashboardRunStore.SchemaVersion, 757SchemaVersion: DashboardRunStore.SchemaVersion, 768SchemaVersion: DashboardRunStore.SchemaVersion, 811SchemaVersion: DashboardRunStore.SchemaVersion, 820SchemaVersion: DashboardRunStore.SchemaVersion, 870SchemaVersion: DashboardRunStore.SchemaVersion, 881SchemaVersion: DashboardRunStore.SchemaVersion,

268SchemaVersion: DashboardRunStore.SchemaVersion,

1072var runsDirectory = DashboardRunStore.GetRunsDirectory(workspace.Path);

35using var runStore = CreateRunStore(options); 37var applicationDirectoryName = DashboardRunStore.GetApplicationDirectoryName("My Dashboard"); 50using var runStore = CreateRunStore(options); 52var applicationDirectoryName = DashboardRunStore.GetApplicationDirectoryName("My Dashboard"); 61var applicationDirectoryName = DashboardRunStore.GetApplicationDirectoryName("My Dashboard"); 68Assert.Equal(expectedDirectory, DashboardRunStore.GetApplicationDirectory(dataRoot: null, "My Dashboard")); 83? [DashboardRunStore.GetRunsDirectory(workspace.Path)] 86DashboardRunStore.GetResumesDirectory(workspace.Path), 87DashboardRunStore.GetApplicationDirectory(workspace.Path, "My Dashboard") 99using var runStore = CreateRunStore(CreateOptions(workspace, "My Dashboard", persistenceMode)); 115using var runStore = CreateRunStore(CreateOptions(workspace), timeProvider); 127using var firstRunStore = CreateRunStore(options, timeProvider); 139using var runStore = CreateRunStore(options); 158Assert.Equal(DashboardRunStore.SchemaVersion, metadata.RootElement.GetProperty("SchemaVersion").GetInt32()); 159Assert.Equal(DashboardRunStore.SchemaVersion, Assert.Single(runStore.GetRuns()).SchemaVersion); 170using (var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt))) 184using var nextRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMinutes(1))); 195using var runStore = CreateRunStore(options); 220using var runStore = new DashboardRunStore( 222loggerFactory.CreateLogger<DashboardRunStore>(), 253using (var runStore = CreateRunStore(options)) 281.AddSingleton<ILogger<DashboardRunStore>>(NullLogger<DashboardRunStore>.Instance) 285.AddSingleton<DashboardRunStore>() 286.AddSingleton<IDashboardRunStore>(serviceProvider => serviceProvider.GetRequiredService<DashboardRunStore>()) 295var runStore = serviceProvider.GetRequiredService<DashboardRunStore>(); 330using var runStore = CreateRunStore(CreateOptions(workspace, persistenceMode: DashboardPersistenceMode.None)); 348using var activeRunStore = CreateRunStore(options); 352using var secondRunStore = CreateRunStore(options); 367using var runStore = CreateRunStore(CreateOptions(workspace, persistenceMode: DashboardPersistenceMode.None)); 385var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 387using var runStore = new DashboardRunStore( 405using (var firstRunStore = CreateRunStore(options)) 413var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 414using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 431using var firstRunStore = CreateRunStore(options); 447using (var firstRunStore = CreateRunStore(options)) 458var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 459using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 465write => write.Message == $"Existing dashboard database at '{databasePath}' is incompatible with schema version {DashboardRunStore.SchemaVersion} and will be replaced."); 479using (var firstRunStore = CreateRunStore(options)) 522var firstDirectoryName = DashboardRunStore.GetApplicationDirectoryName(firstName); 523var secondDirectoryName = DashboardRunStore.GetApplicationDirectoryName(secondName); 525Assert.Equal(DashboardRunStore.MaxApplicationDirectoryNameLength, firstDirectoryName.Length); 526Assert.Equal(DashboardRunStore.MaxApplicationDirectoryNameLength, secondDirectoryName.Length); 530Assert.Equal(firstDirectoryName, DashboardRunStore.GetApplicationDirectoryName(firstName)); 540using (var historicalRunStore = CreateRunStore(options)) 547using var currentRunStore = CreateRunStore(options); 572using (var otherApplicationRunStore = CreateRunStore( 580using (var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(1)))) 585using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(2))); 597using var runStore = CreateRunStore(CreateOptions(workspace)); 609using var runStore = CreateRunStore(CreateOptions(workspace)); 625using (var historicalRunStore = CreateRunStore(options)) 632using var activeRunStore = CreateRunStore(options); 635using var currentRunStore = CreateRunStore(options); 661foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns)) 663using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 668using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt)); 672Assert.Equal(DashboardRunStore.MaxRuns, Directory.GetDirectories(runsDirectory).Length); 686foreach (var index in Enumerable.Range(0, DashboardRunStore.MaxRuns - activeRunCount)) 688using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(index))); 692var activeRunStores = new List<DashboardRunStore>(); 693foreach (var index in Enumerable.Range(DashboardRunStore.MaxRuns - activeRunCount, activeRunCount)) 695var activeRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(index))); 702using var currentRunStore = CreateRunStore( 704new FixedTimeProvider(startedAt.AddMilliseconds(DashboardRunStore.MaxRuns))); 709foreach (var activeRunStore in activeRunStores) 718Assert.Equal(DashboardRunStore.MaxRuns - activeRunCount, selectableRuns.Count); 735using (var runStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++)))) 741using var pinningRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++))); 752for (var index = 0; index < DashboardRunStore.MaxRuns - 1; index++) 754using var runStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++))); 758using var finalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex))); 766Assert.Equal(DashboardRunStore.MaxRuns - 1, runs.Count(run => !run.IsCurrent && !run.IsPinned)); 778foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns - 1)) 780using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 784using var activeRunStore = CreateRunStore( 786new FixedTimeProvider(startedAt.AddDays(-DashboardRunStore.MaxRuns))); 789using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt)); 794Assert.Equal(DashboardRunStore.MaxRuns + 1, Directory.GetDirectories(runsDirectory).Length); 806using (var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt))) 814using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(1))); 820foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns - 2)) 822using var additionalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(index))); 827using var pruningRunStore = new DashboardRunStore( 829NullLogger<DashboardRunStore>.Instance, 838using var nextPruningRunStore = new DashboardRunStore( 840NullLogger<DashboardRunStore>.Instance, 855using (var historicalRunStore = CreateRunStore(options)) 862using var currentRunStore = CreateRunStore(options); 905using (var historicalRunStore = CreateRunStore(options)) 912using var currentRunStore = CreateRunStore(options); 935foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns)) 937using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 944var logger = loggerFactory.CreateLogger<DashboardRunStore>(); 947using var currentRunStore = new DashboardRunStore( 956Assert.Equal(typeof(DashboardRunStore).FullName, warning.LoggerName); 971using (var malformedRunStore = CreateRunStore(options)) 983using var currentRunStore = CreateRunStore(options); 1015using var currentRunStore = CreateRunStore(options); 1018var historicalDatabasePath = Path.Combine(historicalDirectory, DashboardRunStore.DatabaseFileName); 1024var malformedDatabasePath = Path.Combine(malformedDirectory, DashboardRunStore.DatabaseFileName); 1050DatabasePath = Path.Combine(workspace.Path, "unavailable", DashboardRunStore.DatabaseFileName), 1117using (var historicalRunStore = CreateRunStore(options)) 1147using var currentRunStore = CreateRunStore(options); 1225using var currentRunStore = CreateRunStore(options); 1248using (var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(historicalRunTime))) 1253using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(historicalRunTime.AddMilliseconds(1))); 1302private static async Task InitializeAndPublishRunAsync(DashboardRunStore runStore) 1311private static async Task InitializeAndPublishRunWithoutPruningAsync(DashboardRunStore runStore) 1328private static DashboardRunStore CreateRunStore(IOptions<DashboardOptions> options, TimeProvider? timeProvider = null) 1330return new DashboardRunStore(options, NullLogger<DashboardRunStore>.Instance, timeProvider ?? TimeProvider.System); 1351DashboardRunStore.GetRunLockPath(runDirectory),

47[new("current", DashboardRunStore.SchemaVersion, DateTimeOffset.UnixEpoch, null, false, "TestApp", databasePath ?? string.Empty, IsCurrent: true)])