Module service

Structs§

AppState
ControlResult: Result of a control signal.
EncodedMessagePage
EnqueueOptions: Optional envelope fields for enqueued mailbox entries.
MailboxService: Event-driven mailbox service that replaces polling-based dispatch.
MessageQueryParams
PreparedHttpRun: Shared HTTP run bootstrap result.

cancel_pending_for_mailbox
check_run_liveness: After an active-run operation (cancel/forward) fails, check if the run exists in the persistent store. Returns RunLookup::ExistsButInactive or RunLookup::NotFound.
current_run_id_for_thread
encode_message_page
forward_dialog_decisions_by_thread
load_background_task: Look up a background task by run_id (RunStore) or entry_id (MailboxStore).
load_message_page
load_run_record: Load the full RunRecord for a given run id.
normalize_optional_id
parse_message_query
require_agent_state_store
resolve_thread_id_from_run: Resolve the thread id that a run belongs to.
start_background_run: Returns (thread_id, run_id, entry_id).
start_http_dialog_run
start_http_run
truncate_thread_at_message: Truncate a stored thread so it includes messages up to and including message_id.
try_cancel_active_or_queued_run_by_id: Cancel by run_id (active run) or entry_id (queued mailbox entry).
try_cancel_active_run_by_id
try_forward_decisions_to_active_run_by_id