Struct LogAdapter 

pub struct LogAdapter<L, C, A> { /* private fields */ }

Wraps a CommitLog and specializes it for a specific payload type. This adds the type, topic and the encoding and encryption scheme.

Implementations

impl<L, C, A> LogAdapter<L, C, A>

where L: CommitLog, C: Codec<A>, A: 'static,

pub async fn produce(&self, item: A) -> Result<Offset, ProducerError>

Send one item to the underlying commit log.

pub async fn history<'a>(&'a self) -> Pin<Box<impl Stream<Item = A> + 'a>>

Return an async stream of items representing the history up to the time of the call.

Trait Implementations

impl<L: Debug, C: Debug, A: Debug> Debug for LogAdapter<L, C, A>

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

Formats the value using the given formatter.