webhook-gateway 2.17.2

A service to ingress github event
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

use webhook_gateway::config_env;
use webhook_gateway::channel;
use webhook_gateway::queue;
use webhook_gateway::web;
use std::thread;
use tracing::{level_filters};

fn main() {
    let filter = level_filters::LevelFilter::INFO;

    tracing_subscriber::fmt().with_max_level(filter).init();

    config_env::ensure_config();
    queue::init_channels();
    let mut v = vec![];
    let j = thread::spawn(|| {
        web::event_loop().expect("web event loop failing."); // fine to crash as cannot start the web server
    });
    v.push(j);
    let j = thread::spawn(|| {
        channel::consumer::event_loop();
    });
    v.push(j);
    for t in v {
        t.join().expect("cannot join the thread.");
    }
}