Struct InMemoryOffsetStore 

pub struct InMemoryOffsetStore { /* private fields */ }

In-memory offset store implementation

Stores offsets in memory using a concurrent hash map. Suitable for testing and development.

Implementations

impl InMemoryOffsetStore

pub fn new() -> Self

Create a new in-memory offset store

Trait Implementations

impl Default for InMemoryOffsetStore

fn default() -> Self

Returns the “default value” for a type.

impl OffsetStore for InMemoryOffsetStore

fn store_offset<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, offset_info: &'life3 OffsetInfo, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Store offset for a topic-partition

fn get_offset<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, ) -> Pin<Box<dyn Future<Output = StateResult<Option<OffsetInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieve offset for a topic-partition

fn get_all_offsets<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<HashMap<TopicPartition, OffsetInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all offsets for a consumer group

fn delete_offset<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete offset for a topic-partition

fn clear_offsets<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Clear all offsets for a consumer group