dge-gen 0.2.0

Crate for building a computational graph to be executed distributely
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

{% include "part_comment.rs" %}

{% include "part_common_import.rs" %}

use fern;
use chrono;

#[rustfmt::skip]
#[tokio::main]
pub(crate) async fn main() -> Result<()> {
    let rmq_uri = {{ rmq_options.get_rmq_uri }}();

    // all queues used in the graph
    // (work_queue, retry_queue_for_work_queue, retry_interval_in_seconds)
    let all_queues = vec![
        {%- for q in all_queues %}
        ("{{q.0}}", "{{q.1}}", {{q.2}}),
        {%- endfor %}
    ];

    let () = rmq_init::init_exchanges_and_queues(
        rmq_uri.as_ref(),
        "{{ rmq_options.work_exchange }}",
        "{{ rmq_options.retry_exchange }}",
        all_queues,
    ).await?;

    info!("all necessary exchanges and queues initialized");

    Ok(())
}