def snapshot.cursor.seek

mylsm-lsm-store@0.6.0.1 · src/coordinator/ByteClient.bend:392

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as Client
import mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend as Protocol
import mylsm-lsm-store@0.6.0.1/src/coordinator/CursorOpenCodec.bend as CursorOpenCodec
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

392def snapshot.cursor.seek(
393  session: Client.Session,
394  cursor_id: U32,
395  lower: Maybe<&1, Bytes.Bytes>
396) -> IO(Client.Session & Result<&1, &1, Client.Error, Unit>):
397  do IO<Client.Session & Result<&1, &1, Client.Error, Unit>>:
398    pair : Client.Session & Result<&1, &1, Client.Error, Protocol.Response> <-
399      Client.session.call(session, 15,
400        CursorOpenCodec.encode.range(cursor_id, lower, None{}))
401    return snapshot.cursor.seek.result(pair)