Documentation
¶
Index ¶
- Variables
- func DisableLog()
- func UseLogger(logger btclog.Logger)
- type InvoiceRegistry
- func (i *InvoiceRegistry) AddDebugInvoice(amt acmutil.Amount, preimage lntypes.Preimage)
- func (i *InvoiceRegistry) AddInvoice(invoice *channeldb.Invoice, paymentHash lntypes.Hash) (uint64, error)
- func (i *InvoiceRegistry) CancelInvoice(payHash lntypes.Hash) error
- func (i *InvoiceRegistry) LookupInvoice(rHash lntypes.Hash) (channeldb.Invoice, uint32, error)
- func (i *InvoiceRegistry) SettleInvoice(rHash lntypes.Hash, amtPaid lnwire.MilliSatoshi) error
- func (i *InvoiceRegistry) Start() error
- func (i *InvoiceRegistry) Stop()
- func (i *InvoiceRegistry) SubscribeNotifications(addIndex, settleIndex uint64) *InvoiceSubscription
- func (i *InvoiceRegistry) SubscribeSingleInvoice(hash lntypes.Hash) *SingleInvoiceSubscription
- type InvoiceSubscription
- type SingleInvoiceSubscription
Constants ¶
This section is empty.
Variables ¶
var (
// DebugPre is the default debug preimage which is inserted into the
// invoice registry if the --debughtlc flag is activated on start up.
// All nodes initialized with the flag active will immediately settle
// any incoming HTLC whose rHash corresponds with the debug
// preimage.
DebugPre, _ = lntypes.NewPreimage(bytes.Repeat([]byte{1}, 32))
// DebugHash is the hash of the default preimage.
DebugHash = DebugPre.Hash()
)
Functions ¶
func DisableLog ¶
func DisableLog()
DisableLog disables all library log output. Logging output is disabled by default until UseLogger is called.
Types ¶
type InvoiceRegistry ¶
InvoiceRegistry is a central registry of all the outstanding invoices created by the daemon. The registry is a thin wrapper around a map in order to ensure that all updates/reads are thread safe.
func NewRegistry ¶
func NewRegistry(cdb *channeldb.DB, activeNetParams *chaincfg.Params) *InvoiceRegistry
NewRegistry creates a new invoice registry. The invoice registry wraps the persistent on-disk invoice storage with an additional in-memory layer. The in-memory layer is in place such that debug invoices can be added which are volatile yet available system wide within the daemon.
func (*InvoiceRegistry) AddDebugInvoice ¶
func (i *InvoiceRegistry) AddDebugInvoice(amt acmutil.Amount, preimage lntypes.Preimage)
AddDebugInvoice adds a debug invoice for the specified amount, identified by the passed preimage. Once this invoice is added, subsystems within the daemon add/forward HTLCs that are able to obtain the proper preimage required for redemption in the case that we're the final destination.
func (*InvoiceRegistry) AddInvoice ¶
func (i *InvoiceRegistry) AddInvoice(invoice *channeldb.Invoice, paymentHash lntypes.Hash) (uint64, error)
AddInvoice adds a regular invoice for the specified amount, identified by the passed preimage. Additionally, any memo or receipt data provided will also be stored on-disk. Once this invoice is added, subsystems within the daemon add/forward HTLCs are able to obtain the proper preimage required for redemption in the case that we're the final destination. We also return the addIndex of the newly created invoice which monotonically increases for each new invoice added.
func (*InvoiceRegistry) CancelInvoice ¶
func (i *InvoiceRegistry) CancelInvoice(payHash lntypes.Hash) error
CancelInvoice attempts to cancel the invoice corresponding to the passed payment hash.
func (*InvoiceRegistry) LookupInvoice ¶
LookupInvoice looks up an invoice by its payment hash (R-Hash), if found then we're able to pull the funds pending within an HTLC. We'll also return what the expected min final CLTV delta is, pre-parsed from the payment request. This may be used by callers to determine if an HTLC is well formed according to the cltv delta.
TODO(roasbeef): ignore if settled?
func (*InvoiceRegistry) SettleInvoice ¶
func (i *InvoiceRegistry) SettleInvoice(rHash lntypes.Hash, amtPaid lnwire.MilliSatoshi) error
SettleInvoice attempts to mark an invoice as settled. If the invoice is a debug invoice, then this method is a noop as debug invoices are never fully settled.
func (*InvoiceRegistry) Start ¶
func (i *InvoiceRegistry) Start() error
Start starts the registry and all goroutines it needs to carry out its task.
func (*InvoiceRegistry) Stop ¶
func (i *InvoiceRegistry) Stop()
Stop signals the registry for a graceful shutdown.
func (*InvoiceRegistry) SubscribeNotifications ¶
func (i *InvoiceRegistry) SubscribeNotifications(addIndex, settleIndex uint64) *InvoiceSubscription
SubscribeNotifications returns an InvoiceSubscription which allows the caller to receive async notifications when any invoices are settled or added. The invoiceIndex parameter is a streaming "checkpoint". We'll start by first sending out all new events with an invoice index _greater_ than this value. Afterwards, we'll send out real-time notifications.
func (*InvoiceRegistry) SubscribeSingleInvoice ¶
func (i *InvoiceRegistry) SubscribeSingleInvoice( hash lntypes.Hash) *SingleInvoiceSubscription
SubscribeSingleInvoice returns an SingleInvoiceSubscription which allows the caller to receive async notifications for a specific invoice.
type InvoiceSubscription ¶
type InvoiceSubscription struct {
// NewInvoices is a channel that we'll use to send all newly created
// invoices with an invoice index greater than the specified
// StartingInvoiceIndex field.
NewInvoices chan *channeldb.Invoice
// SettledInvoices is a channel that we'll use to send all setted
// invoices with an invoices index greater than the specified
// StartingInvoiceIndex field.
SettledInvoices chan *channeldb.Invoice
// contains filtered or unexported fields
}
InvoiceSubscription represents an intent to receive updates for newly added or settled invoices. For each newly added invoice, a copy of the invoice will be sent over the NewInvoices channel. Similarly, for each newly settled invoice, a copy of the invoice will be sent over the SettledInvoices channel.
type SingleInvoiceSubscription ¶
type SingleInvoiceSubscription struct {
// Updates is a channel that we'll use to send all invoice events for
// the invoice that is subscribed to.
Updates chan *channeldb.Invoice
// contains filtered or unexported fields
}
SingleInvoiceSubscription represents an intent to receive updates for a specific invoice.
Source Files