Struct Schedule

pub struct Schedule<L> {
    pub dag: DAG<Ref<L>>,
}

A task schedule based on a DAG of task nodes.

Fields

dag: DAG<Ref<L>>

Implementations

impl<L> Schedule<L>

pub fn render_to(&self, path: impl AsRef<Path>) -> Result<(), Error>

Render the task graph as an svg image.

Errors

• If writing to the specified output path fails.

pub fn render_to_writer(&self, writer: impl Write) -> Result<(), Error>

Render the task graph as an svg image.

Errors

• If writing to the specified output path fails.

pub fn render(&self) -> String

Render the task graph as an svg image.

impl<L> Schedule<L>

pub fn add_node<I, O, T, D>( &mut self, task: T, deps: D, label: L, ) -> Arc<Node<I, O, L>>

where T: Task<I, O> + Send + Sync + 'static, D: Dependencies<I, L> + Send + Sync + 'static, I: Debug + Send + Sync + 'static, O: Debug + Send + Sync + 'static, L: Debug + Sync + 'static,

Add a new task to the graph.

Dependencies for the task must be references to tasks that have already been added to the task graph (Arc)

pub fn add_closure<C, I, O, D>( &mut self, closure: C, deps: D, label: L, ) -> Arc<Node<I, O, L>>

where C: Closure<I, O> + Send + Sync + 'static, D: Dependencies<I, L> + Send + Sync + 'static, I: Debug + Send + Sync + 'static, O: Debug + Send + Sync + 'static, L: Debug + Sync + 'static,

pub fn add_input<O>(&mut self, input: O, label: L) -> Arc<Node<(), O, L>>

where O: Debug + Send + Sync + 'static, L: Debug + Sync + 'static,

pub fn fail_dependants(&mut self, root: Idx, dependencies: bool)

Marks all dependants as failed.

Optionally also marks all dependencies as failed if they have no pending dependants.

TODO: is this correct and sufficient? TODO: really test this…

pub fn ready(&self) -> impl Iterator<Item = Idx> + '_

pub fn running(&self) -> impl Iterator<Item = Idx> + '_

Trait Implementations

impl<L: Clone> Clone for Schedule<L>

fn clone(&self) -> Schedule<L>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<L: Debug> Debug for Schedule<L>

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

Formats the value using the given formatter.

impl<L> Default for Schedule<L>

fn default() -> Self

Returns the “default value” for a type.