Struct ChannelBuilder 

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

Builder for creating tango channels with ergonomic configuration.

Example

use tango::ChannelBuilder;

// Create channel components with the builder
let (mcache, dcache, fseq, fctl, metrics) = ChannelBuilder::<64, 64, 256>::new()
    .with_flow_control()
    .with_metrics()
    .build();

// Create producer and consumer from the components
use tango::{Producer, Consumer};
let producer = Producer::with_flow_control(&mcache, &dcache, &fseq, fctl.as_ref().unwrap());
let mut consumer = Consumer::with_flow_control(&mcache, &dcache, fctl.as_ref().unwrap(), 1);

Implementations

impl<const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> ChannelBuilder<MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

pub fn new() -> Self

Create a new channel builder with default settings.

pub fn initial_seq(self, seq: u64) -> Self

Set the initial sequence number (default: 1).

pub fn with_flow_control(self) -> Self

Enable credit-based flow control.

pub fn with_metrics(self) -> Self

Enable metrics tracking.

pub fn build( self, ) -> (MCache<MCACHE_DEPTH>, DCache<CHUNK_COUNT, CHUNK_SIZE>, Fseq, Option<Fctl>, Option<Metrics>)

Build the channel components.

Returns a tuple of:

• MCache - the metadata ring buffer
• DCache - the data chunk storage
• Fseq - the sequence counter
• Option<Fctl> - flow control (if enabled)
• Option<Metrics> - metrics (if enabled)

Trait Implementations

impl<const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Debug for ChannelBuilder<MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

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

Formats the value using the given formatter.

impl<const MCACHE_DEPTH: usize, const CHUNK_COUNT: usize, const CHUNK_SIZE: usize> Default for ChannelBuilder<MCACHE_DEPTH, CHUNK_COUNT, CHUNK_SIZE>

fn default() -> Self

Returns the “default value” for a type.