Struct BridgeService 

pub struct BridgeService {
    pub connected_peers: Arc<RwLock<HashMap<String, ConnectedPeer>>>,
    /* private fields */
}

Fields

connected_peers: Arc<RwLock<HashMap<String, ConnectedPeer>>>

Implementations

impl BridgeService

pub fn new( node: Arc<IrohNode>, data_dir: PathBuf, shutdown: Sender<()>, ) -> Result<Self>

Create a new bridge service.

Errors

Returns an error if the blocklist or doc map cannot be loaded.

pub const fn node(&self) -> &Arc<IrohNode>

pub fn shutdown_receiver(&self) -> Receiver<()>

pub fn is_blocked(&self, node_id: &str) -> bool

pub async fn get_or_create_collection( &self, collection_id: &str, ) -> Result<NamespaceId>

Get or create a doc namespace for a collection_id.

Errors

Returns an error if the namespace cannot be created or opened.

pub async fn get_collection(&self, collection_id: &str) -> Result<NamespaceId>

Get an existing collection namespace.

Errors

Returns an error if the namespace cannot be opened.

pub async fn insert_collection( &self, collection_id: &str, namespace: NamespaceId, )

Insert a doc namespace for a collection_id (used by import_collection).

pub async fn subscribe_gossip( &self, topic_str: &str, with_discovery: bool, ) -> Result<GossipSender>

Subscribe to a gossip topic.

Errors

Returns an error if subscription fails.

pub async fn leave_gossip(&self, topic_str: &str)

Leave a gossip topic.

pub async fn send_gossip(&self, topic_str: &str, message: &[u8]) -> Result<()>

Send a gossip message to a topic.

Errors

Returns an error if the topic is not subscribed or publishing fails.

pub fn add_peer(&self, node_id: String, first_seen: u64, last_seen: u64)

Add a connected peer.

pub fn block_peer(&self, node_id: &str) -> Result<()>

Block a peer.

Errors

Returns an error if the blocklist file cannot be written.

pub fn unblock_peer(&self, node_id: &str) -> Result<()>

Unblock a peer.

Errors

Returns an error if the blocklist file cannot be written.

pub fn get_blocked_peers(&self) -> Vec<String>

Get blocked peers.

Trait Implementations

impl Clone for BridgeService

fn clone(&self) -> BridgeService

Returns a duplicate of the value.

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

Performs copy-assignment from source.