Struct TaskChain 

pub struct TaskChain { /* private fields */ }

Available on native and crate feature tasks only.

Task chain configuration

Examples

use reinhardt_tasks::TaskChain;

let chain = TaskChain::new("email-workflow");
assert_eq!(chain.name(), "email-workflow");

Implementations

impl TaskChain

pub fn new(name: impl Into<String>) -> TaskChain

Create a new task chain

Examples

use reinhardt_tasks::TaskChain;

let chain = TaskChain::new("payment-processing");
assert_eq!(chain.name(), "payment-processing");

pub fn id(&self) -> TaskId

Get the chain ID

Examples

use reinhardt_tasks::TaskChain;

let chain = TaskChain::new("test-chain");
let id = chain.id();

pub fn name(&self) -> &str

Get the chain name

Examples

use reinhardt_tasks::TaskChain;

let chain = TaskChain::new("my-chain");
assert_eq!(chain.name(), "my-chain");

pub fn add_task(&mut self, task_id: TaskId)

Add a task to the chain

Examples

use reinhardt_tasks::{TaskChain, TaskId};

let mut chain = TaskChain::new("workflow");
let task_id = TaskId::new();
chain.add_task(task_id);
assert_eq!(chain.task_count(), 1);

pub fn task_count(&self) -> usize

Get the number of tasks in the chain

Examples

use reinhardt_tasks::{TaskChain, TaskId};

let mut chain = TaskChain::new("workflow");
chain.add_task(TaskId::new());
chain.add_task(TaskId::new());
assert_eq!(chain.task_count(), 2);

pub fn current_task(&self) -> Option<TaskId>

Get the current task ID

Examples

use reinhardt_tasks::{TaskChain, TaskId};

let mut chain = TaskChain::new("workflow");
let task_id = TaskId::new();
chain.add_task(task_id);

assert_eq!(chain.current_task(), Some(task_id));

pub fn advance(&mut self) -> bool

Move to the next task in the chain

Returns true if there are more tasks, false if the chain is complete.

Examples

use reinhardt_tasks::{TaskChain, TaskId};

let mut chain = TaskChain::new("workflow");
chain.add_task(TaskId::new());
chain.add_task(TaskId::new());

assert!(chain.advance());
assert!(!chain.advance()); // No more tasks

pub fn status(&self) -> ChainStatus

Get the chain status

Examples

use reinhardt_tasks::{TaskChain, ChainStatus};

let chain = TaskChain::new("workflow");
assert_eq!(chain.status(), ChainStatus::Pending);

pub fn set_status(&mut self, status: ChainStatus)

Set the chain status

Examples

use reinhardt_tasks::{TaskChain, ChainStatus};

let mut chain = TaskChain::new("workflow");
chain.set_status(ChainStatus::Running);
assert_eq!(chain.status(), ChainStatus::Running);

pub fn is_complete(&self) -> bool

Check if the chain is complete

Examples

use reinhardt_tasks::{TaskChain, ChainStatus};

let mut chain = TaskChain::new("workflow");
chain.set_status(ChainStatus::Completed);
assert!(chain.is_complete());

pub async fn execute( &mut self, backend: Arc<dyn TaskBackend>, ) -> Result<(), TaskExecutionError>

Execute the chain

This method will execute all tasks in the chain sequentially.

Examples

use reinhardt_tasks::{TaskChain, DummyBackend};
use std::sync::Arc;

let mut chain = TaskChain::new("workflow");
let backend = Arc::new(DummyBackend::new());

chain.execute(backend).await?;
assert!(chain.is_complete());

Trait Implementations

impl Clone for TaskChain

fn clone(&self) -> TaskChain

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskChain

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskChain

fn deserialize<__D>( __deserializer: __D, ) -> Result<TaskChain, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskChain

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

where __S: Serializer,

Serialize this value into the given Serde serializer.