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 + const ErrorBufferSize + var ErrChannelNotFound = fmt.Errorf("channel not found") + func DisableLog() + func UseLogger(logger btclog.Logger) + func WaitForChanToClose(bestHeight uint32, notifier chainntnfs.ChainNotifier, errChan chan error, ...) + type Brontide struct + func NewBrontide(cfg Config) *Brontide + func (p *Brontide) ActiveSignal() chan struct{} + func (p *Brontide) AddNewChannel(channel *channeldb.OpenChannel, cancel <-chan struct{}) error + func (p *Brontide) Address() net.Addr + func (p *Brontide) BytesReceived() uint64 + func (p *Brontide) BytesSent() uint64 + func (p *Brontide) ChannelSnapshots() []*channeldb.ChannelSnapshot + func (p *Brontide) Conn() net.Conn + func (p *Brontide) ConnReq() *connmgr.ConnReq + func (p *Brontide) Disconnect(reason error) + func (p *Brontide) ErrorBuffer() *queue.CircularBuffer + func (p *Brontide) HandleLocalCloseChanReqs(req *htlcswitch.ChanClose) + func (p *Brontide) IdentityKey() *btcec.PublicKey + func (p *Brontide) Inbound() bool + func (p *Brontide) LastRemotePingPayload() []byte + func (p *Brontide) LocalFeatures() *lnwire.FeatureVector + func (p *Brontide) NetAddress() *lnwire.NetAddress + func (p *Brontide) PingTime() int64 + func (p *Brontide) PubKey() [33]byte + func (p *Brontide) QuitSignal() <-chan struct{} + func (p *Brontide) RemoteFeatures() *lnwire.FeatureVector + func (p *Brontide) SendMessage(sync bool, msgs ...lnwire.Message) error + func (p *Brontide) SendMessageLazy(sync bool, msgs ...lnwire.Message) error + func (p *Brontide) SetAddress(address net.Addr) + func (p *Brontide) Start() error + func (p *Brontide) StartTime() time.Time + func (p *Brontide) String() string + func (p *Brontide) WaitForDisconnect(ready chan struct{}) + func (p *Brontide) WipeChannel(chanPoint *wire.OutPoint) + type ChannelCloseUpdate struct + ClosingTxid []byte + Success bool + type Config struct + AddLocalAlias func(alias, base lnwire.ShortChannelID, gossip bool) error + Addr *lnwire.NetAddress + AnchorTowerClient wtclient.Client + AuthGossiper *discovery.AuthenticatedGossiper + ChainArb *contractcourt.ChainArbitrator + ChainIO lnwallet.BlockChainIO + ChainNotifier chainntnfs.ChainNotifier + ChanActiveTimeout time.Duration + ChanStatusMgr *netann.ChanStatusManager + ChannelCommitBatchSize uint32 + ChannelCommitInterval time.Duration + ChannelDB *channeldb.ChannelStateDB + ChannelGraph *channeldb.ChannelGraph + ChannelNotifier *channelnotifier.ChannelNotifier + Conn MessageConn + ConnReq *connmgr.ConnReq + CoopCloseTargetConfs uint32 + DisconnectPeer func(*btcec.PublicKey) error + ErrorBuffer *queue.CircularBuffer + Features *lnwire.FeatureVector + FeeEstimator chainfee.Estimator + FetchLastChanUpdate func(lnwire.ShortChannelID) (*lnwire.ChannelUpdate, error) + FundingManager funding.Controller + GenNodeAnnouncement func(bool, ...netann.NodeAnnModifier) (lnwire.NodeAnnouncement, error) + GetAliases func(base lnwire.ShortChannelID) []lnwire.ShortChannelID + HandleCustomMessage func(peer [33]byte, msg *lnwire.Custom) error + Hodl *hodl.Config + HtlcNotifier *htlcswitch.HtlcNotifier + Inbound bool + InterceptSwitch *htlcswitch.InterceptableSwitch + Invoices *invoices.InvoiceRegistry + LegacyFeatures *lnwire.FeatureVector + MaxAnchorsCommitFeeRate chainfee.SatPerKWeight + MaxChannelFeeAllocation float64 + MaxOutgoingCltvExpiry uint32 + OutgoingCltvRejectDelta uint32 + PendingCommitInterval time.Duration + PongBuf []byte + PrunePersistentPeerConnection func([33]byte) + PubKeyBytes [33]byte + Quit chan struct{} + ReadPool *pool.Read + RequestAlias func() (lnwire.ShortChannelID, error) + RoutingPolicy htlcswitch.ForwardingPolicy + ServerPubKey [33]byte + SigPool *lnwallet.SigPool + Signer input.Signer + Sphinx *hop.OnionProcessor + Switch messageSwitch + TowerClient wtclient.Client + UnsafeReplay bool + Wallet *lnwallet.LightningWallet + WitnessBeacon contractcourt.WitnessBeacon + WritePool *pool.Write + type LinkUpdater interface + TargetChanID func() lnwire.ChannelID + type MessageConn interface + Close func() error + Flush func() (int, error) + LocalAddr func() net.Addr + Read func([]byte) (int, error) + ReadNextBody func([]byte) ([]byte, error) + ReadNextHeader func() (uint32, error) + RemoteAddr func() net.Addr + SetDeadline func(time.Time) error + SetReadDeadline func(time.Time) error + SetWriteDeadline func(time.Time) error + Write func([]byte) (int, error) + WriteMessage func([]byte) error + type PendingUpdate struct + OutputIndex uint32 + Txid []byte + type TimestampedError struct + Error error + Timestamp time.Time