Struct HookedOffsetStore 

pub struct HookedOffsetStore<S: OffsetStore> { /* private fields */ }

Offset store wrapper that invokes post-commit hooks

Wraps an inner OffsetStore and calls registered hooks after each commit.

Implementations

impl<S: OffsetStore> HookedOffsetStore<S>

pub fn new(inner: S) -> Self

Create a new hooked offset store

pub fn add_hook(self, hook: Arc<dyn PostCommitHook>) -> Self

Add a post-commit hook

pub fn with_hooks(self, hooks: Vec<Arc<dyn PostCommitHook>>) -> Self

Add multiple post-commit hooks

pub fn inner(&self) -> &S

Get the inner store

Trait Implementations

impl<S: OffsetStore> OffsetStore for HookedOffsetStore<S>

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