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 const DEFAULT_MAX_STDOUT_BYTES: usize

Default maximum bytes retained from a compiler or runtime stdout pipe.

pub const DEFAULT_MAX_STDERR_BYTES: usize

Default maximum bytes retained from a compiler or runtime stderr pipe.

pub fn new(config: NativeTsRuntimeConfig) -> Self

pub fn config(&self) -> &NativeTsRuntimeConfig

pub fn with_output_limits( self, max_stdout_bytes: usize, max_stderr_bytes: usize, ) -> Self

Override the independent byte limits for each compiler and runtime stdout/stderr pipe.

Exceeding either limit terminates the direct child process and returns a runtime error. A zero limit allows an empty pipe but rejects its first byte of output.

pub fn max_stdout_bytes(&self) -> usize

Return the configured byte limit for each stdout pipe.

pub fn max_stderr_bytes(&self) -> usize

Return the configured byte limit for each stderr pipe.

pub fn with_compile_timeout(self, timeout: Duration) -> Self

Set the maximum duration of each cold compiler process.

Cache hits do not start a compiler and therefore do not consume this timeout. By default, compilation has no runtime-owned timeout and remains bounded only by caller cancellation or an outer host timeout.

pub fn with_invocation_timeout(self, timeout: Duration) -> Self

Set the maximum duration of each workflow or step artifact invocation.

The timeout covers writing the complete request to stdin, reading both output pipes, and waiting for process exit. By default, invocation has no runtime-owned timeout and remains bounded only by caller cancellation or an outer host timeout.

pub fn compile_timeout(&self) -> Option<Duration>

Return the configured cold-compilation timeout, if any.

pub fn invocation_timeout(&self) -> Option<Duration>

Return the configured workflow and step invocation timeout, if any.

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.