Struct ZeroCopyProducer 

pub struct ZeroCopyProducer { /* private fields */ }

Zero-copy producer for high-throughput message production

Implementations

impl ZeroCopyProducer

pub fn new(buffer_pool: Arc<ZeroCopyBufferPool>) -> Self

Create a new zero-copy producer

pub fn with_defaults() -> Self

Create a new zero-copy producer with default buffer pool

pub fn create_message( &self, topic: &str, partition: u32, key: Option<&[u8]>, value: &[u8], ) -> ZeroCopyMessage

Create a message with zero-copy value

pub fn create_message_from_bytes( &self, topic: &str, partition: u32, key: Option<Bytes>, value: Bytes, ) -> ZeroCopyMessage

Create a message from existing Bytes (true zero-copy)

pub fn allocate(&self, size: usize) -> Option<(Arc<ZeroCopyBuffer>, usize)>

Allocate space in current buffer and return (buffer, offset) for direct writing.

The caller is responsible for writing into the buffer at the returned offset. Unlike reserve(), this does not create a BufferSlice — it increments the buffer’s write position atomically and returns the raw offset.

pub fn stats(&self) -> ProducerStatsSnapshot

Get producer statistics