Struct Broker 

pub struct Broker { /* private fields */ }

Implementations

impl Broker

pub fn new() -> Self

pub fn create(opts: &Options) -> Self

pub fn stats(&self) -> BrokerStats

pub fn info<'a>() -> BrokerInfo<'a>

pub fn set_queue_size(&mut self, queue_size: usize)

pub async fn set_core_rpc_client(&self, client: RpcClient)

pub async fn register_client(&self, name: &str) -> Result<Client, Error>

pub async fn register_secondary_for( &self, client: &Client, ) -> Result<Client, Error>

Panics

Will panic if the client’s secondaries mutex is poisoned

pub async fn unregister_client(&self, client: &Client)

pub fn force_disconnect(&self, name: &str) -> Result<(), Error>

Force disconnect a client

Errors

NotSupported - if attempted to disconnect an internal client NotRegistered - if a client is not registered (may be usually safely omitted)

pub async fn spawn_unix_server( &mut self, path: &str, config: ServerConfig, ) -> Result<(), Error>

pub async fn spawn_tcp_server( &mut self, path: &str, config: ServerConfig, ) -> Result<(), Error>

pub async fn spawn_websocket_server( &mut self, path: &str, config: ServerConfig, tls_config: Option<Arc<ServerConfig>>, ) -> Result<(), Error>

Spawn a websocket server at the given path (host:port)

pub fn spawn_server_connection( &mut self, stream: UnixStream, config: ServerConfig, ) -> Result<(), Error>

Trait Implementations

impl Default for Broker

fn default() -> Self

Returns the “default value” for a type.

impl Drop for Broker

fn drop(&mut self)

Executes the destructor for this type.