Struct InMemoryCursorStore 

pub struct InMemoryCursorStore { /* private fields */ }

HashMap-backed CursorStore for fixtures and unit tests.

Commits are in-memory only and are lost across process restarts; not suitable for production. A sqlite-backed impl is the usual next step for single-node indexers; Postgres or Redis for HA.

Implementations

impl InMemoryCursorStore

pub fn new() -> Self

Construct an empty store.

pub fn insert(&self, subscription_id: &str, seq: u64)

Seed the store with an initial cursor, e.g. for test replay.

Panics

Panics if the internal mutex has been poisoned by a previous panic in another thread.

Trait Implementations

impl CursorStore for InMemoryCursorStore

async fn load(&self, subscription_id: &str) -> Result<Option<u64>, IndexerError>

Load the last committed cursor for subscription_id, if any.

async fn commit( &self, subscription_id: &str, seq: u64, ) -> Result<(), IndexerError>

Commit seq as the new cursor for subscription_id.

async fn list(&self) -> Result<Vec<(String, u64)>, IndexerError>

Enumerate every committed (subscription_id, seq) pair.

impl Debug for InMemoryCursorStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryCursorStore

fn default() -> InMemoryCursorStore

Returns the “default value” for a type.