Struct lightning::routing::network_graph::NetworkGraph

pub struct NetworkGraph { /* private fields */ }

Represents the network as nodes and channels between them

Implementations

impl NetworkGraph

pub fn new(genesis_hash: BlockHash) -> NetworkGraph

Creates a new, empty, network graph.

pub fn read_only(&self) -> ReadOnlyNetworkGraph<'_>

Returns a read-only view of the network graph.

pub fn update_node_from_announcement<T: Verification>(
    &self,
    msg: &NodeAnnouncement,
    secp_ctx: &Secp256k1<T>
) -> Result<(), LightningError>

For an already known node (from channel announcements), update its stored properties from a given node announcement.

You probably don’t want to call this directly, instead relying on a NetGraphMsgHandler’s RoutingMessageHandler implementation to call it indirectly. This may be useful to accept routing messages from a source using a protocol other than the lightning P2P protocol.

pub fn update_node_from_unsigned_announcement(
    &self,
    msg: &UnsignedNodeAnnouncement
) -> Result<(), LightningError>

For an already known node (from channel announcements), update its stored properties from a given node announcement without verifying the associated signatures. Because we aren’t given the associated signatures here we cannot relay the node announcement to any of our peers.

pub fn update_channel_from_announcement<T: Verification, C: Deref>(
    &self,
    msg: &ChannelAnnouncement,
    chain_access: &Option<C>,
    secp_ctx: &Secp256k1<T>
) -> Result<(), LightningError> where
    C::Target: Access, 

Store or update channel info from a channel announcement.

You probably don’t want to call this directly, instead relying on a NetGraphMsgHandler’s RoutingMessageHandler implementation to call it indirectly. This may be useful to accept routing messages from a source using a protocol other than the lightning P2P protocol.

If a chain::Access object is provided via chain_access, it will be called to verify the corresponding UTXO exists on chain and is correctly-formatted.

pub fn update_channel_from_unsigned_announcement<C: Deref>(
    &self,
    msg: &UnsignedChannelAnnouncement,
    chain_access: &Option<C>
) -> Result<(), LightningError> where
    C::Target: Access, 

Store or update channel info from a channel announcement without verifying the associated signatures. Because we aren’t given the associated signatures here we cannot relay the channel announcement to any of our peers.

If a chain::Access object is provided via chain_access, it will be called to verify the corresponding UTXO exists on chain and is correctly-formatted.

pub fn close_channel_from_update(
    &self,
    short_channel_id: u64,
    is_permanent: bool
)

Close a channel if a corresponding HTLC fail was sent. If permanent, removes a channel from the local storage. May cause the removal of nodes too, if this was their last channel. If not permanent, makes channels unavailable for routing.

pub fn fail_node(&self, _node_id: &PublicKey, is_permanent: bool)

Marks a node in the graph as failed.

pub fn remove_stale_channels(&self)

This is supported on crate feature std only.

Removes information about channels that we haven’t heard any updates about in some time. This can be used regularly to prune the network graph of channels that likely no longer exist.

While there is no formal requirement that nodes regularly re-broadcast their channel updates every two weeks, the non-normative section of BOLT 7 currently suggests that pruning occur for updates which are at least two weeks old, which we implement here.

Note that for users of the lightning-background-processor crate this method may be automatically called regularly for you.

This method is only available with the std feature. See NetworkGraph::remove_stale_channels_with_time for no-std use.

pub fn remove_stale_channels_with_time(&self, current_time_unix: u64)

Removes information about channels that we haven’t heard any updates about in some time. This can be used regularly to prune the network graph of channels that likely no longer exist.

While there is no formal requirement that nodes regularly re-broadcast their channel updates every two weeks, the non-normative section of BOLT 7 currently suggests that pruning occur for updates which are at least two weeks old, which we implement here.

This function takes the current unix time as an argument. For users with the std feature enabled, NetworkGraph::remove_stale_channels may be preferable.

pub fn update_channel<T: Verification>(
    &self,
    msg: &ChannelUpdate,
    secp_ctx: &Secp256k1<T>
) -> Result<(), LightningError>

For an already known (from announcement) channel, update info about one of the directions of the channel.

You probably don’t want to call this directly, instead relying on a NetGraphMsgHandler’s RoutingMessageHandler implementation to call it indirectly. This may be useful to accept routing messages from a source using a protocol other than the lightning P2P protocol.

If built with no-std, any updates with a timestamp more than two weeks in the past or materially in the future will be rejected.

pub fn update_channel_unsigned(
    &self,
    msg: &UnsignedChannelUpdate
) -> Result<(), LightningError>

For an already known (from announcement) channel, update info about one of the directions of the channel without verifying the associated signatures. Because we aren’t given the associated signatures here we cannot relay the channel update to any of our peers.

If built with no-std, any updates with a timestamp more than two weeks in the past or materially in the future will be rejected.

Trait Implementations

impl Clone for NetworkGraph

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Display for NetworkGraph

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

Formats the value using the given formatter.

impl PartialEq<NetworkGraph> for NetworkGraph

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl Readable for NetworkGraph

fn read<R: Read>(reader: &mut R) -> Result<NetworkGraph, DecodeError>

Reads a Self in from the given Read

impl Writeable for NetworkGraph

fn write<W: Writer>(&self, writer: &mut W) -> Result<(), Error>

Writes self out to the given Writer

fn encode(&self) -> Vec<u8>

Writes self out to a Vec

fn serialized_length(&self) -> usize

Gets the length of this object after it has been serialized. This can be overridden to optimize cases where we prepend an object with its length.