Struct ThreadRuntime 

pub struct ThreadRuntime {
    pub thread: RwLock<Thread>,
    pub interactions: RwLock<HashMap<InteractionId, Interaction>>,
    pub concurrency_policy: Arc<dyn ConcurrencyPolicy>,
    pub event_store: Arc<dyn EventStore>,
    pub event_bus: Arc<dyn EventBus>,
    pub config: ThreadRuntimeConfig,
}

ThreadRuntime - manages thread lifecycle and interaction concurrency

Fields

thread: RwLock<Thread>

The thread being managed

interactions: RwLock<HashMap<InteractionId, Interaction>>

Active interactions in this thread

concurrency_policy: Arc<dyn ConcurrencyPolicy>

Concurrency policy

event_store: Arc<dyn EventStore>

Event store

event_bus: Arc<dyn EventBus>

Realtime event bus

config: ThreadRuntimeConfig

Configuration

Implementations

impl ThreadRuntime

pub fn new(thread: Thread, event_store: Arc<dyn EventStore>) -> Self

Create a new thread runtime

pub fn new_with_bus( thread: Thread, event_store: Arc<dyn EventStore>, event_bus: Arc<dyn EventBus>, ) -> Self

Create a new thread runtime with custom event bus

pub fn with_policy( thread: Thread, event_store: Arc<dyn EventStore>, policy: Arc<dyn ConcurrencyPolicy>, ) -> Self

Create a new thread runtime with custom policy

pub fn with_policy_and_bus( thread: Thread, event_store: Arc<dyn EventStore>, policy: Arc<dyn ConcurrencyPolicy>, event_bus: Arc<dyn EventBus>, ) -> Self

Create a new thread runtime with custom policy and event bus

pub fn with_config( thread: Thread, event_store: Arc<dyn EventStore>, config: ThreadRuntimeConfig, ) -> Self

Create a new thread runtime with custom config

pub fn with_config_and_bus( thread: Thread, event_store: Arc<dyn EventStore>, config: ThreadRuntimeConfig, event_bus: Arc<dyn EventBus>, ) -> Self

Create a new thread runtime with custom config and event bus

pub fn with_policy_and_config( thread: Thread, event_store: Arc<dyn EventStore>, policy: Arc<dyn ConcurrencyPolicy>, config: ThreadRuntimeConfig, ) -> Self

Create a new thread runtime with custom policy and config

pub fn with_policy_config_and_bus( thread: Thread, event_store: Arc<dyn EventStore>, policy: Arc<dyn ConcurrencyPolicy>, config: ThreadRuntimeConfig, event_bus: Arc<dyn EventBus>, ) -> Self

Create a new thread runtime with custom policy, config, and event bus

pub async fn thread_id(&self) -> ThreadId

Get the thread ID

pub async fn running_state(&self) -> RunningState

Get the current running state

pub async fn handle_event( &self, event: Event, ) -> Result<HandleEventResult, RuntimeError>

Handle a new event

pub async fn cancel_all_active(&self)

Cancel all active interactions

pub async fn get_interaction(&self, id: &str) -> Option<Interaction>

Get an interaction by ID

pub async fn add_task_to_interaction( &self, id: &str, task_id: TaskId, ) -> Result<(), RuntimeError>

Add a task to an interaction

pub async fn find_resume_interaction( &self, event: &Event, ) -> Option<InteractionId>

Find a waiting interaction that can be resumed by this event.

pub async fn append_event_to_interaction( &self, interaction_id: &str, event: Event, ) -> Result<(), RuntimeError>

Append an event to an existing interaction and keep event/interaction IDs consistent.

pub fn subscribe_events(&self) -> Receiver<Event>

Subscribe to the realtime event stream.

pub async fn resume_interaction(&self, id: &str) -> Result<(), RuntimeError>

Mark a waiting interaction active so execution can continue.

pub async fn update_interaction_state( &self, id: &str, state: InteractionState, ) -> Result<(), RuntimeError>

Update an interaction’s state

pub async fn complete_interaction(&self, id: &str) -> Result<(), RuntimeError>

Complete an interaction

pub async fn fail_interaction(&self, id: &str) -> Result<(), RuntimeError>

Fail an interaction

pub async fn active_interaction_ids(&self) -> Vec<InteractionId>

Get all active interaction IDs

pub async fn query_history( &self, limit: usize, ) -> Result<Vec<Event>, RuntimeError>

Query recent events for this thread

pub async fn cleanup_completed(&self)

Cleanup completed interactions