MultiCrossbeamArc

Type Alias MultiCrossbeamArc 

Source
pub type MultiCrossbeamArc<ItemType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> = Multi<ItemType, ChannelMultiArcCrossbeam<ItemType, BUFFER_SIZE, MAX_STREAMS>, INSTRUMENTS, Arc<ItemType>>;

Aliased Type§

pub struct MultiCrossbeamArc<ItemType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> {
    pub multi_name: String,
    pub channel: Arc<Crossbeam<'static, ItemType, BUFFER_SIZE, MAX_STREAMS>>,
    pub executor_infos: RwLock<IndexMap<String, ExecutorInfo>>,
    /* private fields */
}

Fields§

§multi_name: String§channel: Arc<Crossbeam<'static, ItemType, BUFFER_SIZE, MAX_STREAMS>>§executor_infos: RwLock<IndexMap<String, ExecutorInfo>>