Struct ppl::pipeline::node::InOutNode

pub struct InOutNode<TIn, TOut, TCollected, TNext>
where
    TIn: Send,
    TOut: Send,
    TNext: Node<TOut, TCollected>,
{ /* private fields */ }

Struct representing a stage, with an input and an output, of a pipeline.

Implementations

impl<TIn, TOut, TCollected, TNext> InOutNode<TIn, TOut, TCollected, TNext>

where TIn: Send + 'static, TOut: Send + 'static + Sync, TCollected: Sync + Send + 'static, TNext: Node<TOut, TCollected> + Sync + Send + 'static,

pub fn new( handler: Box<dyn InOut<TIn, TOut> + Send + Sync>, next_node: TNext, orchestrator: Arc<Orchestrator> ) -> InOutNode<TIn, TOut, TCollected, TNext>

Create a new Node.

The handler is the struct that implement the trait InOut and defines the behavior of the node we’re creating. next_node contains the stage that follows the node.

Trait Implementations

impl<TIn, TOut, TCollected, TNext> Node<TIn, TCollected> for InOutNode<TIn, TOut, TCollected, TNext>

where TIn: Send + 'static, TOut: Send + Sync + 'static, TCollected: Sync + Send + 'static, TNext: Node<TOut, TCollected> + Send + Sync + 'static,

fn send(&self, input: Message<TIn>, rec_id: usize) -> Result<(), SenderError>

Send a message to the node.

fn collect(self) -> Option<TCollected>

Collect the final result stored in the last stage of the pipeline where is located this node.

fn get_num_of_replicas(&self) -> usize

Fetch the number of replicas of this node.