parallax-runtime 0.1.0

Runtime manager, worker orchestration, and adapter trait
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

//! Runtime adapter trait.

use async_trait::async_trait;
use parallax_core::{
    ExecutionRequest, ExecutionResult, RestoreResult, RuntimeCapabilities, RuntimeKind,
    RuntimeMetadata, RuntimeStatus,
};
use parallax_ir::PirDocument;
use parallax_security::SandboxPolicy;
use std::sync::Arc;

/// Trait implemented by language adapters.
#[async_trait]
pub trait RuntimeAdapter: Send + Sync {
    /// Runtime kind.
    fn kind(&self) -> RuntimeKind;

    /// Static metadata.
    fn metadata(&self) -> RuntimeMetadata;

    /// Declared capabilities.
    fn capabilities(&self) -> RuntimeCapabilities;

    /// Probe host availability (may spawn briefly).
    async fn probe(&self) -> RuntimeStatus;

    /// Execute a program, optionally capturing bindings listed in the request.
    async fn execute(
        &self,
        request: ExecutionRequest,
        policy: &SandboxPolicy,
    ) -> parallax_core::Result<ExecutionResult>;

    /// Restore PIR bindings into a fresh worker context.
    async fn restore(
        &self,
        pir: &PirDocument,
        policy: &SandboxPolicy,
    ) -> parallax_core::Result<RestoreResult>;
}

/// Heap-allocated adapter.
pub type BoxRuntimeAdapter = Arc<dyn RuntimeAdapter>;

/// Factory fn type.
pub type AdapterFactory = Arc<dyn Fn() -> BoxRuntimeAdapter + Send + Sync>;