mscheduler 0.3.1

Use mongodb to schedule task running
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use mongodb::bson::doc;
use mongodb::options::IndexOptions;
use mongodb::{Collection, IndexModel};

pub async fn ensure_index<T: Send + Sync>(collection: &Collection<T>) {
    let key_index = IndexModel::builder()
        .keys(doc! {"key":1})
        .options({
            let mut options = IndexOptions::default();
            options.name = Some("key".to_string());
            options.unique = Some(true);
            options.background = Some(true);
            options
        })
        .build();
    let _ = collection.create_index(key_index).await;
    let worker_id_index = IndexModel::builder()
        .keys(doc! {"key":1,"task_state.worker_states.worker_id": 1})
        .options({
            let mut options = IndexOptions::default();
            options.name = Some("key_worker_id".to_string());
            options.unique = Some(true);
            options.background = Some(true);
            options
        })
        .build();
    let _ = collection.create_index(worker_id_index).await;
}