Struct VpnMeshNetwork 

pub struct VpnMeshNetwork {
    pub node_id: String,
    pub config: VpnMeshConfig,
    /* private fields */
}

Fields

node_id: String

config: VpnMeshConfig

Implementations

impl VpnMeshNetwork

pub fn new( node_id: String, config: VpnMeshConfig, bootstrap_urls: Vec<String>, mdns_enabled: bool, _mdns_service_name: &str, peer_timeout_secs: u64, ) -> Result<VpnMeshNetwork, Box<dyn Error>>

Create a new VpnMeshNetwork with the given configuration.

Arguments

• node_id - Unique identifier for this node
• config - VPN mesh configuration
• bootstrap_urls - URLs of bootstrap registry servers for peer discovery
• mdns_enabled - Whether to enable mDNS discovery
• _mdns_service_name - Service name for mDNS registration
• peer_timeout_secs - Timeout for peer communication

Returns

Result with VpnMeshNetwork instance or error

Trait Implementations

impl PeerNetwork for VpnMeshNetwork

fn node_id(&self) -> &String

fn discover_peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerInfo>, TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, VpnMeshNetwork: 'async_trait,

fn broadcast_challenge<'life0, 'life1, 'async_trait>( &'life0 self, challenge: &'life1 Challenge, ) -> Pin<Box<dyn Future<Output = Result<(), TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

fn relay_proof<'life0, 'life1, 'async_trait>( &'life0 self, proof: &'life1 ProofPayload, ) -> Pin<Box<dyn Future<Output = Result<(), TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

fn sync_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<NetworkState, TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, VpnMeshNetwork: 'async_trait,

fn pull_lattice<'life0, 'life1, 'async_trait>( &'life0 self, peer_url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

Pull the hexchain lattice snapshot from a peer by URL. Returns None if the peer is unreachable or returns non-200.

fn push_lattice<'life0, 'life1, 'async_trait>( &'life0 self, snapshot: &'life1 Value, ) -> Pin<Box<dyn Future<Output = Result<usize, TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

Push the local hexchain lattice snapshot to all known peers. Returns count of successful pushes.

fn broadcast_transaction<'life0, 'life1, 'async_trait>( &'life0 self, tx: &'life1 Value, ) -> Pin<Box<dyn Future<Output = Result<(), TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

Broadcast a transaction to all known peers so they can add it to their mempool.

fn register_with_bootstrap<'life0, 'life1, 'async_trait>( &'life0 self, cfg: &'life1 RegistrationConfig, ) -> Pin<Box<dyn Future<Output = Result<(), TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

Register this node with bootstrap registry URL(s). Default is no-op; VpnMeshNetwork overrides with HTTP POST.

fn broadcast_block<'life0, 'life1, 'async_trait>( &'life0 self, proof: &'life1 Value, ) -> Pin<Box<dyn Future<Output = Result<usize, TribeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, VpnMeshNetwork: 'async_trait,

Broadcast a newly produced block to all known peer validators. Returns count of successful broadcasts.