Struct ASKit 

pub struct ASKit { /* private fields */ }

Implementations

impl ASKit

pub fn new() -> Self

pub fn init() -> Result<Self, AgentError>

pub async fn ready(&self) -> Result<(), AgentError>

pub fn quit(&self)

pub fn register_agent(&self, def: AgentDefinition)

pub fn get_agent_definitions(&self) -> AgentDefinitions

pub fn get_agent_definition(&self, def_name: &str) -> Option<AgentDefinition>

pub fn get_agent_default_configs( &self, def_name: &str, ) -> Option<AgentDefaultConfigs>

pub fn get_agent_flows(&self) -> AgentFlows

pub fn new_agent_flow(&self, name: &str) -> Result<AgentFlow, AgentError>

pub fn rename_agent_flow( &self, old_name: &str, new_name: &str, ) -> Result<String, AgentError>

pub fn unique_flow_name(&self, name: &str) -> String

pub fn add_agent_flow(&self, agent_flow: &AgentFlow) -> Result<(), AgentError>

pub async fn remove_agent_flow(&self, flow_name: &str) -> Result<(), AgentError>

pub fn insert_agent_flow(&self, flow: AgentFlow) -> Result<(), AgentError>

pub fn new_agent_flow_node( &self, def_name: &str, ) -> Result<AgentFlowNode, AgentError>

pub fn add_agent_flow_node( &self, flow_name: &str, node: &AgentFlowNode, ) -> Result<(), AgentError>

pub fn add_agent_flow_edge( &self, flow_name: &str, edge: &AgentFlowEdge, ) -> Result<(), AgentError>

pub async fn remove_agent_flow_node( &self, flow_name: &str, node_id: &str, ) -> Result<(), AgentError>

pub fn remove_agent_flow_edge( &self, flow_name: &str, edge_id: &str, ) -> Result<(), AgentError>

pub fn copy_sub_flow( &self, nodes: &Vec<AgentFlowNode>, edges: &Vec<AgentFlowEdge>, ) -> (Vec<AgentFlowNode>, Vec<AgentFlowEdge>)

pub async fn start_agent_flow(&self, name: &str) -> Result<(), AgentError>

pub async fn stop_agent_flow(&self, name: &str) -> Result<(), AgentError>

pub async fn start_agent(&self, agent_id: &str) -> Result<(), AgentError>

pub async fn stop_agent(&self, agent_id: &str) -> Result<(), AgentError>

pub async fn set_agent_configs( &self, agent_id: String, configs: AgentConfigs, ) -> Result<(), AgentError>

pub fn get_global_configs(&self, def_name: &str) -> Option<AgentConfigs>

pub fn set_global_configs(&self, def_name: String, configs: AgentConfigs)

pub fn set_global_configs_map(&self, new_configs_map: AgentConfigsMap)

pub fn get_global_configs_map(&self) -> AgentConfigsMap

pub async fn send_agent_out( &self, agent_id: String, ctx: AgentContext, pin: String, value: AgentValue, ) -> Result<(), AgentError>

pub fn try_send_agent_out( &self, agent_id: String, ctx: AgentContext, pin: String, value: AgentValue, ) -> Result<(), AgentError>

pub fn write_board_value( &self, name: String, value: AgentValue, ) -> Result<(), AgentError>

pub fn subscribe(&self, observer: Box<dyn ASKitObserver + Sync + Send>) -> usize

pub fn unsubscribe(&self, observer_id: usize)

Trait Implementations

impl Clone for ASKit

fn clone(&self) -> ASKit

Returns a duplicate of the value.

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

Performs copy-assignment from source.