Struct NativeTsRuntime 

pub struct NativeTsRuntime { /* private fields */ }

Runtime that compiles TypeScript to a native executable and speaks JSON over stdin/stdout with that executable.

Implementations

impl NativeTsRuntime

pub fn new(config: NativeTsRuntimeConfig) -> Self

pub fn config(&self) -> &NativeTsRuntimeConfig

pub async fn preflight( &self, spec: &WorkflowSpec, ) -> Result<NativeTsRuntimePreflight>

Trait Implementations

impl Clone for NativeTsRuntime

fn clone(&self) -> NativeTsRuntime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NativeTsRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FlowRuntime for NativeTsRuntime

fn run_workflow<'life0, 'async_trait>( &'life0 self, invocation: WorkflowInvocation, ) -> Pin<Box<dyn Future<Output = Result<RuntimeCommand>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replay the deterministic workflow function and return the next command.

fn run_step<'life0, 'async_trait>( &'life0 self, invocation: StepInvocation, ) -> Pin<Box<dyn Future<Output = Result<JsonValue>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute one side-effecting step. The engine persists success/failure.