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 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.