Skip to main content

Module cursor

Module cursor 

Source

Structs§

CheckpointDriver
Drives cursor checkpoints according to the channel’s configured policy.
ConsumerCursor
Partition-specific durable read position for one consumer.

Functions§

cursor_key_for
Formats the haematite key used for cursor compare-and-swap state.