Struct Chain 

pub struct Chain {
    pub id: String,
    /* private fields */
}

A sequence of jobs.

Fields

id: String

A name for the whole, so progress for the pipeline has one key. Generated when not given.

Implementations

impl Chain

pub fn new<J: Job>(first: J) -> Chain

Start a chain with its first step.

pub fn named(self, id: impl Into<String>) -> Chain

Name the chain yourself — an order id, a video id — so the key a UI watches is one it already knows.

pub fn then<J: Job>(self, next: J) -> Chain

pub fn then_queued(self, next: QueuedJob) -> Chain

Add a step that is already an envelope, for a job with no Rust type.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn into_queued(self) -> QueuedJob

The first step, carrying the rest and the chain’s id. This is what is pushed; the worker peels one step off each time one succeeds.

Trait Implementations

impl Clone for Chain

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Chain

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

Formats the value using the given formatter.

impl PartialEq for Chain

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Chain