Struct NetworkServiceHandle

pub struct NetworkServiceHandle<K: KeyType> {
    pub local_peer_id: PeerId,
    pub blueprint_protocol_name: Arc<str>,
    pub local_signing_key: K::Secret,
    pub sender: NetworkSender<K>,
    pub receiver: NetworkReceiver,
    pub peer_manager: Arc<PeerManager<K>>,
    pub local_verification_key: Option<VerificationIdentifierKey<K>>,
}

Combined handle for the network service

Fields

local_peer_id: PeerId

blueprint_protocol_name: Arc<str>

local_signing_key: K::Secret

sender: NetworkSender<K>

receiver: NetworkReceiver

peer_manager: Arc<PeerManager<K>>

local_verification_key: Option<VerificationIdentifierKey<K>>

The local verification key used to identify this node in the whitelist

Implementations

impl<K: KeyType> NetworkServiceHandle<K>

pub fn new( local_peer_id: PeerId, blueprint_protocol_name: String, local_signing_key: K::Secret, peer_manager: Arc<PeerManager<K>>, network_message_sender: Sender<NetworkCommandMessage<K>>, protocol_message_receiver: Receiver<ProtocolMessage>, ) -> Self

pub fn next_protocol_message(&mut self) -> Option<ProtocolMessage>

pub fn peers(&self) -> Vec<PeerId>

pub fn peer_info(&self, peer_id: &PeerId) -> Option<PeerInfo>

pub fn send( &self, routing: MessageRouting, message: impl Into<Vec<u8>>, ) -> Result<(), String>

Send a message

Errors

See crossbeam_channel::Sender::send

pub fn send_network_message( &self, message: NetworkCommandMessage<K>, ) -> Result<(), String>

Send a network message

Errors

See crossbeam_channel::Sender::send

pub fn get_listen_addr(&self) -> Option<Multiaddr>

pub fn get_participant_id(&self) -> Option<usize>

Get the participant ID (index) of this node in the whitelisted keys

This returns the position of this node’s verification key in the whitelist, which can be used as a participant identifier.

Returns

Returns the index in the whitelist if found, None otherwise

pub fn split(self) -> (NetworkSender<K>, NetworkReceiver)

Split the handle into separate sender and receiver

Trait Implementations

impl<K: KeyType> Clone for NetworkServiceHandle<K>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.