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::options::ClientOptions;
use mongodb::{Client, Collection};

pub async fn get_collection<T: Send + Sync>(
    connection_str: impl AsRef<str>,
    collection_name: impl AsRef<str>,
) -> Collection<T> {
    let client_options = ClientOptions::parse(connection_str.as_ref()).await.unwrap();
    let target_database = client_options.default_database.clone().unwrap();
    // Get a handle to the deployment.
    let client = Client::with_options(client_options).unwrap();
    let database = client.database(target_database.as_str());
    let collection = database.collection::<T>(collection_name.as_ref());
    collection
}

pub async fn get_collection_result<T: Send + Sync>(
    connection_str: impl AsRef<str>,
    collection_name: impl AsRef<str>,
) -> Collection<T> {
    let client_options = ClientOptions::parse(connection_str.as_ref()).await.unwrap();
    let target_database = client_options.default_database.clone().unwrap();
    // Get a handle to the deployment.
    let client = Client::with_options(client_options).unwrap();
    let database = client.database(target_database.as_str());
    let collection = database.collection::<T>(collection_name.as_ref());
    collection
}