def wal.locked.classified

mylsm-lsm-store@0.6.0.1 · src/transfer/MigrateIo.bend:704

import Base
import mylsm-lsm-store@0.6.0.1/src/DbLock.bend as DbLock
import mylsm-lsm-store@0.6.0.1/src/MemTable.bend as MemTable
import mylsm-lsm-store@0.6.0.1/src/transfer/LegacyWal.bend as LegacyWal

704def wal.locked.classified(
705  result: LegacyWal.ReplayResult,
706  lock: DbLock.Lock,
707  path: String,
708  size: Nat,
709  records: List<&2, MemTable.Entry>
710) -> TableValidation:
711  match result:
712    case LegacyWal.ReplayInvalid{}:
713      table.validation.records(lock, path, Fail{InvalidLegacyWal{}}, records)
714    case LegacyWal.ReplayValid{batches}:
715      wal.locked.valid.batches(wal.batches.measure(batches), lock, path,
716        size, records)