Struct Producer 

pub struct Producer<'a, const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> { /* private fields */ }

Implementations

impl<'a, const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Producer<'a, MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

pub fn new( mcache: &'a MCache<MCACHE_DEPTH>, dcache: &'a DCache<CHUNK_COUNT, CHUNK_SIZE>, fseq: &'a Fseq, ) -> Self

Create a producer for a shared mcache/dcache pair.

Without flow control, this producer will freely overwrite chunks. Use with_flow_control for backpressure.

pub fn with_flow_control( mcache: &'a MCache<MCACHE_DEPTH>, dcache: &'a DCache<CHUNK_COUNT, CHUNK_SIZE>, fseq: &'a Fseq, fctl: &'a Fctl, ) -> Self

Create a producer with credit-based flow control.

The producer will acquire a credit before allocating a chunk. Initialize fctl with CHUNK_COUNT credits.

pub fn with_metrics(self, metrics: &'a Metrics) -> Self

Attach metrics tracking to this producer.

Returns a new producer with the same configuration plus metrics.

pub fn publish( &self, payload: &[u8], sig: u64, ctl: u16, ts: u32, ) -> Result<FragmentMetadata, TangoError>

Publish a payload fragment and its metadata.

If flow control is enabled, returns TangoError::NoCredits when no credits are available (consumer hasn’t caught up).

pub fn publish_blocking( &self, payload: &[u8], sig: u64, ctl: u16, ts: u32, ) -> Result<FragmentMetadata, TangoError>

Try to publish, spinning until credits are available or mcache stops.

Only useful when flow control is enabled.

pub fn publish_batch(&self, payloads: &[&[u8]], sig: u64, ctl: u16) -> usize

Publish multiple payloads in a batch.

Returns the number of successfully published messages. Stops on the first error (e.g., NoCredits).

This can be more efficient than calling publish() in a loop as it reduces function call overhead.

Trait Implementations

impl<'a, const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Clone for Producer<'a, MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

fn clone(&self) -> Producer<'a, MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Debug for Producer<'a, MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

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

Formats the value using the given formatter.

impl<'a, const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Copy for Producer<'a, MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>