/// Initializes and returns a send queue
Initializes and returns a send queue
Initializes and returns a send queue
pub(crate) fn new(
        flow_label: String,
        flow_tag: &FlowTag,
        queue_size: QueueSize,
        metrics: SendQueueMetrics,
    ) -> Self {
        let (send_end, receive_end) = channel(queue_size.get());
        let receieve_end_wrapper = ReceiveEndContainer::new(receive_end);
        Self {
            flow_label,
            flow_tag: flow_tag.to_string(),
            error: Arc::new(AtomicBool::new(false)),
            queue_size,
            channel_ends: RwLock::new((send_end, Arc::new(receieve_end_wrapper))),
            metrics,
        }
    }
pub ( crate ) fn new ( flow_label : String , flow_tag : & FlowTag , queue_size : QueueSize , metrics : SendQueueMetrics , ) -> Self { let ( send_end , receive_end ) = channel ( queue_size . get ( ) ) ; let receieve_end_wrapper = ReceiveEndContainer :: new ( receive_end ) ; Self { flow_label , flow_tag : flow_tag . to_string ( ) , error : Arc :: new ( AtomicBool :: new ( false ) ) , queue_size , channel_ends : RwLock :: new ( ( send_end , Arc :: new ( receieve_end_wrapper ) ) ) , metrics , } }
Initializes and returns a send queue
Initializes and returns a send queue
flow_label
String
flow_tag
&FlowTag
queue_size
QueueSize
metrics
SendQueueMetrics