Struct Coordinator 

pub struct Coordinator<'a> { /* private fields */ }

The Coordinator coordinates the dispatching of jobs for flow execution.

A Job consists of a set of Input values and an Implementation of a Function for execution, gathering the resulting Outputs and distributing output values to other connected function’s Inputs.

It accepts Flows to be executed in the form of a Submission struct that has the required information to execute the flow.

Implementations

impl<'a> Coordinator<'a>

pub fn new( dispatcher: Dispatcher, submitter: &'a mut dyn SubmissionHandler, debug_server: &'a mut dyn DebuggerHandler, ) -> Self

Create a new coordinator with num_threads local executor threads

pub fn submission_loop(&mut self, loop_forever: bool) -> Result<()>

Enter a loop - waiting for a submission from the client, or disconnection of the client

Errors

Returns an error if there was some issue while waiting for a submission to be sent, usually related to some networking issue, busy ports etc.

pub fn execute_flow(&mut self, submission: Submission) -> Result<()>

Execute a flow by looping while there are jobs to be processed in an inner loop. There is an outer loop for the case when you are using the debugger, to allow entering the debugger when the flow ends and at any point resetting all the state and starting execution again from the initial state

Errors

Returns an error if the execution of the flow did not complete normally.