Struct Context 

pub struct Context { /* private fields */ }

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: &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: &PublicKey, 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: &PublicKey) -> Option<Anr>

Get ANR by public key bytes

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

Get all handshaked ANRs (validators)

pub fn get_entries_by_height(&self, height: u64) -> Result<Vec<Entry>, Error>

Get entries by height from fabric

pub fn get_temporal_entry(&self) -> Result<Option<Entry>, Error>

Get temporal entry from fabric

pub fn get_trainers_for_height(&self, height: u64) -> Option<Vec<PublicKey>>

Get trainers for height

pub fn get_wallet_balance(&self, public_key: &PublicKey, symbol: &[u8]) -> i128

Get wallet balance - wrapper around fabric.chain_balance_symbol

pub fn get_contract_state( &self, contract: &PublicKey, key: &[u8], ) -> Option<Vec<u8>>

Get contract state from CF_CONTRACTSTATE

pub fn get_chain_diff_bits(&self) -> u32

Get chain difficulty bits

pub fn get_chain_total_sols(&self) -> i128

Get total sols

pub fn get_all_wallet_balances( &self, public_key: &PublicKey, ) -> Vec<(Vec<u8>, i128)>

Get all balances for a wallet using prefix scan

pub fn get_entry_by_hash(&self, hash: &Hash) -> Option<Entry>

Get entry by hash

pub fn db_get(&self, cf: &str, key: &[u8]) -> Result<Option<Vec<u8>>, Error>

Get value from database column family

pub fn db_iter_prefix( &self, cf: &str, prefix: &[u8], ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, Error>

Iterate over keys with prefix in database column family

pub async fn parse_udp(&self, buf: &[u8], src: Ipv4Addr) -> Option<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: 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