Struct Producer

pub struct Producer<'env> { /* private fields */ }

Implementations

impl<'env> Producer<'env>

pub fn new( env: &'env Env, name: &str, chunk_size: Option<u64>, ) -> Result<Self, Error>

pub fn push_back_batch<'a, B>(&mut self, messages: &'a B) -> Result<(), Error>

where B: AsRef<[&'a [u8]]>,

pub fn push_back<'a>(&mut self, message: &'a [u8]) -> Result<(), Error>

Trait Implementations

impl<'env> Topic for Producer<'env>

fn get_env(&self) -> &Env

fn get_db(&self) -> Database

fn lag(&self) -> Result<u64, Error>

fn inc( &self, txn: &mut RwTransaction<'_>, key: &[u8], delta: u64, ) -> Result<(), Error>

fn replace( &self, txn: &mut RwTransaction<'_>, key: &[u8], value: u64, ) -> Result<(), Error>

fn get_tail<TXN>(db: Database, txn: &TXN) -> Result<(u64, u64), Error>

where TXN: Transaction,

fn get_value<TXN>(db: Database, txn: &TXN, key: &[u8]) -> Result<u64, Error>

where TXN: Transaction,