Struct TypedTableView 

pub struct TypedTableView<S: Schema, C: ConsumerApi + Clone = Consumer> { /* private fields */ }

Schema-aware TableView. Wraps a raw TableView plus an Arc<S> and exposes typed accessors that decode the payload on demand. Mirrors Java’s pulsar.tableView(Schema) shape.

Engine-generic. Defaults C = magnetar_runtime_tokio::Consumer so existing call sites (TypedTableView<MySchema> without a second type argument) keep resolving to the tokio specialisation.

Implementations

impl<S: Schema + 'static, C: ConsumerApi + Clone> TypedTableView<S, C>

pub fn inner(&self) -> &TableView<C>

Borrow the underlying raw TableView. Useful for the unchanged getters (len, is_empty, keys, listener registration, etc.).

pub fn get(&self, key: &str) -> Result<Option<S::Owned>, PulsarError>

Decode the value for key. Returns Ok(None) when the key is absent, Err when decoding the stored bytes against the schema fails.

pub fn snapshot(&self) -> Result<HashMap<String, S::Owned>, PulsarError>

Decode every currently-known value. Allocates; use Self::for_each to avoid the HashMap allocation when streaming. Errors stop at the first decode failure.

pub fn for_each<F>(&self, f: F)

where F: FnMut(&str, Result<S::Owned, SchemaError>),

Iterate every currently-known (key, decoded value) pair. The callback receives Result<S::Owned, SchemaError> so per-key decode failures don’t abort the iteration.

pub fn listen<F>(&self, callback: F)

where F: Fn(&str, Option<&S::Owned>) + Send + Sync + 'static,

Register a typed listener fired for every mutation. The callback receives the pre-decoded value (or None for a tombstone). Decode failures replace the value with None so the listener is never poisoned by a single bad payload. The callback runs inside the drain task — keep it fast and non-blocking.

Trait Implementations

impl<S: Schema, C: ConsumerApi + Clone> Clone for TypedTableView<S, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Schema, C: ConsumerApi + Clone> Debug for TypedTableView<S, C>

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

Formats the value using the given formatter.