1 write to _database
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
90_database = database;
47 references to _database
Aspire.Dashboard (47)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (2)
478using (_database.WriteLock.Lock()) 487using 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)) 313_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)
208using var connection = _database.OpenConnection(); 238using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (5)
33using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 40using var connection = _database.OpenConnection(); 878using var connection = _database.OpenConnection(); 891using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 893using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (3)
40using var connection = _database.OpenConnection(); 61using (await _database.WriteLock.LockAsync().ConfigureAwait(false)) 63using var connection = _database.OpenConnection();
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (9)
18using var connection = _database.OpenConnection(); 61using var connection = _database.OpenConnection(); 401using var connection = _database.OpenConnection(); 431using var connection = _database.OpenConnection(); 647using var connection = _database.OpenConnection(); 656using var connection = _database.OpenConnection(); 688using var connection = _database.OpenConnection(); 754using var connection = _database.OpenConnection(); 765using 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();