Struct RainEngineClient 

pub struct RainEngineClient { /* private fields */ }

A client for the RainEngine Gateway.

Provides strongly-typed async methods for every ingress route exposed by the runtime HTTP server.

Implementations

impl RainEngineClient

pub fn new(base_url: &str) -> Result<Self, ClientError>

Creates a new client connecting to the given base URL.

pub fn with_headers( base_url: &str, headers: HeaderMap, ) -> Result<Self, ClientError>

Creates a new client with custom request headers (e.g. for future auth).

pub async fn send_human_input( &self, actor_id: &str, session_id: &str, content: &str, ) -> Result<RuntimeRunResult, ClientError>

Sends human input to a specific actor. Route: POST /triggers/human/{actor_id}

pub async fn send_human_input_request( &self, actor_id: &str, request: &HumanInputIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends a fully-specified human input request. Route: POST /triggers/human/{actor_id}

pub async fn submit_approval( &self, session_id: &str, resume_token: &str, decision: ApprovalDecision, metadata: Value, ) -> Result<RuntimeRunResult, ClientError>

Submits an approval decision. Route: POST /triggers/approval

pub async fn submit_approval_request( &self, request: &ApprovalIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Submits a fully-specified approval request. Route: POST /triggers/approval

pub async fn send_webhook( &self, source: &str, request: &WebhookIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends a webhook event from the given source. Route: POST /triggers/webhook/{source}

pub async fn send_external_event( &self, source: &str, request: &EventIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends an external event from the given source. Route: POST /triggers/external/{source}

pub async fn send_system_observation( &self, source: &str, request: &EventIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends a system observation from the given source. Route: POST /triggers/system/{source}

pub async fn send_scheduled_wake( &self, session_id: &str, wake_id: &str, due_at: i64, reason: &str, ) -> Result<RuntimeRunResult, ClientError>

Sends a scheduled wake event with simple args. Route: POST /triggers/wake

pub async fn send_scheduled_wake_request( &self, request: &ScheduledWakeIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends a fully-specified scheduled wake request. Route: POST /triggers/wake

pub async fn send_delegation_result( &self, request: &DelegationResultIngressRequest, ) -> Result<RuntimeRunResult, ClientError>

Sends a delegation result back to the engine. Route: POST /triggers/delegation-result

pub async fn health(&self) -> Result<Value, ClientError>

Check the runtime health. Route: GET /health

pub async fn list_sessions(&self) -> Result<Value, ClientError>

List all sessions. Route: GET /sessions

pub async fn get_session(&self, session_id: &str) -> Result<Value, ClientError>

Get a session snapshot by ID. Route: GET /sessions/{session_id}

pub async fn list_records( &self, session_id: &str, offset: usize, limit: usize, ) -> Result<Value, ClientError>

List records in a session with pagination. Route: GET /sessions/{session_id}/records

Trait Implementations

impl Clone for RainEngineClient

fn clone(&self) -> RainEngineClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RainEngineClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.