Struct MemoryOffsetStore 

pub struct MemoryOffsetStore { /* private fields */ }

In-memory offset store for testing and ephemeral consumers

Offsets are lost when the process exits. Use for testing or when offset persistence is handled externally (e.g., in a database transaction).

Implementations

impl MemoryOffsetStore

pub fn new() -> Self

Create a new in-memory offset store

Trait Implementations

impl Clone for MemoryOffsetStore

fn clone(&self) -> MemoryOffsetStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MemoryOffsetStore

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

Formats the value using the given formatter.

impl Default for MemoryOffsetStore

fn default() -> MemoryOffsetStore

Returns the “default value” for a type.

impl OffsetStore for MemoryOffsetStore

fn load( &self, topic_id: u32, consumer_id: u64, ) -> Result<Option<u64>, ClientError>

Load the stored offset for a topic and consumer

fn save( &self, topic_id: u32, consumer_id: u64, offset: u64, ) -> Result<(), ClientError>

Save the current offset for a topic and consumer

fn delete(&self, topic_id: u32, consumer_id: u64) -> Result<(), ClientError>

Delete stored offset for a topic and consumer

fn list_all(&self) -> Result<HashMap<(u32, u64), u64>, ClientError>

List all stored offsets