def migration.measured

mylsm-lsm-store@0.6.0.1 · src/transfer/MigrateRunIo.bend:131

import Base
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/transfer/FormatInspect.bend as FormatInspect
import mylsm-lsm-store@0.6.0.1/src/transfer/Migrate.bend as Migrate

131def migration.measured(
132  inspection: FormatInspect.Inspection,
133  destination: String,
134  bundle: String,
135  encoded_bytes: Nat,
136  measured: List<&1, ByteMemTable.Entry> & Nat
137) -> IO(Result<&1, &1, Error, Unit>):
138  match measured:
139    case (entries, count):
140      decision = Migrate.plan(inspection,
141        Migrate.LegacyFilesVerified{count, encoded_bytes}, True{},
142        1000000n, 134217728n)
143      migration.admitted(decision, destination, bundle, entries)