omnia-wasi-config 0.31.0

WASI config interface implementation for the Omnia runtime
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

//! Default no-op implementation for wasi-otel
//!
//! This is a lightweight implementation for development use only.
//! It logs telemetry data but doesn't export it anywhere.
//! For production use, use the `be-opentelemetry` backend.

#![allow(clippy::used_underscore_binding)]

use std::env;
use std::fmt::{Debug, Formatter};
use std::sync::Arc;

use anyhow::Result;
use omnia::Backend;
use tracing::instrument;
use wasmtime_wasi_config::WasiConfigVariables;

use crate::WasiConfigCtx;

#[derive(Debug, Clone, Default)]
pub struct ConnectOptions;

impl omnia::FromEnv for ConnectOptions {
    fn from_env() -> Result<Self> {
        Ok(Self)
    }
}

/// Default implementation for `wasi:config`.
#[derive(Clone)]
pub struct ConfigDefault {
    /// The configuration variables.
    pub config_vars: Arc<WasiConfigVariables>,
}

impl Debug for ConfigDefault {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        write!(f, "WasiConfigCtxImpl")
    }
}

impl Backend for ConfigDefault {
    type ConnectOptions = ConnectOptions;

    #[instrument]
    async fn connect_with(_: Self::ConnectOptions) -> Result<Self> {
        let config_vars = env::vars().collect();

        Ok(Self {
            config_vars: Arc::new(config_vars),
        })
    }
}

impl WasiConfigCtx for ConfigDefault {
    fn get_config(&self) -> &WasiConfigVariables {
        &self.config_vars
    }
}