def snapshot.cursor.count

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

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

572# Counts one retained owner cursor without materializing its records.
573def snapshot.cursor.count(
574  session: Client.Session,
575  cursor_id: U32
576) -> IO(Client.Session & Result<&1, &1, Client.Error, U32>):
577  snapshot.cursor.count.loop(
578    Nat.mul(3n, Nat.add(4294967295n, 1n)),
579    SnapshotCountNeed{session, CursorCountPolicy.u32.pair(cursor_id), 0})