Versions in this module Expand all Collapse all v0 v0.15.10001 Jan 16, 2023 v0.15.101 Jan 16, 2023 Changes in this version + var ErrChanStatusManagerExiting = errors.New("chan status manager exiting") + var ErrEnableInactiveChan = errors.New(...) + var ErrEnableManuallyDisabledChan = errors.New(...) + var ErrInvalidTimeoutConstraints = errors.New(...) + var ErrUnableToExtractChanUpdate = fmt.Errorf("unable to extract ChannelUpdate") + func ChanUpdSetTimestamp(update *lnwire.ChannelUpdate) + func ChannelUpdateFromEdge(info *channeldb.ChannelEdgeInfo, policy *channeldb.ChannelEdgePolicy) (*lnwire.ChannelUpdate, error) + func CreateChanAnnouncement(chanProof *channeldb.ChannelAuthProof, chanInfo *channeldb.ChannelEdgeInfo, ...) (*lnwire.ChannelAnnouncement, *lnwire.ChannelUpdate, *lnwire.ChannelUpdate, ...) + func DisableLog() + func ExtractChannelUpdate(ownerPubKey []byte, info *channeldb.ChannelEdgeInfo, ...) (*lnwire.ChannelUpdate, error) + func IPAnnouncer(annUpdater NodeAnnUpdater) func([]net.Addr, map[string]struct{}) error + func NodeAnnSetAddrs(addrs []net.Addr) func(*lnwire.NodeAnnouncement) + func NodeAnnSetAlias(alias lnwire.NodeAlias) func(*lnwire.NodeAnnouncement) + func NodeAnnSetColor(newColor color.RGBA) func(*lnwire.NodeAnnouncement) + func NodeAnnSetFeatures(features *lnwire.RawFeatureVector) func(*lnwire.NodeAnnouncement) + func NodeAnnSetTimestamp(nodeAnn *lnwire.NodeAnnouncement) + func SignAnnouncement(signer lnwallet.MessageSigner, keyLoc keychain.KeyLocator, msg lnwire.Message) (input.Signature, error) + func SignChannelUpdate(signer lnwallet.MessageSigner, keyLoc keychain.KeyLocator, ...) error + func SignNodeAnnouncement(signer lnwallet.MessageSigner, keyLoc keychain.KeyLocator, ...) error + func UnsignedChannelUpdateFromEdge(info *channeldb.ChannelEdgeInfo, policy *channeldb.ChannelEdgePolicy) *lnwire.ChannelUpdate + func UseLogger(logger btclog.Logger) + type ChanStatus uint8 + const ChanStatusDisabled + const ChanStatusEnabled + const ChanStatusManuallyDisabled + const ChanStatusPendingDisabled + type ChanStatusConfig struct + ApplyChannelUpdate func(*lnwire.ChannelUpdate, *wire.OutPoint, bool) error + ChanDisableTimeout time.Duration + ChanEnableTimeout time.Duration + ChanStatusSampleInterval time.Duration + DB DB + Graph ChannelGraph + IsChannelActive func(lnwire.ChannelID) bool + MessageSigner lnwallet.MessageSigner + OurKeyLoc keychain.KeyLocator + OurPubKey *btcec.PublicKey + type ChanStatusManager struct + func NewChanStatusManager(cfg *ChanStatusConfig) (*ChanStatusManager, error) + func (m *ChanStatusManager) RequestAuto(outpoint wire.OutPoint) error + func (m *ChanStatusManager) RequestDisable(outpoint wire.OutPoint, manual bool) error + func (m *ChanStatusManager) RequestEnable(outpoint wire.OutPoint, manual bool) error + func (m *ChanStatusManager) Start() error + func (m *ChanStatusManager) Stop() error + type ChannelGraph interface + FetchChannelEdgesByOutpoint func(*wire.OutPoint) (*channeldb.ChannelEdgeInfo, *channeldb.ChannelEdgePolicy, ...) + type ChannelState struct + SendDisableTime time.Time + Status ChanStatus + type ChannelUpdateModifier func(*lnwire.ChannelUpdate) + func ChanUpdSetDisable(disabled bool) ChannelUpdateModifier + type DB interface + FetchAllOpenChannels func() ([]*channeldb.OpenChannel, error) + type HostAnnouncer struct + func NewHostAnnouncer(cfg HostAnnouncerConfig) *HostAnnouncer + func (h *HostAnnouncer) Start() error + func (h *HostAnnouncer) Stop() error + type HostAnnouncerConfig struct + AdvertisedIPs map[string]struct{} + AnnounceNewIPs func([]net.Addr, map[string]struct{}) error + Hosts []string + LookupHost func(string) (net.Addr, error) + RefreshTicker ticker.Ticker + type NodeAnnModifier func(*lnwire.NodeAnnouncement) + type NodeAnnUpdater func(refresh bool, modifier ...NodeAnnModifier) (lnwire.NodeAnnouncement, error) + type NodeSigner struct + func NewNodeSigner(keySigner keychain.SingleKeyMessageSigner) *NodeSigner + func (n *NodeSigner) SignMessage(keyLoc keychain.KeyLocator, msg []byte, doubleHash bool) (*ecdsa.Signature, error) + func (n *NodeSigner) SignMessageCompact(msg []byte, doubleHash bool) ([]byte, error)