def migration.publication.started

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

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/Migrate.bend as Migrate

105def migration.publication.started(
106  result: Migrate.PublicationDecision,
107  destination: String,
108  bundle: String,
109  entries: List<&1, ByteMemTable.Entry>
110) -> IO(Result<&1, &1, Error, Unit>):
111  match result:
112    case Migrate.PublicationAdvanced{Migrate.SourceValidated{}}:
113      migration.publication.export(destination, path.clone.pair(bundle),
114        entries)
115    case _:
116      IO.pure(Result<&1, &1, Error, Unit>, Fail{PublicationStateInvalid{}})