Struct ExternalStoreRuntime 

pub struct ExternalStoreRuntime { /* private fields */ }

A thread whose messages the app owns.

Implementations

impl ExternalStoreRuntime

pub fn new(store: impl ExternalStore + 'static) -> Self

A runtime over store, with no messages yet.

pub fn subscribe(&self, callback: impl Fn() + 'static) -> Subscription

Called after every change. Drop the guard to unsubscribe.

pub fn set_messages<M: Into<Arc<ThreadMessage>>>( &self, messages: impl IntoIterator<Item = M>, )

The app’s current messages as a linear history (messages). Messages equal to what is already shown keep their Arc.

pub fn set_repository(&self, exported: ExportedRepository)

The app’s messages with branches (messageRepository).

pub fn set_running(&self, running: bool)

Tell the runtime whether the app is generating a response.

pub fn set_disabled(&self, disabled: bool)

Disable sending (for example while the app is offline).

Trait Implementations

impl Clone for ExternalStoreRuntime

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ThreadRuntime for ExternalStoreRuntime

fn messages(&self) -> Arc<[Arc<ThreadMessage>]>

The selected branch, root first.

fn message(&self, id: &MessageId) -> Result<MessageEntry, RuntimeError>

A message and its position, by id.

fn is_running(&self) -> bool

Whether a run is in progress.

fn capabilities(&self) -> RuntimeCapabilities

What the UI may offer for this thread.

fn branches(&self, id: &MessageId) -> Result<Vec<MessageId>, RuntimeError>

The message and its siblings.

fn branch_position( &self, id: &MessageId, ) -> Result<(usize, usize), RuntimeError>

(position, count) of the message among its siblings, 1-based. The default builds branches; runtimes override it to avoid the allocation, which a UI pays once per message per update.

fn switch_to_branch(&self, id: &MessageId) -> Result<(), RuntimeError>

Select the branch containing id.

fn append(&self, message: AppendMessage) -> Result<RunFuture, RuntimeError>

Add a message; a user message answers it (see AppendMessage).

fn reload(&self, config: StartRunConfig) -> Result<RunFuture, RuntimeError>

Answer parent_id again (regenerate).

fn cancel_run(&self)

Stop the run in progress, if any.

fn add_tool_result( &self, result: ToolResult, ) -> Result<Option<RunFuture>, RuntimeError>

Answer a tool call; may resume the run, which is then returned to spawn.

fn respond_to_tool_approval( &self, message_id: &MessageId, approval_id: &str, approved: bool, reason: Option<String>, ) -> Result<Option<RunFuture>, RuntimeError>

Approve or deny a pending tool approval; may resume the run, which is then returned to spawn.

fn submit_feedback( &self, id: &MessageId, feedback: Option<SubmittedFeedback>, ) -> Result<(), RuntimeError>

None clears feedback.

fn composer(&self) -> Composer

The composer for the next message.

fn begin_edit(&self, id: &MessageId) -> Result<Composer, RuntimeError>

Start editing a message and return its composer.

fn edit_composer(&self, id: &MessageId) -> Option<Composer>

The composer of a message being edited, if any.

fn subscribe_dyn(&self, callback: Box<dyn Fn()>) -> Subscription

Called after every change; drop the guard to unsubscribe.

fn export(&self) -> ExportedRepository

Persisted messages and the selected head.

fn import(&self, exported: ExportedRepository) -> Result<(), RuntimeError>

Load history.

fn structure_version(&self) -> Option<u64>

A number that changes whenever branches or the selected path change, but not when a message is updated in place. While it is unchanged a UI may keep every message’s branch_position. None (the default) means unknown: positions must be read again.

fn message_changes_since(&self, _version: Option<u64>) -> Option<MessageChanges>

Changed selected-message indices since a consumer’s last version. None (the default) means this runtime does not track changes: scan messages. A supported runtime returns a current version even when the journal requires a full read. Changes must cover every selected message update and be valid for the current messages() snapshot; versions are local to this runtime. Consumers must still refresh when running state or capabilities change.