Struct DurableThread 

pub struct DurableThread { /* private fields */ }

Implementations

impl DurableThread

pub fn recover( session: Session, kmap: Arc<K1AccessKmap>, ) -> Result<Self, String>

pub fn boxes(&self) -> &[ChatBox]

pub fn status(&self) -> Status

pub fn accept_box( &mut self, box_type: String, contents: String, hidden_type: String, hidden_contents: String, ) -> Result<(), String>

pub fn accept_user( &mut self, context: AccessContext, profile_id: ProfileId, policy: AccessPolicy, contents: String, ) -> Result<(), TransitionError>

pub fn accept_return( &mut self, id: ToolCallId, result: Result<String, String>, ) -> Result<(), String>

pub fn prepare_stage( &mut self, job: u64, text: String, boxes: Vec<BoxValue>, ) -> Result<Vec<PreparedCall>, String>

pub fn launch_action( &mut self, name: &str, arguments: &str, ) -> Result<String, String>

pub fn accept_tool_message( &mut self, id: ToolCallId, contents: String, ) -> Result<(), String>

pub fn accept_tool_return( &mut self, id: ToolCallId, result: Result<String, String>, ) -> Result<(), String>

pub fn accept_tool_return_v2( &mut self, id: ToolCallId, result: Result<String, String>, metadata_type: String, metadata_contents: String, ) -> Result<(), String>

pub fn prepare_steer( &mut self, job: u64, ) -> Result<Option<PreparedSteer>, String>

pub fn prepared_input(&self, prepared: &PreparedSteer) -> Result<String, String>

pub fn commit_steer(&mut self, prepared: PreparedSteer) -> Result<(), String>

pub fn begin_input(&mut self) -> Result<Option<(u64, String)>, String>

pub fn complete( &mut self, job: u64, output: ShimOutput<BoxValue>, ) -> Result<bool, String>

pub fn fail(&mut self, job: u64, error: String, restartable: bool)

pub fn restart( &mut self, context: AccessContext, profile_id: ProfileId, policy: AccessPolicy, ) -> Result<(), TransitionError>

pub fn clear_authorization(&mut self)