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 MaxBtcFundingAmount + const MaxBtcFundingAmountWumbo + const MaxBtcRemoteDelay + const MaxLtcFundingAmount + const MaxLtcRemoteDelay + const MinBtcRemoteDelay + const MinChanFundingSize + const MinLtcRemoteDelay + const Subsystem + var ErrConfirmationTimeout = errors.New(...) + var ErrFundingManagerShuttingDown = errors.New(...) + func DisableLog() + func UseLogger(logger btclog.Logger) + func WriteOutpoint(w io.Writer, o *wire.OutPoint) error + type BatchConfig struct + ChannelAbandoner ChannelAbandoner + ChannelOpener ChannelOpener + NetParams *chaincfg.Params + Quit chan struct{} + RequestParser RequestParser + Wallet Wallet + WalletKitServer WalletKitServer + type Batcher struct + func NewBatcher(cfg *BatchConfig) *Batcher + func (b *Batcher) BatchFund(ctx context.Context, req *lnrpc.BatchOpenChannelRequest) ([]*lnrpc.PendingUpdate, error) + type ChannelAbandoner func(*wire.OutPoint) error + type ChannelOpener func(*InitFundingMsg) (chan *lnrpc.OpenStatusUpdate, chan error) + type Config struct + AliasManager aliasHandler + CurrentNodeAnnouncement func() (lnwire.NodeAnnouncement, error) + DefaultMinHtlcIn lnwire.MilliSatoshi + DefaultRoutingPolicy htlcswitch.ForwardingPolicy + DeleteAliasEdge func(scid lnwire.ShortChannelID) (*channeldb.ChannelEdgePolicy, error) + EnableUpfrontShutdown bool + FeeEstimator chainfee.Estimator + FindChannel func(node *btcec.PublicKey, chanID lnwire.ChannelID) (*channeldb.OpenChannel, error) + IDKey *btcec.PublicKey + IDKeyLoc keychain.KeyLocator + MaxAnchorsCommitFeeRate chainfee.SatPerKWeight + MaxChanSize btcutil.Amount + MaxLocalCSVDelay uint16 + MaxPendingChannels int + MinChanSize btcutil.Amount + NoWumboChans bool + Notifier chainntnfs.ChainNotifier + NotifyOpenChannelEvent func(wire.OutPoint) + NotifyPendingOpenChannelEvent func(wire.OutPoint, *channeldb.OpenChannel) + NotifyWhenOnline func(peer [33]byte, peerChan chan<- lnpeer.Peer) + NumRequiredConfs func(btcutil.Amount, lnwire.MilliSatoshi) uint16 + OpenChannelPredicate chanacceptor.ChannelAcceptor + PublishTransaction func(*wire.MsgTx, string) error + RegisteredChains *chainreg.ChainRegistry + RejectPush bool + ReportShortChanID func(wire.OutPoint) error + RequiredRemoteChanReserve func(capacity, dustLimit btcutil.Amount) btcutil.Amount + RequiredRemoteDelay func(btcutil.Amount) uint16 + RequiredRemoteMaxHTLCs func(btcutil.Amount) uint16 + RequiredRemoteMaxValue func(btcutil.Amount) lnwire.MilliSatoshi + ReservationTimeout time.Duration + SendAnnouncement func(msg lnwire.Message, optionalFields ...discovery.OptionalMsgField) chan error + SignMessage func(keyLoc keychain.KeyLocator, msg []byte, doubleHash bool) (*ecdsa.Signature, error) + TempChanIDSeed [32]byte + UpdateLabel func(chainhash.Hash, string) error + Wallet *lnwallet.LightningWallet + WatchNewChannel func(*channeldb.OpenChannel, *btcec.PublicKey) error + ZombieSweeperInterval time.Duration + type Controller interface + IsPendingChannel func([32]byte, lnpeer.Peer) bool + ProcessFundingMsg func(lnwire.Message, lnpeer.Peer) + type InitFundingMsg struct + BaseFee *uint64 + ChainHash chainhash.Hash + ChanFunder chanfunding.Assembler + ChannelType *lnwire.ChannelType + Err chan error + FeeRate *uint64 + FundingFeePerKw chainfee.SatPerKWeight + LocalFundingAmt btcutil.Amount + MaxHtlcs uint16 + MaxLocalCsv uint16 + MaxValueInFlight lnwire.MilliSatoshi + MinConfs int32 + MinHtlcIn lnwire.MilliSatoshi + Peer lnpeer.Peer + PendingChanID [32]byte + Private bool + PushAmt lnwire.MilliSatoshi + RemoteChanReserve btcutil.Amount + RemoteCsvDelay uint16 + ShutdownScript lnwire.DeliveryAddress + SubtractFees bool + TargetPubkey *btcec.PublicKey + Updates chan *lnrpc.OpenStatusUpdate + type Manager struct + func NewFundingManager(cfg Config) (*Manager, error) + func (f *Manager) CancelPeerReservations(nodePub [33]byte) + func (f *Manager) InitFundingWorkflow(msg *InitFundingMsg) + func (f *Manager) IsPendingChannel(pendingChanID [32]byte, peer lnpeer.Peer) bool + func (f *Manager) ProcessFundingMsg(msg lnwire.Message, peer lnpeer.Peer) + func (f *Manager) Start() error + func (f *Manager) Stop() error + type RequestParser func(*lnrpc.OpenChannelRequest) (*InitFundingMsg, error) + type Wallet interface + CancelFundingIntent func([32]byte) error + PsbtFundingFinalize func([32]byte, *psbt.Packet, *wire.MsgTx) error + PsbtFundingVerify func([32]byte, *psbt.Packet, bool) error + PublishTransaction func(*wire.MsgTx, string) error + type WalletKitServer interface + FinalizePsbt func(context.Context, *walletrpc.FinalizePsbtRequest) (*walletrpc.FinalizePsbtResponse, error) + FundPsbt func(context.Context, *walletrpc.FundPsbtRequest) (*walletrpc.FundPsbtResponse, error) + ReleaseOutput func(context.Context, *walletrpc.ReleaseOutputRequest) (*walletrpc.ReleaseOutputResponse, error)