Struct LightningClient 

pub struct LightningClient { /* private fields */ }

QUIC client for sending synapse requests to Bittensor miners.

Manages persistent, authenticated QUIC connections to one or more miners. Each connection is established with a mutual sr25519 handshake; subsequent synapse requests reuse the connection without re-authenticating.

Implementations

impl LightningClient

pub fn new(wallet_hotkey: String) -> Self

Creates a client with default configuration. Panics only if defaults are invalid.

pub fn with_config( wallet_hotkey: String, config: LightningClientConfig, ) -> Result<Self>

Creates a client with the given configuration, validating constraints.

pub fn set_signer(&mut self, signer: Box<dyn Signer>)

Sets the Signer used for handshake authentication. Must be called before initialize_connections.

pub fn set_wallet( &mut self, wallet_name: &str, wallet_path: &str, hotkey_name: &str, ) -> Result<()>

Loads the signer from a Bittensor wallet on disk. Requires the btwallet feature.

pub async fn initialize_connections( &mut self, miners: Vec<QuicAxonInfo>, ) -> Result<()>

Opens QUIC connections and performs sr25519 handshakes with the given miners.

Miners sharing an ip:port are multiplexed over a single QUIC connection. If metagraph is configured, a background monitor is also started.

pub async fn create_endpoint(&mut self) -> Result<()>

Creates the QUIC client endpoint bound to 0.0.0.0:0. Called automatically by initialize_connections; only call directly if you need the endpoint before connecting.

pub async fn query_axon( &self, axon_info: QuicAxonInfo, request: QuicRequest, ) -> Result<QuicResponse>

Sends a synapse request to a miner and waits for the full response.

Transparently reconnects if the underlying QUIC connection has died.

pub async fn query_axon_with_timeout( &self, axon_info: QuicAxonInfo, request: QuicRequest, timeout: Duration, ) -> Result<QuicResponse>

Like query_axon but aborts after timeout.

pub async fn query_axon_stream( &self, axon_info: QuicAxonInfo, request: QuicRequest, ) -> Result<StreamingResponse>

Sends a synapse request and returns a StreamingResponse for incremental chunk reading.

pub async fn update_miner_registry( &self, miners: Vec<QuicAxonInfo>, ) -> Result<()>

Reconciles the active miner set: adds new miners, removes stale ones, and opens/closes QUIC connections as needed.

pub async fn get_connection_stats(&self) -> Result<HashMap<String, String>>

Returns a map of connection statistics (total connections, active miners, per-address status).

pub async fn start_metagraph_monitor( &self, monitor_config: MetagraphMonitorConfig, ) -> Result<()>

Starts a background task that periodically syncs the metagraph and updates connections. Requires the subtensor feature.

pub async fn stop_metagraph_monitor(&self)

Stops the metagraph monitor background task if running.

pub async fn close_all_connections(&self) -> Result<()>

Gracefully closes all QUIC connections and clears the miner registry.