Struct TaskBuilder

Source

pub struct TaskBuilder<E> { /* private fields */ }

Implementations§

Source §

impl<E: Clone + PartialEq + Send + 'static> TaskBuilder<E>

Source

pub fn new<F>(name: &str, action: F) -> Self
where F: Fn() -> JoinHandle<Result<(), E>> + Send + Sync + 'static,

Examples found in repository ?

examples/basic.rs (lines 7-12)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}

Source

pub fn interval(self, interval: Duration) -> Self

Source

pub fn max_retries(self, retries: u32) -> Self

Examples found in repository ?

examples/basic.rs (line 13)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}

Source

pub fn retry_base_delay(self, delay: Duration) -> Self

Examples found in repository ?

examples/basic.rs (line 14)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}

Source

pub fn timeout(self, timeout: Duration) -> Self

Source

pub fn retry_errors(self, errors: Vec<E>) -> Self

Source

pub fn logger<FN>(self, logger: FN) -> Self
where FN: Fn(&str) + Send + Sync + 'static,

Source

pub fn on_success<FN>(self, callback: FN) -> Self
where FN: Fn() + Send + Sync + 'static,

Examples found in repository ?

examples/basic.rs (line 15)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}

Source

pub fn on_failure<FN>(self, callback: FN) -> Self
where FN: Fn() + Send + Sync + 'static,

Examples found in repository ?

examples/basic.rs (line 16)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}

Source

pub fn build(self) -> Task<E>

Examples found in repository ?

examples/basic.rs (line 17)

6async fn main() {
7    let task = TaskBuilder::new("demo_task", || {
8        tokio::spawn(async {
9            println!("Tentative de tâche...");
10            Err::<(), i32>(1)
11        })
12    })
13    .max_retries(3)
14    .retry_base_delay(Duration::from_millis(50))
15    .on_success(|| println!("🎉 Task succeeded!"))
16    .on_failure(|| println!("💥 Task failed after all retries"))
17    .build();
18
19    let mut scheduler = Scheduler::new();
20    scheduler.add(task);
21    scheduler.run().await;
22}