def wal.locked.read.classify

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

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
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

718def wal.locked.read.classify(
719  result: Result<&1, &1, U32 & String, Bytes.Bytes>,
720  lock: DbLock.Lock,
721  path: String,
722  size: Nat,
723  records: List<&2, MemTable.Entry>
724) -> TableValidation:
725  match result:
726    case Fail{(code, message)}:
727      table.validation.records(lock, path, Fail{HostError{code, message}}, records)
728    case Done{bytes}:
729      wal.locked.classified(LegacyWal.replay(bytes), lock, path, size, records)