def migration.snapshot

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

import Base
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
import mylsm-lsm-store@0.6.0.1/src/transfer/MigrateIo.bend as MigrateIo

159def migration.snapshot(
160  inspection: FormatInspect.Inspection,
161  destination: String,
162  bundle: String,
163  result: Result<&1, &1, MigrateIo.Error, MigrateIo.SourceSnapshot>
164) -> IO(Result<&1, &1, Error, Unit>):
165  match result:
166    case Fail{error}:
167      IO.pure(Result<&1, &1, Error, Unit>, Fail{Source{error}})
168    case Done{MigrateIo.LegacySourceSnapshot{sst_records, wal_batches,
169        _, _, encoded_bytes}}:
170      migration.converted(inspection, destination, bundle, encoded_bytes,
171        Migrate.legacy.snapshot.entries(sst_records, wal_batches))