Struct HilComponent 

pub struct HilComponent { /* private fields */ }

Human-in-the-Loop Component.

Manages a queue of approval requests and responds to Human Approve/Reject signals.

Implementations

impl HilComponent

pub fn new() -> Self

Creates a new HIL component.

pub fn submit(&mut self, request: ApprovalRequest) -> String

Submits a new approval request.

Returns the request ID that can be used to check status or cancel.

pub fn has_pending(&self) -> bool

Returns true if there are pending approval requests.

pub fn is_pending(&self, id: &str) -> bool

Returns true if the given request ID is pending.

pub fn get_pending(&self, id: &str) -> Option<&ApprovalRequest>

Returns a reference to a pending request.

pub fn pending_requests(&self) -> Vec<&ApprovalRequest>

Returns all pending requests.

pub fn pending_count(&self) -> usize

Returns the number of pending requests.

pub fn get_resolved( &self, id: &str, ) -> Option<&(ApprovalRequest, ApprovalResult)>

Returns a resolved request by ID.

pub fn resolved_count(&self) -> usize

Returns the number of resolved requests.

pub fn resolve( &mut self, id: &str, result: ApprovalResult, ) -> Result<ApprovalResult, ComponentError>

Resolves an approval request.

Returns Ok(result) if the request was found and resolved, or Err if the request ID was not found.

Trait Implementations

impl Component for HilComponent

fn id(&self) -> &ComponentId

Returns the component’s identifier.

fn subscriptions(&self) -> &[EventCategory]

Returns the event categories this component subscribes to.

fn status(&self) -> Status

Returns the current execution status.

fn on_request(&mut self, request: &Request) -> Result<Value, ComponentError>

Handle an incoming request.

fn on_signal(&mut self, signal: &Signal) -> SignalResponse

Handle an incoming signal.

fn abort(&mut self)

Immediate abort.

fn snapshot(&self) -> Result<ComponentSnapshot, SnapshotError>

Captures the component’s current state as a snapshot.

fn restore(&mut self, snapshot: &ComponentSnapshot) -> Result<(), SnapshotError>

Restores the component’s state from a snapshot.

fn subscription_entries(&self) -> Vec<SubscriptionEntry>

Returns subscription entries with optional operation-level filtering.

fn status_detail(&self) -> Option<StatusDetail>

Returns detailed status information.

fn init(&mut self, _config: &Value) -> Result<(), ComponentError>

Initialize the component with optional configuration.

fn shutdown(&mut self)

Shutdown the component.

fn runtime_hints(&self) -> RuntimeHints

Returns runtime hints for this component.

fn as_packageable(&self) -> Option<&dyn Packageable>

Returns this component as a Packageable if supported.

fn as_packageable_mut(&mut self) -> Option<&mut dyn Packageable>

Returns this component as a mutable Packageable if supported.

fn set_emitter(&mut self, _emitter: Box<dyn Emitter>)

Sets the event emitter for this component.

fn set_child_context(&mut self, _ctx: Box<dyn ChildContext>)

Sets the child context for this component.

impl Default for HilComponent

fn default() -> Self

Returns the “default value” for a type.