Struct everscale_network::overlay::Shard

pub struct Shard { /* private fields */ }

P2P messages distribution layer

Implementations

impl Shard

pub fn options(&self) -> &ShardOptions

Configuration

pub fn metrics(&self) -> ShardMetrics

Instant metrics

pub fn id(&self) -> &IdShort

Short overlay id

pub fn overlay_key(&self) -> &Arc<Key>

Returns local ADNL key for public overlay

pub fn add_public_peer(
    &self,
    adnl: &Node,
    ip_address: PackedSocketAddr,
    node: Node<'_>
) -> Result<Option<NodeIdShort>>

Verifies and adds new peer to the overlay. Returns Some short peer id if new peer was successfully added and None if peer already existed.

See Shard::add_public_peers for multiple peers.

pub fn add_public_peers<'a, I>(
    &self,
    adnl: &Node,
    nodes: I
) -> Result<Vec<NodeIdShort>> where
    I: IntoIterator<Item = (PackedSocketAddr, Node<'a>)>, 

Verifies and adds new peers to the overlay. Returns a list of successfully added peers.

See Shard::add_public_peer for single peer.

pub fn delete_public_peer(&self, peer_id: &NodeIdShort) -> bool

Removes peer from random peers and adds it to ignored peers

pub fn write_cached_peers(&self, amount: usize, dst: &PeersSet)

Fill dst with amount peers from known peers

pub fn query_prefix(&self) -> &[u8]

Serialized proto::rpc::OverlayQuery with own overlay id

pub fn message_prefix(&self) -> &[u8]

Serialized proto::overlay::Message with own overlay id

pub fn send_message(
    &self,
    adnl: &Node,
    peer_id: &NodeIdShort,
    data: &[u8]
) -> Result<()>

Sends direct ADNL message (proto::adnl::Message::Custom) to the given peer.

NOTE: Local id (Shard::overlay_key) will be used as sender

pub async fn adnl_query<Q>(
    &self,
    adnl: &Node,
    peer_id: &NodeIdShort,
    query: Q,
    timeout: Option<u64>
) -> Result<Option<Vec<u8>>> where
    Q: TlWrite, 

Sends ADNL query directly to the given peer. In case of timeout returns Ok(None)

NOTE: Local id (Shard::overlay_key) will be used as sender

pub async fn rldp_query(
    &self,
    rldp: &Node,
    peer_id: &NodeIdShort,
    data: Vec<u8>,
    roundtrip: Option<u64>
) -> Result<(Option<Vec<u8>>, u64)>

Sends RLDP query directly to the given peer. In case of timeout returns Ok((None, max_timeout))

NOTE: Local id (Shard::overlay_key) will be used as sender

pub fn broadcast(
    self: &Arc<Self>,
    adnl: &Arc<Node>,
    data: Vec<u8>,
    source: Option<&Arc<Key>>,
    target: BroadcastTarget
) -> OutgoingBroadcastInfo

Distributes provided message to the neighbours subset.

See broadcast_target_count in ShardOptions

NOTE: If data len is greater than

pub async fn wait_for_broadcast(&self) -> IncomingBroadcastInfo

Waits until the next received broadcast.

NOTE: It is important to keep polling this method because otherwise received broadcasts queue will consume all the memory.

pub fn take_new_peers(&self) -> ReceivedPeersMap

Take received peers map

pub fn sign_local_node(&self) -> NodeOwned

Returns raw signed overlay node

pub async fn exchange_random_peers(
    &self,
    adnl: &Node,
    peer_id: &NodeIdShort,
    existing_peers: &FxDashSet<NodeIdShort>,
    timeout: Option<u64>
) -> Result<Option<Vec<NodeIdShort>>>

Exchanges random peers with the specified peer. Returns Ok(None) in case of timeout