191using var runStore = new DashboardRunStore( 358using var runStore = new DashboardRunStore( 385using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 430using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 771using var pruningRunStore = new DashboardRunStore( 782using var nextPruningRunStore = new DashboardRunStore( 891using var currentRunStore = new DashboardRunStore( 1274return new DashboardRunStore(options, NullLogger<DashboardRunStore>.Instance, timeProvider ?? TimeProvider.System);

320builder.Services.AddSingleton<DashboardRunStore>(); 321builder.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;

84private readonly ILogger<DashboardRunStore> _logger; 91public DashboardRunStore(IOptions<DashboardOptions> options, ILogger<DashboardRunStore> logger, TimeProvider timeProvider) 98ILogger<DashboardRunStore> logger, 587private sealed class RunLease(DashboardRunStore owner, DashboardRunDescriptor run, FileLock runLock) : IDisposable

315SchemaVersion: DashboardRunStore.SchemaVersion, 326SchemaVersion: DashboardRunStore.SchemaVersion, 361SchemaVersion: DashboardRunStore.SchemaVersion, 395SchemaVersion: DashboardRunStore.SchemaVersion, 406SchemaVersion: DashboardRunStore.SchemaVersion, 573SchemaVersion: DashboardRunStore.SchemaVersion, 582SchemaVersion: DashboardRunStore.SchemaVersion, 634SchemaVersion: DashboardRunStore.SchemaVersion, 643SchemaVersion: DashboardRunStore.SchemaVersion, 688SchemaVersion: DashboardRunStore.SchemaVersion, 697new DashboardRunDescriptor("unpinned-b", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 12, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 698new DashboardRunDescriptor("pinned-b", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 11, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 699new DashboardRunDescriptor("unpinned-a", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 9, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false), 700new DashboardRunDescriptor("pinned-a", DashboardRunStore.SchemaVersion, new(2025, 1, 2, 10, 0, 0, TimeSpan.Zero), null, true, "TestApp", string.Empty, IsCurrent: false) 752SchemaVersion: DashboardRunStore.SchemaVersion, 796SchemaVersion: DashboardRunStore.SchemaVersion, 807SchemaVersion: DashboardRunStore.SchemaVersion, 850SchemaVersion: DashboardRunStore.SchemaVersion, 859SchemaVersion: DashboardRunStore.SchemaVersion, 909SchemaVersion: DashboardRunStore.SchemaVersion, 920SchemaVersion: DashboardRunStore.SchemaVersion,

259SchemaVersion: DashboardRunStore.SchemaVersion,

1073DashboardRunStore.GetApplicationDirectory(workspace.Path, applicationName),

35using var runStore = CreateRunStore(options); 37var applicationDirectoryName = DashboardRunStore.GetApplicationDirectoryName("My Dashboard"); 45var applicationDirectoryName = DashboardRunStore.GetApplicationDirectoryName("My Dashboard"); 51Assert.Equal(expectedDirectory, DashboardRunStore.GetApplicationDirectory(dataRoot: null, "My Dashboard")); 65var applicationDirectory = DashboardRunStore.GetApplicationDirectory(workspace.Path, "My Dashboard"); 73using var runStore = CreateRunStore(CreateOptions(workspace, "My Dashboard", persistenceMode)); 86using var runStore = CreateRunStore(CreateOptions(workspace), timeProvider); 98using var firstRunStore = CreateRunStore(options, timeProvider); 110using var runStore = CreateRunStore(options); 129Assert.Equal(DashboardRunStore.SchemaVersion, metadata.RootElement.GetProperty("SchemaVersion").GetInt32()); 130Assert.Equal(DashboardRunStore.SchemaVersion, Assert.Single(runStore.GetRuns()).SchemaVersion); 141using (var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt))) 155using var nextRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMinutes(1))); 166using var runStore = CreateRunStore(options); 191using var runStore = new DashboardRunStore( 193loggerFactory.CreateLogger<DashboardRunStore>(), 224using (var runStore = CreateRunStore(options)) 252.AddSingleton<ILogger<DashboardRunStore>>(NullLogger<DashboardRunStore>.Instance) 256.AddSingleton<DashboardRunStore>() 257.AddSingleton<IDashboardRunStore>(serviceProvider => serviceProvider.GetRequiredService<DashboardRunStore>()) 266var runStore = serviceProvider.GetRequiredService<DashboardRunStore>(); 301using var runStore = CreateRunStore(CreateOptions(workspace, persistenceMode: DashboardPersistenceMode.None)); 319using var activeRunStore = CreateRunStore(options); 323using var secondRunStore = CreateRunStore(options); 338using var runStore = CreateRunStore(CreateOptions(workspace, persistenceMode: DashboardPersistenceMode.None)); 356var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 358using var runStore = new DashboardRunStore( 376using (var firstRunStore = CreateRunStore(options)) 384var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 385using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 402using var firstRunStore = CreateRunStore(options); 418using (var firstRunStore = CreateRunStore(options)) 429var logger = new TestLogger<DashboardRunStore>(new TestLoggerFactory(testSink, enabled: true)); 430using var secondRunStore = new DashboardRunStore(options, logger, TimeProvider.System); 436write => write.Message == $"Existing dashboard database at '{databasePath}' is incompatible with schema version {DashboardRunStore.SchemaVersion} and will be replaced."); 450using (var firstRunStore = CreateRunStore(options)) 493var firstDirectoryName = DashboardRunStore.GetApplicationDirectoryName(firstName); 494var secondDirectoryName = DashboardRunStore.GetApplicationDirectoryName(secondName); 496Assert.Equal(DashboardRunStore.MaxApplicationDirectoryNameLength, firstDirectoryName.Length); 497Assert.Equal(DashboardRunStore.MaxApplicationDirectoryNameLength, secondDirectoryName.Length); 501Assert.Equal(firstDirectoryName, DashboardRunStore.GetApplicationDirectoryName(firstName)); 511using (var historicalRunStore = CreateRunStore(options)) 518using var currentRunStore = CreateRunStore(options); 541using var runStore = CreateRunStore(CreateOptions(workspace)); 553using var runStore = CreateRunStore(CreateOptions(workspace)); 569using (var historicalRunStore = CreateRunStore(options)) 576using var activeRunStore = CreateRunStore(options); 579using var currentRunStore = CreateRunStore(options); 605foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns)) 607using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 612using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt)); 616Assert.Equal(DashboardRunStore.MaxRuns, Directory.GetDirectories(runsDirectory).Length); 630foreach (var index in Enumerable.Range(0, DashboardRunStore.MaxRuns - activeRunCount)) 632using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(index))); 636var activeRunStores = new List<DashboardRunStore>(); 637foreach (var index in Enumerable.Range(DashboardRunStore.MaxRuns - activeRunCount, activeRunCount)) 639var activeRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(index))); 646using var currentRunStore = CreateRunStore( 648new FixedTimeProvider(startedAt.AddMilliseconds(DashboardRunStore.MaxRuns))); 653foreach (var activeRunStore in activeRunStores) 662Assert.Equal(DashboardRunStore.MaxRuns - activeRunCount, selectableRuns.Count); 679using (var runStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++)))) 685using var pinningRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++))); 696for (var index = 0; index < DashboardRunStore.MaxRuns - 1; index++) 698using var runStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex++))); 702using var finalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(runIndex))); 710Assert.Equal(DashboardRunStore.MaxRuns - 1, runs.Count(run => !run.IsCurrent && !run.IsPinned)); 722foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns - 1)) 724using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 728using var activeRunStore = CreateRunStore( 730new FixedTimeProvider(startedAt.AddDays(-DashboardRunStore.MaxRuns))); 733using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt)); 738Assert.Equal(DashboardRunStore.MaxRuns + 1, Directory.GetDirectories(runsDirectory).Length); 750using (var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt))) 758using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddMilliseconds(1))); 764foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns - 2)) 766using var additionalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(index))); 771using var pruningRunStore = new DashboardRunStore( 773NullLogger<DashboardRunStore>.Instance, 782using var nextPruningRunStore = new DashboardRunStore( 784NullLogger<DashboardRunStore>.Instance, 799using (var historicalRunStore = CreateRunStore(options)) 806using var currentRunStore = CreateRunStore(options); 849using (var historicalRunStore = CreateRunStore(options)) 856using var currentRunStore = CreateRunStore(options); 879foreach (var index in Enumerable.Range(1, DashboardRunStore.MaxRuns)) 881using var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(startedAt.AddDays(-index))); 888var logger = loggerFactory.CreateLogger<DashboardRunStore>(); 891using var currentRunStore = new DashboardRunStore( 900Assert.Equal(typeof(DashboardRunStore).FullName, warning.LoggerName); 915using (var malformedRunStore = CreateRunStore(options)) 927using var currentRunStore = CreateRunStore(options); 959using var currentRunStore = CreateRunStore(options); 962var historicalDatabasePath = Path.Combine(historicalDirectory, DashboardRunStore.DatabaseFileName); 968var malformedDatabasePath = Path.Combine(malformedDirectory, DashboardRunStore.DatabaseFileName); 994DatabasePath = Path.Combine(workspace.Path, "unavailable", DashboardRunStore.DatabaseFileName), 1061using (var historicalRunStore = CreateRunStore(options)) 1091using var currentRunStore = CreateRunStore(options); 1169using var currentRunStore = CreateRunStore(options); 1192using (var historicalRunStore = CreateRunStore(options, new FixedTimeProvider(historicalRunTime))) 1197using var currentRunStore = CreateRunStore(options, new FixedTimeProvider(historicalRunTime.AddMilliseconds(1))); 1246private static async Task InitializeAndPublishRunAsync(DashboardRunStore runStore) 1255private static async Task InitializeAndPublishRunWithoutPruningAsync(DashboardRunStore runStore) 1272private static DashboardRunStore CreateRunStore(IOptions<DashboardOptions> options, TimeProvider? timeProvider = null) 1274return new DashboardRunStore(options, NullLogger<DashboardRunStore>.Instance, timeProvider ?? TimeProvider.System); 1295DashboardRunStore.GetRunLockPath(runDirectory),

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