overclock 0.1.13

A framework for building data-driven distributed systems
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

// Copyright 2022 Louay Kamel
// Copyright 2021 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

//// Based on minimal axum hello example

use axum::{extract::ConnectInfo, routing::get, Router};

// basic handler that responds with a static string
async fn root(ConnectInfo(addr): ConnectInfo<std::net::SocketAddr>) -> String {
    format!("Hello {}", addr)
}

// our prefab example starts from here
use overclock::{core::*, prefab::axum::Axum};

#[tokio::main]
async fn main() {
    #[cfg(not(feature = "console"))]
    {
        let env = env_logger::Env::new().filter_or("RUST_LOG", "info");
        env_logger::Builder::from_env(env).init();
    }
    let addr = ([127, 0, 0, 1], 3000).into();
    // build our application with a route
    let app = Router::new().route("/", get(root));
    let axum = Axum::<std::net::SocketAddr>::new(addr, app);
    let runtime = Runtime::new("axum".to_string(), axum).await.expect("Runtime to run");
    runtime.block_on().await.expect("Runtime to shutdown gracefully");
}