Struct erdos::scheduler::channel_manager::ChannelManager

pub struct ChannelManager { /* fields omitted */ }

Data structure that stores information needed to set up dataflow channels by constructing individual transport channels.

Methods

impl ChannelManager

pub async fn new<'_>(
    graph: &'_ Graph,
    node_id: NodeId,
    channels_to_receivers: Arc<Mutex<ChannelsToReceivers>>,
    channels_to_senders: Arc<Mutex<ChannelsToSenders>>
) -> Self

Creates transport channels between connected operators on this node, transport channels for operators with streams containing dataflow channels to other nodes, and transport channels from TCP receivers to operators that are connected to streams originating on other nodes.

pub fn take_recv_endpoint<D>(
    &mut self,
    stream_id: StreamId
) -> Result<RecvEndpoint<Message<D>>, String> where
    D: Data + Deserialize<'a>, 

Takes a RecvEnvpoint from a given stream.

pub fn get_send_endpoints<D>(
    &mut self,
    stream_id: StreamId
) -> Result<Vec<SendEndpoint<Message<D>>>, String> where
    D: Data + Deserialize<'a>, 

Returns a cloned vector of the SendEndpoints for a given stream.