| 291 | } |
| 292 | |
| 293 | void writeLogEntry(const LogsDBLogEntry& entry) { |
| 294 | _maybeRotate(); |
| 295 | |
| 296 | auto& partition = _getPartitionForIdx(entry.idx); |
| 297 | _sharedDb.db()->Put({}, partition.cf, U64Key::Static(entry.idx.u64).toSlice(), rocksdb::Slice((const char*)entry.value.data(), entry.value.size())); |
| 298 | _partitionKeyInserted(partition, entry.idx); |
| 299 | |
| 300 | } |
| 301 | |
| 302 | void dropEntriesAfterIdx(LogIdx start) { |
| 303 | auto iterator = getIterator(); |
no test coverage detected