def Bytes.backup_to.remote.snapshot.cloned

mylsm-lsm-store@0.6.0.1 · mylsm.bend:1282

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as OwnerClient
import mylsm-lsm-store@0.6.0.1/src/coordinator/ByteClient.bend as OwnerByteClient

1282def Bytes.backup_to.remote.snapshot.cloned(
1283  path: String,
1284  sessions: OwnerClient.Session & OwnerClient.Session,
1285  snapshot_ids: U32 & U32 & U32
1286) -> IO(Bytes.Handle & Result<&1, &1, Bytes.Error, Unit>):
1287  match sessions:
1288    case (handle_session, owner_session):
1289      match snapshot_ids:
1290        case (count_id, (export_id, _)):
1291          do IO<Bytes.Handle & Result<&1, &1, Bytes.Error, Unit>>:
1292            opened_cursor : OwnerClient.Session &
1293              Result<&1, &1, OwnerClient.Error, U32> <-
1294                OwnerByteClient.snapshot.cursor.open(owner_session, count_id)
1295            Bytes.backup_to.remote.cursor.counted(path, handle_session,
1296              export_id, opened_cursor)