Struct LocalDurableContext 

pub struct LocalDurableContext<P: Provider> { /* private fields */ }

A passthrough durable context for local development and testing.

Executes LLM calls and tool calls directly without journaling. No crash recovery, no replay — just direct passthrough.

This is the default when you do not need durable execution but want a concrete DurableContext implementation.

Implementations

impl<P: Provider> LocalDurableContext<P>

pub fn new(provider: Arc<P>, tools: Arc<ToolRegistry>) -> Self

Create a new local durable context.

Trait Implementations

impl<P: Provider> DurableContext for LocalDurableContext<P>

async fn execute_llm_call( &self, request: CompletionRequest, _options: ActivityOptions, ) -> Result<CompletionResponse, DurableError>

Execute an LLM call as a durable activity.

async fn execute_tool( &self, tool_name: &str, input: Value, ctx: &ToolContext, _options: ActivityOptions, ) -> Result<ToolOutput, DurableError>

Execute a tool call as a durable activity.

async fn wait_for_signal<T: DeserializeOwned + WasmCompatSend>( &self, _signal_name: &str, timeout: Duration, ) -> Result<Option<T>, DurableError>

Wait for an external signal with a timeout.

fn should_continue_as_new(&self) -> bool

Whether the workflow should continue-as-new to avoid history bloat.

async fn continue_as_new(&self, _state: Value) -> Result<(), DurableError>

Continue the workflow as a new execution with the given state.

async fn sleep(&self, duration: Duration)

Sleep for a duration (durable — survives replay).

fn now(&self) -> DateTime<Utc>

Current time (deterministic during replay).