wasmx 0.0.0

High-performance, embeddable WebAssembly execution engine
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

pub mod config;
mod engine;
mod host;
pub mod wasmtime;

use core::fmt::Debug;
use core::str::FromStr;
use core::sync::atomic::AtomicU64;
use core::task::Waker;
use core::time::Duration;

use std::env::{self, VarError};

use tracing::warn;

pub use self::config::Manifest;
pub use self::engine::{
    bindings, wasi, Cmd, Ctx, DynamicWorkloadInvocation, Engine, WorkloadInvocation,
    WorkloadInvocationPayload,
};
pub use self::host::{apply_manifest, load_and_apply_manifest, load_manifest, Host};

pub const EPOCH_INTERVAL: Duration = Duration::from_millis(1);

pub static EPOCH_MONOTONIC_NOW: AtomicU64 = AtomicU64::new(0);
pub static EPOCH_SYSTEM_NOW: AtomicU64 = AtomicU64::new(0);

pub(crate) const NOOP_WAKER: &Waker = Waker::noop();

fn getenv<T>(key: &str) -> Option<T>
where
    T: FromStr,
    T::Err: Debug,
{
    match env::var(key).as_deref().map(FromStr::from_str) {
        Ok(Ok(v)) => Some(v),
        Ok(Err(err)) => {
            warn!(?err, "failed to parse `{key}` value, ignoring");
            None
        }
        Err(VarError::NotPresent) => None,
        Err(VarError::NotUnicode(..)) => {
            warn!("`{key}` value is not valid UTF-8, ignoring");
            None
        }
    }
}