def migration.admitted

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

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

118def migration.admitted(
119  decision: Migrate.Decision,
120  destination: String,
121  bundle: String,
122  entries: List<&1, ByteMemTable.Entry>
123) -> IO(Result<&1, &1, Error, Unit>):
124  match decision:
125    case Migrate.MigrateRejected{reason}:
126      IO.pure(Result<&1, &1, Error, Unit>, Fail{Rejected{reason}})
127    case Migrate.MigrateReady{_, _}:
128      migration.publication.started(Migrate.begin(decision), destination,
129        bundle, entries)