hyperstack-interpreter 0.6.9

AST transformation runtime and VM for HyperStack streaming pipelines
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

use std::sync::{Arc, OnceLock};

use crate::runtime_resolvers::{InProcessResolver, SharedRuntimeResolver};

pub type ResolverBuildError = Box<dyn std::error::Error + Send + Sync>;
pub type ResolverFactory =
    Box<dyn Fn() -> Result<SharedRuntimeResolver, ResolverBuildError> + Send + Sync>;

static FACTORY: OnceLock<ResolverFactory> = OnceLock::new();

/// Register a custom resolver factory. Intended for closed-source backends
/// (e.g. a remote gRPC resolver) to inject themselves before server startup.
///
/// Only the first call takes effect; subsequent calls are ignored.
pub fn set_resolver_factory(factory: ResolverFactory) {
    if FACTORY.set(factory).is_err() {
        tracing::warn!(
            "set_resolver_factory called after a factory was already registered; \
             subsequent registration ignored"
        );
    }
}

/// Build the runtime resolver. Uses the registered factory if set, otherwise
/// falls back to `InProcessResolver::from_env()`.
pub fn build_resolver() -> Result<SharedRuntimeResolver, ResolverBuildError> {
    if let Some(factory) = FACTORY.get() {
        return factory();
    }
    Ok(Arc::new(InProcessResolver::from_env()?))
}