Struct LndDaemon 

pub struct LndDaemon {
    pub alias: String,
    pub container: SpawnedContainer,
    pub cert_hex: String,
    pub macaroon_hex: String,
    pub rpc_socket: String,
    pub p2p_socket: String,
    pub public_key: String,
}

A running LND container and authenticated connection material.

Fields

alias: String

LND alias.

container: SpawnedContainer

Docker container metadata.

cert_hex: String

Hex-encoded TLS certificate.

macaroon_hex: String

Hex-encoded admin macaroon.

rpc_socket: String

Host gRPC socket, usually 127.0.0.1:<port>.

p2p_socket: String

Host P2P socket, usually 127.0.0.1:<port>.

public_key: String

LND identity public key.

Implementations

impl LndDaemon

pub async fn spawn( docker: &DockerClient, bitcoind: &BitcoinCore, config: LndConfig, ) -> Result<Self, LndError>

Spawn an LND container, initialize its wallet, and wait for chain sync.

pub fn node_config(&self) -> LndNodeConfig

Build an lnd_grpc_rust connection config for this node.

pub async fn connect(&self) -> Result<LndClient, LndError>

Connect to this node using its TLS certificate and admin macaroon.

pub async fn wait_synced_to_chain(&self) -> Result<GetInfoResponse, LndError>

Wait until GetInfo reports synced_to_chain.

pub async fn new_address(&self) -> Result<String, LndError>

Generate a new LND wallet address.

pub async fn connect_peer( &self, public_key: impl Into<String>, host: impl Into<String>, ) -> Result<ConnectPeerResponse, LndError>

Connect this LND node to a peer by public key and host socket.

pub async fn wallet_balance( &self, min_confs: i32, ) -> Result<WalletBalanceResponse, LndError>

Return LND wallet balance with the given minimum confirmations.

pub async fn list_unspent( &self, min_confs: i32, max_confs: i32, ) -> Result<Vec<Utxo>, LndError>

Return wallet UTXOs matching the confirmation range.

pub async fn wait_for_spendable_balance( &self, minimum_sat: i64, ) -> Result<WalletBalanceResponse, LndError>

Wait until confirmed wallet balance is at least minimum_sat.

pub async fn wait_for_spendable_utxos( &self, minimum_sat: i64, ) -> Result<Vec<Utxo>, LndError>

Wait until spendable UTXOs total at least minimum_sat.

pub async fn open_channel_sync( &self, remote_public_key: &str, local_funding_amount_sat: i64, push_sat: i64, ) -> Result<ChannelPoint, LndError>

Open a public channel synchronously through LND.

pub async fn pending_channels( &self, ) -> Result<PendingChannelsResponse, LndError>

Return LND pending channel state.

pub async fn list_channels( &self, remote_public_key: Option<&str>, ) -> Result<Vec<Channel>, LndError>

List channels, optionally filtered by remote public key.

pub async fn wait_for_pending_channel( &self, remote_public_key: &str, channel_point: &str, ) -> Result<(), LndError>

Wait until LND reports a pending channel with the given peer and point.

pub async fn wait_for_active_channel( &self, remote_public_key: &str, channel_point: &str, ) -> Result<Channel, LndError>

Wait until LND reports an active channel with the given peer and point.

Trait Implementations

impl Clone for LndDaemon

fn clone(&self) -> LndDaemon

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LndDaemon

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

Formats the value using the given formatter.