Skip to main content

IndexedCheckpointFn

Type Alias IndexedCheckpointFn 

Source
pub type IndexedCheckpointFn = Arc<dyn Fn() -> Option<u64> + Send + Sync>;
Expand description

Reads the highest checkpoint the index has committed (the embedded rpc-store’s live-cohort watermark), or None if it has indexed nothing yet. When supplied to SubscriptionService::build, the service holds a checkpoint back until the index has committed it, so a client that observes a checkpoint (e.g. via execute_transaction_and_wait_for_checkpoint) can immediately read that checkpoint’s indexed state.

Aliased Type§

pub struct IndexedCheckpointFn { /* private fields */ }