micro-tower 0.1.0

micro-tower is a framework to generate and manage micro services.
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

#![feature(error_reporter)]

use std::net::SocketAddr;
use std::num::ParseIntError;

use micro_tower::api::codec;
use micro_tower::prelude::*;
use micro_tower::shutdown::Controller;
use micro_tower::ServiceBuilder;
use tracing::Level;
use tracing_subscriber::FmtSubscriber;

/// Service documentation
#[micro_tower::codegen::service]
pub async fn parse_str(request: String) -> Result<i32, ParseIntError> {
    request.parse()
}

#[tokio::main]
async fn main() {
    let subscriber = FmtSubscriber::builder()
        .with_max_level(Level::TRACE)
        .finish();
    tracing::subscriber::set_global_default(subscriber).unwrap();

    let controller = Controller::default();

    let service = ServiceBuilder::new().service_fn(|_| async move {
        let service = parse_str::builder().build();
        let service = ServiceBuilder::new()
            .api::<String, codec::Json>()
            .service(service);
        Ok(service)
    });

    let addr: SocketAddr = "127.0.0.1:8000".parse().unwrap();
    let service_handle = micro_tower::session::tcp::spawn(addr, service, &controller);
    let shutdown_handle = controller.spawn_handler().unwrap();

    if let Err(err) = service_handle.await.unwrap() {
        let report = micro_tower::report!(err.as_ref());
        panic!("{report:?}")
    }
    shutdown_handle.await.unwrap();
}