Struct TaskChain

Source

pub struct TaskChain { /* private fields */ }

Expand description

Task chain configuration

§Examples

use reinhardt_tasks::TaskChain;

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

Implementations§

Source §

impl TaskChain

Source

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

Create a new task chain

§Examples

use reinhardt_tasks::TaskChain;

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

Source

pub fn id(&self) -> TaskId

Get the chain ID

§Examples

use reinhardt_tasks::TaskChain;

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

Source

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");

Source

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);

Source

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);

Source

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));

Source

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

Source

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);

Source

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);

Source

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());

Source

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());