Struct Scheduler

Source

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

Implementations§

Source §

impl<E: Clone + PartialEq + Send + Default + 'static> Scheduler<E>

Source

pub fn new() -> Self

Examples found in repository ?

examples/basic.rs (line 19)

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 add(&mut self, task: Task<E>)

Examples found in repository ?

examples/basic.rs (line 20)

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 async fn run_once(&self)

Source

pub async fn run(&self)

Examples found in repository ?

examples/basic.rs (line 21)

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}