Struct JobSpec 

pub struct JobSpec {
    pub name: String,
    pub factory: Arc<JobGraphFactory>,
    pub restart_policy: JobRestartPolicy,
    pub drain_behavior: JobDrainBehavior,
    pub cluster: Option<ClusterJobMetadata>,
}

A named, supervised stream program.

Fields

name: String

factory: Arc<JobGraphFactory>

restart_policy: JobRestartPolicy

drain_behavior: JobDrainBehavior

cluster: Option<ClusterJobMetadata>

Implementations

impl JobSpec

pub fn new<F>(name: impl Into<String>, factory: F) -> Self

where F: Fn(JobContext) -> StreamResult<RunnableGraph<JobMat>> + Send + Sync + 'static,

pub fn with_restart_policy(self, restart_policy: JobRestartPolicy) -> Self

pub fn with_drain_behavior(self, drain_behavior: JobDrainBehavior) -> Self

pub fn with_cluster_metadata(self, metadata: ClusterJobMetadata) -> Self

Trait Implementations

impl Clone for JobSpec

fn clone(&self) -> JobSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JobSpec

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

Formats the value using the given formatter.