vyuh 0.2.7

Vyuh web framework for Axum and SQLx with handler-first APIs
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use vyuh::{Data, bundles, tasks::TaskOutcome};

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
struct EmailJob {
    to: String,
    subject: String,
}

#[bundles::task(name = "send_email")]
async fn send_email(input: Data<EmailJob>) -> TaskOutcome {
    TaskOutcome::complete(&format!("sent {} to {}", input.subject, input.to)).unwrap()
}

fn app_bundle() -> bundles::Bundle {
    bundles::bundle! {
        send_email,
    }
}

#[tokio::main]
async fn main() {
    let _bundle = app_bundle();

    // With a built Site:
    // site.tasks().submit(EmailJob {
    //     to: "user@example.com".into(),
    //     subject: "Welcome".into(),
    // }).await?;
    //
    // site.tasks()
    //     .submit_with(
    //         EmailJob {
    //             to: "user@example.com".into(),
    //             subject: "Welcome".into(),
    //         },
    //         vyuh::tasks::TaskOptions {
    //             priority: 10,
    //             initial_delay: Some(std::time::Duration::from_secs(300)),
    //             retry_delay: Some(std::time::Duration::from_secs(60)),
    //             lease_duration: Some(std::time::Duration::from_secs(900)),
    //             max_attempts: Some(5),
    //             identity: Some("welcome:user@example.com".into()),
    //             ..vyuh::tasks::TaskOptions::default()
    //         },
    //     )
    //     .await?;
}