Struct flowrlib::coordinator::Submission

pub struct Submission {
    pub max_parallel_jobs: usize,
    pub job_timeout: Duration,
    pub debug: bool,
    // some fields omitted
}

A Submission is the struct used to send a flow to the Coordinator for execution. It contains all the information necessary to execute it:

A new Submission is created supplying:

• the manifest of the flow to execute
• the maximum number of jobs you want dispatched/executing in parallel
• whether to display some execution metrics when the flow completes
• an optional DebugClient to allow you to debug the execution

Fields

max_parallel_jobs: usize

job_timeout: Duration

debug: bool

Implementations

impl Submission

pub fn new(
    manifest_url: &str,
    max_parallel_jobs: usize,
    #[cfg(feature = "debugger")] debug: bool
) -> Submission

Create a new Submission of a Flow for execution with the specified Manifest of Functions, executing it with a maximum of mac_parallel_jobs running in parallel connecting via the optional DebugClient

Trait Implementations

impl Debug for Submission

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Submission

pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<Submission> for Submission

pub fn eq(&self, other: &Submission) -> bool

This method tests for self and other values to be equal, and is used by ==.

pub fn ne(&self, other: &Submission) -> bool

This method tests for !=.

impl Serialize for Submission

pub fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Submission