Struct Service

pub struct Service { /* private fields */ }

Implementations

impl Service

pub fn new(id: ID) -> Self

Create a new Service

pub fn with_config(self, config: ServiceConfiguration) -> Self

Set the configuration of the service

pub fn with_message_processor( self, message_processor: Arc<MessageProcessor>, ) -> Self

Set the message processor of the service

pub fn config(&self) -> &ServiceConfiguration

get the service configuration

pub fn signal(self) -> Signal

get signal used to shutdown the service NOTE: this method consumes the service!

pub async fn run(&mut self) -> Result<(), ServiceError>

Run the service

pub async fn create_agent( &self, agent_name: &Agent, ) -> Result<AppChannelReceiver, ServiceError>

pub async fn delete_agent(&self, agent_name: &Agent) -> Result<(), ServiceError>

pub fn run_server(&self, config: &ServerConfig) -> Result<(), ServiceError>

pub fn stop_server(&self, endpoint: &str) -> Result<(), ServiceError>

pub async fn connect(&self, config: &ClientConfig) -> Result<u64, ServiceError>

pub fn disconnect(&self, conn: u64) -> Result<(), ServiceError>

pub fn get_connection_id(&self, endpoint: &str) -> Option<u64>

pub async fn subscribe( &self, local_agent: &Agent, agent_type: &AgentType, agent_id: Option<u64>, conn: Option<u64>, ) -> Result<(), ServiceError>

pub async fn unsubscribe( &self, local_agent: &Agent, agent_type: &AgentType, agent_id: Option<u64>, conn: Option<u64>, ) -> Result<(), ServiceError>

pub async fn set_route( &self, local_agent: &Agent, agent_type: &AgentType, agent_id: Option<u64>, conn: u64, ) -> Result<(), ServiceError>

pub async fn remove_route( &self, local_agent: &Agent, agent_type: &AgentType, agent_id: Option<u64>, conn: u64, ) -> Result<(), ServiceError>

pub async fn publish_to( &self, source: &Agent, session_info: Info, agent_type: &AgentType, agent_id: Option<u64>, forward_to: u64, blob: Vec<u8>, ) -> Result<(), ServiceError>

pub async fn publish( &self, source: &Agent, session_info: Info, agent_type: &AgentType, agent_id: Option<u64>, blob: Vec<u8>, ) -> Result<(), ServiceError>

pub async fn publish_with_flags( &self, source: &Agent, session_info: Info, agent_type: &AgentType, agent_id: Option<u64>, flags: AgpHeaderFlags, blob: Vec<u8>, ) -> Result<(), ServiceError>

pub async fn create_session( &self, agent: &Agent, session_config: SessionConfig, ) -> Result<Info, ServiceError>

Create a new session

pub async fn set_session_config( &self, agent: &Agent, session_config: &SessionConfig, session_id: Option<Id>, ) -> Result<(), ServiceError>

Set config for a session

pub async fn get_session_config( &self, agent: &Agent, session_id: Id, ) -> Result<SessionConfig, ServiceError>

Get config for a session

pub async fn get_default_session_config( &self, agent: &Agent, session_type: SessionType, ) -> Result<SessionConfig, ServiceError>

Get default session config

pub async fn delete_session( &self, agent: &Agent, session_id: Id, ) -> Result<(), ServiceError>

delete a session

Trait Implementations

impl Component for Service

fn identifier(&self) -> &ID

async fn start(&mut self) -> Result<(), ComponentError>

impl Debug for Service

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

Formats the value using the given formatter.