Struct snarkos_node_router::Cache

pub struct Cache<N: Network> { /* private fields */ }

Implementations

impl<N: Network> Cache<N>

pub fn new() -> Self

Initializes a new instance of the cache.

impl<N: Network> Cache<N>

pub fn insert_inbound_connection( &self, peer_ip: IpAddr, interval_in_secs: i64 ) -> usize

Inserts a new timestamp for the given peer connection, returning the number of recent connection requests.

pub fn insert_inbound_message( &self, peer_ip: SocketAddr, interval_in_secs: i64 ) -> usize

Inserts a new timestamp for the given peer message, returning the number of recent messages.

pub fn insert_inbound_puzzle_request(&self, peer_ip: SocketAddr) -> usize

Inserts a new timestamp for the given peer IP, returning the number of recent requests.

pub fn insert_inbound_solution( &self, peer_ip: SocketAddr, solution: PuzzleCommitment<N> ) -> Option<OffsetDateTime>

Inserts a solution commitment into the cache, returning the previously seen timestamp if it existed.

pub fn insert_inbound_transaction( &self, peer_ip: SocketAddr, transaction: N::TransactionID ) -> Option<OffsetDateTime>

Inserts a transaction ID into the cache, returning the previously seen timestamp if it existed.

impl<N: Network> Cache<N>

pub fn contains_outbound_block_request( &self, peer_ip: &SocketAddr, request: &BlockRequest ) -> bool

Returns true if the cache contains the block request for the given peer.

pub fn insert_outbound_block_request( &self, peer_ip: SocketAddr, request: BlockRequest ) -> usize

Inserts the block request for the given peer IP, returning the number of recent requests.

pub fn remove_outbound_block_request( &self, peer_ip: SocketAddr, request: &BlockRequest ) -> bool

Removes the block request for the given peer IP, returning true if the request was present.

pub fn contains_outbound_puzzle_request(&self, peer_ip: &SocketAddr) -> bool

Returns true if the cache contains a puzzle request from the given peer.

pub fn increment_outbound_puzzle_requests(&self, peer_ip: SocketAddr) -> u16

Increment the peer IP’s number of puzzle requests, returning the updated number of puzzle requests.

pub fn decrement_outbound_puzzle_requests(&self, peer_ip: SocketAddr) -> u16

Decrement the peer IP’s number of puzzle requests, returning the updated number of puzzle requests.

pub fn insert_outbound_solution( &self, peer_ip: SocketAddr, solution: PuzzleCommitment<N> ) -> Option<OffsetDateTime>

Inserts a solution commitment into the cache, returning the previously seen timestamp if it existed.

pub fn insert_outbound_transaction( &self, peer_ip: SocketAddr, transaction: N::TransactionID ) -> Option<OffsetDateTime>

Inserts a transaction ID into the cache, returning the previously seen timestamp if it existed.

Trait Implementations

impl<N: Debug + Network> Debug for Cache<N>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<N: Network> Default for Cache<N>

fn default() -> Self

Initializes a new instance of the cache.