wasmio 0.0.13

WasmIO a S3 Implementation on steroid
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63

#![cfg_attr(all(target_arch = "wasm32", target_os = "wasi"), feature(wasi_ext))]
#![cfg_attr(
    all(target_arch = "wasm32", target_os = "wasi"),
    feature(async_fn_in_trait)
)]
#![cfg_attr(all(target_arch = "wasm32", target_os = "wasi"), feature(stdsimd))]

mod application;
use application::Application;

mod domain;

mod infrastructure;
use infrastructure::config::Cfg;
use infrastructure::constant::VERSION;
use infrastructure::instrumentation::Instruments;
use infrastructure::storage::FSStorage;
use tracing::info;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    println!(
        r###"
 ▄     ▄ ▄▄▄▄▄▄ ▄▄▄▄▄▄▄ ▄▄   ▄▄ ▄▄▄ ▄▄▄▄▄▄▄ 
█ █ ▄ █ █      █       █  █▄█  █   █       █
█ ██ ██ █  ▄   █  ▄▄▄▄▄█       █   █   ▄   █
█       █ █▄█  █ █▄▄▄▄▄█       █   █  █ █  █
█       █      █▄▄▄▄▄  █       █   █  █▄█  █
█   ▄   █  ▄   █▄▄▄▄▄█ █ ██▄██ █   █       █
█▄▄█ █▄▄█▄█ █▄▄█▄▄▄▄▄▄▄█▄█   █▄█▄▄▄█▄▄▄▄▄▄▄█
"###
    );

    let config = Cfg::hack()?;

    println!(
        r###"

Version: {version}
port: {port}
addr: {addr}

by @miaxos https://github.com/miaxos
"###,
        version = VERSION,
        port = config.bind_addr.port(),
        addr = config.bind_addr.ip(),
    );

    // Instrumentation
    let _ = Instruments::new();
    info!("Starting the process");

    // Initiate the storage, we only support FS for now
    let storage = FSStorage::new(config.storage.path);

    // Server
    let app = Application::new(storage).serve(config.bind_addr);
    app.await??;

    info!("Ending the process");
    Ok(())
}