Struct Broker

pub struct Broker { /* private fields */ }

Implementations

impl Broker

pub fn get_server_peer_id(&self) -> DirectPeerId

pub fn set_server_config(&mut self, config: ServerConfig)

pub fn set_listeners( &mut self, listeners: HashMap<String, ListenerInfo>, ) -> (HashMap<String, ListenerInfo>, HashMap<BindAddress, String>)

pub async fn join_shutdown() -> Result<(), ProtocolError>

pub async fn join_shutdown_with_timeout( timeout: Duration, ) -> Result<(), ProtocolError>

Used in tests mostly

pub async fn graceful_shutdown()

pub async fn close_all_connections()

pub async fn probe( &mut self, cnx: Box<dyn IConnect>, ip: IP, port: u16, ) -> Result<Option<PubKey>, ProtocolError>

pub async fn admin<A: Into<ProtocolMessage> + Into<AdminRequestContentV0> + Debug + Sync + Send + 'static>( &mut self, cnx: Box<dyn IConnect>, peer_privk: PrivKey, peer_pubk: PubKey, remote_peer_id: DirectPeerId, user: PubKey, user_priv: PrivKey, addr: BindAddress, request: A, ) -> Result<AdminResponseContentV0, ProtocolError>

pub async fn ext<A: Into<ProtocolMessage> + Into<ExtRequestContentV0> + Debug + Sync + Send + 'static, B: TryFrom<ProtocolMessage, Error = ProtocolError> + Debug + Sync + Send + 'static>( cnx: Box<dyn IConnect>, peer_privk: PrivKey, peer_pubk: PubKey, remote_peer_id: DirectPeerId, url: String, request: A, ) -> Result<B, NgError>

pub async fn connect( &mut self, cnx: Arc<Box<dyn IConnect>>, peer_privk: PrivKey, peer_pubk: PubKey, remote_peer_id: DirectPeerId, config: StartConfig, ) -> Result<(), ProtocolError>

pub async fn request<A: Into<ProtocolMessage> + Debug + Sync + Send + 'static, B: TryFrom<ProtocolMessage, Error = ProtocolError> + Debug + Sync + Send + 'static>( &self, user: &Option<UserId>, remote_peer_id: &Option<DirectPeerId>, msg: A, ) -> Result<SoS<B>, NgError>

pub async fn close_peer_connection( &mut self, peer_id: &DirectPeerId, user: Option<PubKey>, )