type SnapshotCountState

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

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/CursorCodec.bend as CursorCodec
import mylsm-lsm-store@0.6.0.1/src/coordinator/CursorCountPolicy.bend as CursorCountPolicy

15# Carries a bounded remote cursor count across incremental owner reads.
16type SnapshotCountState is Type:
17  SnapshotCountNeed{session: Client.Session, cursor_ids: U32 & U32,
18    count: U32}
19  SnapshotCountFrame{pair:
20    Client.Session & Result<&1, &1, Client.Error, CursorCodec.Frame>,
21    cursor_id: U32, count: U32}
22  SnapshotCountItem{session: Client.Session, cursor_id: U32,
23    decision: CursorCountPolicy.Decision}