Struct InterruptableRunner 

pub struct InterruptableRunner { /* private fields */ }

Interruptable execution handler

Implementations

impl InterruptableRunner

pub fn new() -> Self

pub fn with_approval_policy<P: ApprovalPolicy + 'static>( self, policy: P, ) -> Self

Set the approval policy for this runner

pub fn with_approval_policy_arc(self, policy: Arc<dyn ApprovalPolicy>) -> Self

Set the approval policy from an Arc

pub fn check_plan_approval(&self, plan: &Value) -> Option<String>

Check if a plan requires approval based on the configured policy Returns the approval reason if approval is required, None otherwise

pub fn requires_approval(&self, plan: &Value) -> bool

Check if a plan requires approval (boolean)

pub fn policy_name(&self) -> Option<&str>

Get the approval policy name (for logging)

pub fn execution_id(&self) -> &ExecutionId

Get the execution ID

pub fn emitter(&self) -> &EventEmitter

pub fn decision_sender(&self) -> Sender<InterruptDecision>

Get the decision sender (for external use to send decisions)

pub async fn approve(&self)

Send approval decision

pub async fn reject(&self, reason: Option<String>)

Send rejection decision

pub async fn request_approval_if_needed(&mut self, plan: &Value) -> Result<bool>

Request approval if the policy requires it

This combines policy check and approval request into a single method. Returns Ok(true) if:

• No approval policy is set
• Policy doesn’t require approval for this plan
• Approval is requested and granted

Returns Ok(false) if approval is rejected. Returns Err if there’s a communication error.

pub async fn request_approval(&mut self, plan: Value) -> Result<bool>

Request approval and wait for decision

Trait Implementations

impl Default for InterruptableRunner

fn default() -> Self

Returns the “default value” for a type.