Struct AxonFlowClient 

pub struct AxonFlowClient { /* private fields */ }

Implementations

impl AxonFlowClient

pub fn new(config: AxonFlowConfig) -> Result<Self, AxonFlowError>

pub async fn proxy_llm_call( &self, user_token: &str, query: &str, request_type: &str, context: HashMap<String, Value>, ) -> Result<ClientResponse, AxonFlowError>

pub async fn list_connectors( &self, ) -> Result<Vec<ConnectorMetadata>, AxonFlowError>

pub async fn get_connector( &self, connector_id: &str, ) -> Result<ConnectorMetadata, AxonFlowError>

pub async fn get_connector_health( &self, connector_id: &str, ) -> Result<ConnectorHealthStatus, AxonFlowError>

pub async fn install_connector( &self, req: ConnectorInstallRequest, ) -> Result<(), AxonFlowError>

pub async fn query_connector( &self, user_token: &str, connector_name: &str, query: &str, params: HashMap<String, Value>, ) -> Result<ConnectorResponse, AxonFlowError>

pub async fn generate_plan( &self, query: &str, domain: &str, user_token: Option<&str>, ) -> Result<PlanResponse, AxonFlowError>

pub async fn execute_plan( &self, plan_id: &str, user_token: Option<&str>, ) -> Result<PlanExecutionResponse, AxonFlowError>

pub async fn get_plan_status( &self, plan_id: &str, ) -> Result<PlanExecutionResponse, AxonFlowError>

pub async fn cancel_plan( &self, plan_id: &str, reason: Option<&str>, ) -> Result<CancelPlanResponse, AxonFlowError>

pub async fn audit_llm_call( &self, req: &AuditRequest, ) -> Result<AuditResult, AxonFlowError>

Trait Implementations

impl Clone for AxonFlowClient

fn clone(&self) -> AxonFlowClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.