Struct Context 

pub struct Context { /* private fields */ }

Runtime container for config, metrics, reassembler, and node state.

Implementations

impl Context

pub async fn with_config_and_socket( config: Config, socket: Arc<dyn UdpSocketExt>, ) -> Result<Arc<Self>, Error>

pub fn get_prometheus_metrics(&self) -> String

pub fn get_json_health(&self) -> Value

pub async fn send_message_to( &self, message: &impl Protocol, dst: Ipv4Addr, ) -> Result<(), Error>

Convenience function to send UDP data with metrics tracking

pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>

Convenience function to receive UDP data with metrics tracking

pub async fn is_peer_handshaked(&self, ip: Ipv4Addr) -> bool

pub async fn get_peers_summary(&self) -> Result<PeersSummary, Error>

pub fn get_softfork_status(&self) -> SoftforkStatus

pub fn get_config(&self) -> &Config

pub fn get_socket(&self) -> Arc<dyn UdpSocketExt>

pub fn get_metrics(&self) -> &Metrics

pub fn get_metrics_snapshot(&self) -> MetricsSnapshot

pub fn get_system_stats(&self) -> SystemStats

pub fn get_uptime(&self) -> String

pub fn inc_tasks(&self)

Add a task to the metrics tracker

pub fn dec_tasks(&self)

Remove a task from the metrics tracker

pub fn get_temporal_height(&self) -> u64

Get temporal height from fabric

pub fn get_rooted_height(&self) -> u64

Get rooted height from fabric

pub async fn get_entries(&self) -> Vec<(u64, u64, u64)>

pub async fn set_peer_handshake_status( &self, ip: Ipv4Addr, status: HandshakeStatus, ) -> Result<(), Error>

Set handshake status for a peer by IP address

pub async fn update_peer_from_anr( &self, ip: Ipv4Addr, pk: &[u8; 48], version: &Ver, status: Option<HandshakeStatus>, )

Update peer information from ANR data

pub async fn get_all_anrs(&self) -> Vec<Anr>

Get all ANRs

pub async fn get_anr_by_pk_b58(&self, pk_b58: &str) -> Option<Anr>

Get ANR by public key (Base58 encoded)

pub async fn get_anr_by_pk(&self, pk: &[u8; 48]) -> Option<Anr>

Get ANR by public key bytes

pub async fn get_validator_anrs(&self) -> Vec<Anr>

Get all handshaked ANRs (validators)

pub async fn parse_udp( &self, buf: &[u8], src: Ipv4Addr, ) -> Option<Box<dyn Protocol>>

Reads UDP datagram and silently does parsing, validation and reassembly If the protocol message is complete, returns Some(Protocol)

pub async fn handle( &self, message: Box<dyn Protocol>, src: Ipv4Addr, ) -> Result<Vec<Instruction>, Error>

pub async fn execute(&self, instruction: Instruction) -> Result<(), Error>

pub async fn execute_inner(&self, instruction: Instruction) -> Result<(), Error>

Handle instruction processing following the Elixir reference implementation