1 write to _database
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
65_database = database;
43 references to _database
Aspire.Dashboard (43)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (2)
475using (_database.WriteLock.Lock()) 484using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.cs (5)
36public bool IsReadOnly => _database.IsReadOnly; 46internal ActivitySource SqlActivitySource => _database.ActivitySource; 104using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 144using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 275_database.EnsureWritable("Historical dashboard telemetry is read-only.");
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (11)
27using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 29using var connection = _database.OpenConnection(); 198using var connection = _database.OpenConnection(); 278using var connection = _database.OpenConnection(); 407using var connection = _database.OpenConnection(); 442using var connection = _database.OpenConnection(); 473using var connection = _database.OpenConnection(); 569using var connection = _database.OpenConnection(); 726using var connection = _database.OpenConnection(); 752using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 754using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (2)
118using var connection = _database.OpenConnection(); 144using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (5)
31using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 38using var connection = _database.OpenConnection(); 757using var connection = _database.OpenConnection(); 770using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 772using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (2)
31using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 33using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (8)
19using var connection = _database.OpenConnection(); 59using var connection = _database.OpenConnection(); 391using var connection = _database.OpenConnection(); 551using var connection = _database.OpenConnection(); 560using var connection = _database.OpenConnection(); 592using var connection = _database.OpenConnection(); 656using var connection = _database.OpenConnection(); 667using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (8)
28using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 30using var connection = _database.OpenConnection(); 995using var connection = _database.OpenConnection(); 1014using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 1016using var writeConnection = _database.OpenConnection(); 1018using var readConnection = _database.OpenConnection(); 1213using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 1215using var connection = _database.OpenConnection();