1 write to _database
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
90_database = database;
45 references to _database
Aspire.Dashboard (45)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (2)
475using (_database.WriteLock.Lock()) 484using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.cs (7)
37public bool IsReadOnly => _database.IsReadOnly; 47using (_database.WriteLock.Lock()) 49using var connection = _database.OpenConnection(); 71internal ActivitySource SqlActivitySource => _database.ActivitySource; 134using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 180using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 311_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(); 445using var connection = _database.OpenConnection(); 476using var connection = _database.OpenConnection(); 572using var connection = _database.OpenConnection(); 729using var connection = _database.OpenConnection(); 755using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 757using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (2)
140using var connection = _database.OpenConnection(); 170using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (5)
33using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 40using var connection = _database.OpenConnection(); 874using var connection = _database.OpenConnection(); 887using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 889using 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)
18using var connection = _database.OpenConnection(); 61using var connection = _database.OpenConnection(); 396using var connection = _database.OpenConnection(); 559using var connection = _database.OpenConnection(); 568using var connection = _database.OpenConnection(); 600using var connection = _database.OpenConnection(); 666using var connection = _database.OpenConnection(); 677using 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();