Struct flowcore::model::submission::Submission
source · pub struct Submission {
pub manifest: FlowManifest,
pub max_parallel_jobs: Option<usize>,
pub job_timeout: Option<Duration>,
}
Expand description
A Submission
is the struct used to send a flow to the Coordinator for execution. It contains
all the information necessary to execute it:
Fields§
§manifest: FlowManifest
The FlowManifest loaded from the manifest_url
max_parallel_jobs: Option<usize>
An optional maximum number of jobs you want dispatched/executing in parallel
job_timeout: Option<Duration>
The Duration to wait before timing out when waiting for jobs to complete
Implementations§
source§impl Submission
impl Submission
sourcepub fn new(
manifest: FlowManifest,
max_parallel_jobs: Option<usize>,
job_timeout: Option<Duration>
) -> Submission
pub fn new( manifest: FlowManifest, max_parallel_jobs: Option<usize>, job_timeout: Option<Duration> ) -> Submission
Create a new Submission
of a flow for execution with the specified FlowManifest
optionally setting a limit for the number of jobs running in parallel
via max_parallel_jobs
Trait Implementations§
source§impl Clone for Submission
impl Clone for Submission
source§fn clone(&self) -> Submission
fn clone(&self) -> Submission
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for Submission
impl Debug for Submission
source§impl<'de> Deserialize<'de> for Submission
impl<'de> Deserialize<'de> for Submission
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Display for Submission
impl Display for Submission
source§impl PartialEq for Submission
impl PartialEq for Submission
source§fn eq(&self, other: &Submission) -> bool
fn eq(&self, other: &Submission) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for Submission
impl Serialize for Submission
impl Eq for Submission
impl StructuralEq for Submission
impl StructuralPartialEq for Submission
Auto Trait Implementations§
impl RefUnwindSafe for Submission
impl Send for Submission
impl Sync for Submission
impl Unpin for Submission
impl UnwindSafe for Submission
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.