Struct StreamingExecutor

pub struct StreamingExecutor { /* private fields */ }

Streaming executor implementation

Implementations

impl StreamingExecutor

pub fn new(instance_id: InstanceId, config: StreamingConfig) -> Self

Create a new streaming executor

pub fn with_defaults(instance_id: InstanceId) -> Self

Create with default configuration

Trait Implementations

impl StreamingExecution for StreamingExecutor

fn execute_stream<'life0, 'async_trait, S>( &'life0 self, input: S, ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = FunctionResult> + Send>>> + Send + 'async_trait>>

where S: Stream<Item = FunctionCall> + Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Execute a stream of function calls, yielding results as they complete

fn execute_batch<'life0, 'async_trait, I>( &'life0 self, calls: I, ) -> Pin<Box<dyn Future<Output = Vec<FunctionResult>> + Send + 'async_trait>>

where I: IntoIterator<Item = FunctionCall> + Send + 'async_trait, I::IntoIter: Send, Self: 'async_trait, 'life0: 'async_trait,

Execute a batch of function calls

fn execute_with_streaming_input<'life0, 'life1, 'async_trait, S>( &'life0 self, function_name: &'life1 str, input_stream: S, ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Result<Value>> + Send>>> + Send + 'async_trait>>

where S: Stream<Item = Value> + Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a function with streaming input data

fn execute_with_streaming_output<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, function_name: &'life1 str, parameters: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Result<Value>> + Send>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a function that produces streaming output