1 write to _database
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
64_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)
35public bool IsReadOnly => _database.IsReadOnly; 45internal ActivitySource SqlActivitySource => _database.ActivitySource; 103using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 143using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 274_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(); 275using var connection = _database.OpenConnection(); 404using var connection = _database.OpenConnection(); 439using var connection = _database.OpenConnection(); 470using var connection = _database.OpenConnection(); 566using var connection = _database.OpenConnection(); 723using var connection = _database.OpenConnection(); 749using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 751using 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(); 394using var connection = _database.OpenConnection(); 554using var connection = _database.OpenConnection(); 563using var connection = _database.OpenConnection(); 595using var connection = _database.OpenConnection(); 661using var connection = _database.OpenConnection(); 672using 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();