Trait flowrlib::protocols::SubmissionProtocol

pub trait SubmissionProtocol {
    // Required methods
    fn flow_execution_starting(&mut self) -> Result<()>;
    fn flow_execution_ended(&mut self, state: &RunState) -> Result<()>;
    fn wait_for_submission(&mut self) -> Result<Option<Submission>>;
    fn coordinator_is_exiting(&mut self, result: Result<()>) -> Result<()>;
}

Programs linking flowrlib that wish to submit a flow for execution via a Submission and then track it’s execution (such as a CLI or a UI) should implement this trait.

Required Methods

fn flow_execution_starting(&mut self) -> Result<()>

Execution of the flow is starting

fn flow_execution_ended(&mut self, state: &RunState) -> Result<()>

The flow has ended

fn wait_for_submission(&mut self) -> Result<Option<Submission>>

Wait for a Submission to be sent to the Coordinator for execution

fn coordinator_is_exiting(&mut self, result: Result<()>) -> Result<()>

The thread or process running the Coordinator to execute the flow is about to exit

Implementors