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 slice for direct writing

pub fn stats(&self) -> ProducerStatsSnapshot

Get producer statistics