Struct FormationClient 

pub struct FormationClient { /* private fields */ }

Implementations

impl FormationClient

pub fn new(config: FormationConfig) -> Result<Self>

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

pub async fn get_status(&self) -> Result<Value>

pub async fn get_config(&self) -> Result<Value>

pub async fn get_formation_info(&self) -> Result<Value>

pub async fn get_agents(&self) -> Result<Value>

pub async fn get_agent(&self, agent_id: &str) -> Result<Value>

pub async fn get_mcp_servers(&self) -> Result<Value>

pub async fn get_mcp_server(&self, server_id: &str) -> Result<Value>

pub async fn get_mcp_tools(&self) -> Result<Value>

pub async fn get_secrets(&self) -> Result<Value>

pub async fn get_secret(&self, key: &str) -> Result<Value>

pub async fn set_secret(&self, key: &str, value: &str) -> Result<Value>

pub async fn delete_secret(&self, key: &str) -> Result<Value>

pub async fn chat(&self, payload: Value, user_id: Option<&str>) -> Result<Value>

pub fn chat_stream<'a>( &'a self, payload: Value, user_id: Option<&'a str>, ) -> impl Stream<Item = Result<SseEvent>> + 'a

pub async fn audio_chat( &self, payload: Value, user_id: Option<&str>, ) -> Result<Value>

pub fn audio_chat_stream<'a>( &'a self, payload: Value, user_id: Option<&'a str>, ) -> impl Stream<Item = Result<SseEvent>> + 'a

pub async fn get_sessions( &self, user_id: &str, limit: Option<u32>, ) -> Result<Value>

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

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

pub async fn restore_session( &self, session_id: &str, user_id: &str, messages: Value, ) -> Result<Value>

pub async fn get_requests(&self, user_id: &str) -> Result<Value>

pub async fn get_request_status( &self, request_id: &str, user_id: &str, ) -> Result<Value>

pub async fn cancel_request( &self, request_id: &str, user_id: &str, ) -> Result<Value>

pub async fn get_memory_config(&self) -> Result<Value>

pub async fn get_memories( &self, user_id: &str, limit: Option<u32>, ) -> Result<Value>

pub async fn add_memory( &self, user_id: &str, memory_type: &str, detail: &str, ) -> Result<Value>

pub async fn delete_memory( &self, user_id: &str, memory_id: &str, ) -> Result<Value>

pub async fn get_user_buffer(&self, user_id: &str) -> Result<Value>

pub async fn clear_user_buffer(&self, user_id: &str) -> Result<Value>

pub async fn clear_all_buffers(&self) -> Result<Value>

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

pub async fn get_buffer_stats(&self) -> Result<Value>

pub async fn get_scheduler_config(&self) -> Result<Value>

pub async fn get_scheduler_jobs(&self, user_id: &str) -> Result<Value>

pub async fn get_scheduler_job(&self, job_id: &str) -> Result<Value>

pub async fn create_scheduler_job( &self, job_type: &str, schedule: &str, message: &str, user_id: &str, ) -> Result<Value>

pub async fn delete_scheduler_job(&self, job_id: &str) -> Result<Value>

pub async fn update_scheduler_job( &self, job_id: &str, updates: Value, ) -> Result<Value>

pub async fn pause_scheduler_job(&self, job_id: &str) -> Result<Value>

pub async fn resume_scheduler_job(&self, job_id: &str) -> Result<Value>

pub async fn get_async_config(&self) -> Result<Value>

pub async fn get_a2a_config(&self) -> Result<Value>

pub async fn get_logging_config(&self) -> Result<Value>

pub async fn get_logging_destinations(&self) -> Result<Value>

pub async fn get_overlord_config(&self) -> Result<Value>

pub async fn get_overlord_soul(&self) -> Result<Value>

pub async fn get_llm_settings(&self) -> Result<Value>

pub async fn get_triggers(&self) -> Result<Value>

pub async fn get_trigger(&self, name: &str) -> Result<Value>

pub async fn fire_trigger( &self, name: &str, data: Value, is_async: bool, user_id: Option<&str>, ) -> Result<Value>

pub async fn get_sops(&self) -> Result<Value>

pub async fn get_sop(&self, name: &str) -> Result<Value>

pub async fn get_audit_log(&self) -> Result<Value>

pub async fn clear_audit_log(&self) -> Result<Value>

pub async fn list_credential_services(&self) -> Result<Value>

pub async fn list_credentials(&self, user_id: &str) -> Result<Value>

pub async fn get_credential( &self, credential_id: &str, user_id: &str, ) -> Result<Value>

pub async fn create_credential( &self, user_id: &str, payload: Value, ) -> Result<Value>

pub async fn delete_credential( &self, credential_id: &str, user_id: &str, ) -> Result<Value>

pub async fn get_user_identifiers(&self, user_id: &str) -> Result<Value>

pub async fn link_user_identifier( &self, muxi_user_id: &str, identifiers: Value, ) -> Result<Value>

pub async fn unlink_user_identifier(&self, identifier: &str) -> Result<Value>

pub fn stream_events<'a>( &'a self, user_id: &'a str, ) -> impl Stream<Item = Result<SseEvent>> + 'a

pub fn stream_logs<'a>( &'a self, filters: Option<Vec<(&'a str, String)>>, ) -> impl Stream<Item = Result<SseEvent>> + 'a

pub async fn resolve_user( &self, identifier: &str, create_user: bool, ) -> Result<Value>

Trait Implementations

impl Clone for FormationClient

fn clone(&self) -> FormationClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.