Function apply_observability_env

nodedb/src/config/server/observability.rs:159–233

Apply observability-related environment variable overrides. Variables: - `NODEDB_PROMQL_ENABLED` — "true"/"false" - `NODEDB_OTLP_RECEIVER_ENABLED` — "true"/"false" - `NODEDB_OTLP_HTTP_LISTEN` — SocketAddr - `NODEDB_OTLP_GRPC_LISTEN` — SocketAddr - `NODEDB_OTLP_EXPORT_ENABLED` — "true"/"false" - `NODEDB_OTLP_EXPORT_ENDPOINT` — URL string - `NODEDB_OTLP_EXPORT_INTERVAL`

(config: &mut ObservabilityConfig)

/// - `NODEDB_OTLP_EXPORT_ENDPOINT`   — URL string
/// - `NODEDB_OTLP_EXPORT_INTERVAL`   — seconds (u64)
pub fn apply_observability_env(config: &mut ObservabilityConfig) {
    if let Ok(val) = std::env::var("NODEDB_PROMQL_ENABLED")
        && let Ok(b) = val.parse::<bool>()
    {
        tracing::info!(
            env_var = "NODEDB_PROMQL_ENABLED",
            value = b,
            "override applied"
        );
        config.promql.enabled = b;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_RECEIVER_ENABLED")
        && let Ok(b) = val.parse::<bool>()
    {
        tracing::info!(
            env_var = "NODEDB_OTLP_RECEIVER_ENABLED",
            value = b,
            "override applied"
        );
        config.otlp.receiver.enabled = b;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_HTTP_LISTEN")
        && let Ok(addr) = val.parse::<SocketAddr>()
    {
        tracing::info!(env_var = "NODEDB_OTLP_HTTP_LISTEN", value = %val, "override applied");
        config.otlp.receiver.http_listen = addr;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_GRPC_LISTEN")
        && let Ok(addr) = val.parse::<SocketAddr>()
    {
        tracing::info!(env_var = "NODEDB_OTLP_GRPC_LISTEN", value = %val, "override applied");
        config.otlp.receiver.grpc_listen = addr;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_EXPORT_ENABLED")
        && let Ok(b) = val.parse::<bool>()
    {
        tracing::info!(
            env_var = "NODEDB_OTLP_EXPORT_ENABLED",
            value = b,
            "override applied"
        );
        config.otlp.export.enabled = b;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_EXPORT_ENDPOINT") {
        tracing::info!(env_var = "NODEDB_OTLP_EXPORT_ENDPOINT", value = %val, "override applied");
        config.otlp.export.endpoint = val;
    }

    if let Ok(val) = std::env::var("NODEDB_OTLP_EXPORT_INTERVAL")
        && let Ok(secs) = val.parse::<u64>()
    {
        tracing::info!(
            env_var = "NODEDB_OTLP_EXPORT_INTERVAL",