Struct everscale_network::AdnlNode

pub struct AdnlNode { /* private fields */ }

Unreliable UDP transport layer

Implementations

impl AdnlNode

pub fn new<T>(
    socket_addr: T,
    keystore: Keystore,
    options: AdnlNodeOptions,
    peer_filter: Option<Arc<dyn AdnlPeerFilter>>
) -> Arc<Self> where
    T: Into<PackedSocketAddr>, 

Create new ADNL node on the specified address

pub fn options(&self) -> &AdnlNodeOptions

ADNL node options

pub fn metrics(&self) -> AdnlNodeMetrics

Instant metrics

pub fn add_message_subscriber(
    &self,
    message_subscriber: Arc<dyn MessageSubscriber>
) -> Result<()>

pub fn add_query_subscriber(
    &self,
    query_subscriber: Arc<dyn QuerySubscriber>
) -> Result<()>

pub fn start(self: &Arc<Self>) -> Result<()>

Starts listening for incoming packets

pub fn shutdown(&self)

Stops all spawned listeners

pub fn compute_query_timeout(&self, roundtrip: Option<u64>) -> u64

Computes ADNL query timeout, based on the roundtrip and the configured options

pub fn socket_addr(&self) -> PackedSocketAddr

Socket address of the node

pub fn start_time(&self) -> u32

Node start timestamp

pub fn build_address_list(&self) -> AddressList

Builds new address list for the current ADNL node with no expiration date

pub fn key_by_id(
    &self,
    id: &AdnlNodeIdShort
) -> Result<&Arc<StoredAdnlNodeKey>, KeystoreError>

Searches for the stored ADNL key by it’s short id

See AdnlNode::key_by_tag

pub fn key_by_tag(
    &self,
    tag: usize
) -> Result<&Arc<StoredAdnlNodeKey>, KeystoreError>

Searches for the stored ADNL key by it’s tag

See AdnlNode::key_by_id

pub fn add_peer(
    &self,
    ctx: NewPeerContext,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort,
    peer_ip_address: PackedSocketAddr,
    peer_full_id: AdnlNodeIdFull
) -> Result<bool>

Adds new remote peer. Returns whether the peer was added

See AdnlNode::remove_peer

pub fn remove_peer(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort
) -> Result<bool>

Removes remote peer.

NOTE: This method will return an error if there is no peers table for the specified local id.

See AdnlNode::add_peer

pub fn get_peer_ip(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort
) -> Option<PackedSocketAddr>

Searches for remote peer ip in the known peers

pub async fn query<Q, A>(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort,
    query: Q,
    timeout: Option<u64>
) -> Result<Option<A>> where
    Q: TlWrite,
    for<'a> A: TlRead<'a, Repr = Boxed> + 'static, 

ADNL query without prefix to the remote peer.

NOTE: In case of timeout returns Ok(None)

pub async fn query_with_prefix<Q, A>(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort,
    prefix: &[u8],
    query: Q,
    timeout: Option<u64>
) -> Result<Option<A>> where
    Q: TlWrite,
    for<'a> A: TlRead<'a, Repr = Boxed> + 'static, 

ADNL query with prefix to the remote peer

NOTE: In case of timeout returns Ok(None)

pub async fn query_raw(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort,
    query: Bytes,
    timeout: Option<u64>
) -> Result<Option<Vec<u8>>>

ADNL query to the remote peer

NOTE: In case of timeout returns Ok(None)

pub fn send_custom_message(
    &self,
    local_id: &AdnlNodeIdShort,
    peer_id: &AdnlNodeIdShort,
    data: &[u8]
) -> Result<()>

Trait Implementations

impl Drop for AdnlNode

fn drop(&mut self)

Executes the destructor for this type.