Documentation ¶
Index ¶
- Variables
- func NewBasicClient(lndHost, tlsPath, macDir, network string, basicOptions ...BasicClientOption) (lnrpc.LightningClient, error)
- func NewBasicConn(lndHost, tlsPath, macDir, network string, basicOptions ...BasicClientOption) (*grpc.ClientConn, error)
- func UseLogger(logger btclog.Logger)
- func VersionString(version *verrpc.Version) string
- func VersionStringShort(version *verrpc.Version) string
- type BasicClientOption
- type ChainNotifierClient
- type ChannelInfo
- type CloseType
- type ClosedChannel
- type DialerFunc
- type ForwardingEvent
- type ForwardingHistoryRequest
- type ForwardingHistoryResponse
- type GrpcLndServices
- type Info
- type Initiator
- type Invoice
- type InvoiceUpdate
- type InvoicesClient
- type LightningClient
- type ListInvoicesRequest
- type ListInvoicesResponse
- type ListPaymentsRequest
- type ListPaymentsResponse
- type LndServices
- type LndServicesConfig
- type Network
- type Payment
- type PaymentResult
- type PaymentStatus
- type RouterClient
- type SendPaymentRequest
- type SignerClient
- type Transaction
- type VersionerClient
- type WalletKitClient
Constants ¶
This section is empty.
Variables ¶
var ( // ErrMalformedServerResponse is returned when the swap and/or prepay // invoice is malformed. ErrMalformedServerResponse = errors.New( "one or more invoices are malformed", ) // ErrNoRouteToServer is returned if no quote can returned because there // is no route to the server. ErrNoRouteToServer = errors.New("no off-chain route to server") // PaymentResultUnknownPaymentHash is the string result returned by // SendPayment when the final node indicates the hash is unknown. PaymentResultUnknownPaymentHash = "UnknownPaymentHash" // PaymentResultSuccess is the string result returned by SendPayment // when the payment was successful. PaymentResultSuccess = "" // PaymentResultAlreadyPaid is the string result returned by SendPayment // when the payment was already completed in a previous SendPayment // call. PaymentResultAlreadyPaid = channeldb.ErrAlreadyPaid.Error() // PaymentResultInFlight is the string result returned by SendPayment // when the payment was initiated in a previous SendPayment call and // still in flight. PaymentResultInFlight = channeldb.ErrPaymentInFlight.Error() )
var ( // ErrVersionCheckNotImplemented is the error that is returned if the // version RPC is not implemented in lnd. This means the version of lnd // is lower than v0.10.0-beta. ErrVersionCheckNotImplemented = errors.New("version check not " + "implemented, need minimum lnd version of v0.10.0-beta") // ErrVersionIncompatible is the error that is returned if the connected // lnd instance is not supported. ErrVersionIncompatible = errors.New("version incompatible") // ErrBuildTagsMissing is the error that is returned if the // connected lnd instance does not have all built tags activated that // are required. ErrBuildTagsMissing = errors.New("build tags missing") )
Functions ¶
func NewBasicClient ¶
func NewBasicClient(lndHost, tlsPath, macDir, network string, basicOptions ...BasicClientOption) ( lnrpc.LightningClient, error)
NewBasicClient creates a new basic gRPC client to lnd. We call this client "basic" as it falls back to expected defaults if the arguments aren't provided.
func NewBasicConn ¶
func NewBasicConn(lndHost, tlsPath, macDir, network string, basicOptions ...BasicClientOption) ( *grpc.ClientConn, error)
NewBasicConn creates a new basic gRPC connection to lnd. We call this connection "basic" as it falls back to expected defaults if the arguments aren't provided.
func UseLogger ¶
UseLogger uses a specified Logger to output package logging info. This should be used in preference to SetLogWriter if the caller is also using btclog.
func VersionString ¶
VersionString returns a nice, human readable string of a version returned by the VersionerClient, including all build tags.
func VersionStringShort ¶
VersionStringShort returns a nice, human readable string of a version returned by the VersionerClient.
Types ¶
type BasicClientOption ¶
type BasicClientOption func(*basicClientOptions)
BasicClientOption is a functional option argument that allows adding arbitrary lnd basic client configuration overrides, without forcing existing users of NewBasicClient to update their invocation. These are always processed in order, with later options overriding earlier ones.
func MacFilename ¶
func MacFilename(macFilename string) BasicClientOption
MacFilename is a basic client option that sets the name of the macaroon file to use.
type ChainNotifierClient ¶
type ChainNotifierClient interface { RegisterBlockEpochNtfn(ctx context.Context) ( chan int32, chan error, error) RegisterConfirmationsNtfn(ctx context.Context, txid *chainhash.Hash, pkScript []byte, numConfs, heightHint int32) ( chan *chainntnfs.TxConfirmation, chan error, error) RegisterSpendNtfn(ctx context.Context, outpoint *wire.OutPoint, pkScript []byte, heightHint int32) ( chan *chainntnfs.SpendDetail, chan error, error) }
ChainNotifierClient exposes base lightning functionality.
type ChannelInfo ¶
type ChannelInfo struct { // ChannelPoint is the funding outpoint of the channel. ChannelPoint string // Active indicates whether the channel is active. Active bool // ChannelID holds the unique channel ID for the channel. The first 3 bytes // are the block height, the next 3 the index within the block, and the last // 2 bytes are the /output index for the channel. ChannelID uint64 // PubKeyBytes is the raw bytes of the public key of the remote node. PubKeyBytes route.Vertex // Capacity is the total amount of funds held in this channel. Capacity btcutil.Amount // LocalBalance is the current balance of this node in this channel. LocalBalance btcutil.Amount // RemoteBalance is the counterparty's current balance in this channel. RemoteBalance btcutil.Amount // Initiator indicates whether we opened the channel or not. Initiator bool // Private indicates that the channel is private. Private bool // LifeTime is the total amount of time we have monitored the peer's // online status for. LifeTime time.Duration // Uptime is the total amount of time the peer has been observed as // online over its lifetime. Uptime time.Duration }
ChannelInfo stores unpacked per-channel info.
type CloseType ¶
type CloseType uint8
CloseType is an enum which represents the types of closes our channels may have. This type maps to the rpc value.
const ( // CloseTypeCooperative represents cooperative closes. CloseTypeCooperative CloseType = iota // CloseTypeLocalForce represents force closes that we initiated. CloseTypeLocalForce // CloseTypeRemoteForce represents force closes that our peer initiated. CloseTypeRemoteForce // CloseTypeBreach represents breach closes from our peer. CloseTypeBreach // CloseTypeFundingCancelled represents channels which were never // created because their funding transaction was cancelled. CloseTypeFundingCancelled // CloseTypeAbandoned represents a channel that was abandoned. CloseTypeAbandoned )
type ClosedChannel ¶
type ClosedChannel struct { // ChannelPoint is the funding outpoint of the channel. ChannelPoint string // ChannelID holds the unique channel ID for the channel. The first 3 // bytes are the block height, the next 3 the index within the block, // and the last 2 bytes are the output index for the channel. ChannelID uint64 // ClosingTxHash is the tx hash of the close transaction for the channel. ClosingTxHash string // CloseType is the type of channel closure. CloseType CloseType // OpenInitiator is true if we opened the channel. This value is not // always available (older channels do not have it). OpenInitiator Initiator // Initiator indicates which party initiated the channel close. Since // this value is not always set in the rpc response, we also make a best // effort attempt to set it based on CloseType. CloseInitiator Initiator // PubKeyBytes is the raw bytes of the public key of the remote node. PubKeyBytes route.Vertex // Capacity is the total amount of funds held in this channel. Capacity btcutil.Amount // SettledBalance is the amount we were paid out directly in this // channel close. Note that this does not include cases where we need to // sweep our commitment or htlcs. SettledBalance btcutil.Amount }
ClosedChannel represents a channel that has been closed.
type DialerFunc ¶
DialerFunc is a function that is used as grpc.WithContextDialer().
type ForwardingEvent ¶
type ForwardingEvent struct { // Timestamp is the time that we processed the forwarding event. Timestamp time.Time // ChannelIn is the id of the channel the htlc arrived at our node on. ChannelIn uint64 // ChannelOut is the id of the channel the htlc left our node on. ChannelOut uint64 // AmountMsatIn is the amount that was forwarded into our node in // millisatoshis. AmountMsatIn lnwire.MilliSatoshi // AmountMsatOut is the amount that was forwarded out of our node in // millisatoshis. AmountMsatOut lnwire.MilliSatoshi // FeeMsat is the amount of fees earned in millisatoshis, FeeMsat lnwire.MilliSatoshi }
ForwardingEvent represents a htlc that was forwarded through our node.
type ForwardingHistoryRequest ¶
type ForwardingHistoryRequest struct { // StartTime is the beginning of the query period. StartTime time.Time // EndTime is the end of the query period. EndTime time.Time // MaxEvents is the maximum number of events to return. MaxEvents uint32 // Offset is the index from which to start querying. Offset uint32 }
ForwardingHistoryRequest contains the request parameters for a paginated forwarding history call.
type ForwardingHistoryResponse ¶
type ForwardingHistoryResponse struct { // LastIndexOffset is the index offset of the last item in our set. LastIndexOffset uint32 // Events is the set of events that were found in the interval queried. Events []ForwardingEvent }
ForwardingHistoryResponse contains the response to a forwarding history query, including last index offset required for paginated queries.
type GrpcLndServices ¶
type GrpcLndServices struct { LndServices // contains filtered or unexported fields }
GrpcLndServices constitutes a set of required RPC services.
func NewLndServices ¶
func NewLndServices(cfg *LndServicesConfig) (*GrpcLndServices, error)
NewLndServices creates creates a connection to the given lnd instance and creates a set of required RPC services.
func (*GrpcLndServices) Close ¶
func (s *GrpcLndServices) Close()
Close closes the lnd connection and waits for all sub server clients to finish their goroutines.
type Info ¶
type Info struct { BlockHeight uint32 IdentityPubkey [33]byte Alias string Network string Uris []string }
Info contains info about the connected lnd node.
type Initiator ¶
type Initiator uint8
Initiator indicates the party that opened or closed a channel. This enum is used for cases where we may not have a full set of initiator information available over rpc (this is the case for older channels).
const ( // InitiatorUnrecorded is set when we do not know the open/close // initiator for a channel, this is the case when the channel was // closed before lnd started tracking initiators. InitiatorUnrecorded Initiator = iota // InitiatorLocal is set when we initiated a channel open or close. InitiatorLocal // InitiatorRemote is set when the remote party initiated a chanel open // or close. InitiatorRemote // InitiatorBoth is set in the case where both parties initiated a // cooperative close (this is possible with multiple rounds of // negotiation). InitiatorBoth )
type Invoice ¶
type Invoice struct { // Preimage is the invoice's preimage, which is set if the invoice // is settled. Preimage *lntypes.Preimage // Hash is the invoice hash. Hash lntypes.Hash // Memo is an optional memo field for hte invoice. Memo string // PaymentRequest is the invoice's payment request. PaymentRequest string // Amount is the amount of the invoice in millisatoshis. Amount lnwire.MilliSatoshi // AmountPaid is the amount that was paid for the invoice. This field // will only be set if the invoice is settled. AmountPaid lnwire.MilliSatoshi // CreationDate is the time the invoice was created. CreationDate time.Time // SettleDate is the time the invoice was settled. SettleDate time.Time // State is the invoice's current state. State channeldb.ContractState // IsKeysend indicates whether the invoice was a spontaneous payment. IsKeysend bool }
Invoice represents an invoice in lnd.
type InvoiceUpdate ¶
type InvoiceUpdate struct { State channeldb.ContractState AmtPaid btcutil.Amount }
InvoiceUpdate contains a state update for an invoice.
type InvoicesClient ¶
type InvoicesClient interface { SubscribeSingleInvoice(ctx context.Context, hash lntypes.Hash) ( <-chan InvoiceUpdate, <-chan error, error) SettleInvoice(ctx context.Context, preimage lntypes.Preimage) error CancelInvoice(ctx context.Context, hash lntypes.Hash) error AddHoldInvoice(ctx context.Context, in *invoicesrpc.AddInvoiceData) ( string, error) }
InvoicesClient exposes invoice functionality.
type LightningClient ¶
type LightningClient interface { PayInvoice(ctx context.Context, invoice string, maxFee btcutil.Amount, outgoingChannel *uint64) chan PaymentResult GetInfo(ctx context.Context) (*Info, error) EstimateFeeToP2WSH(ctx context.Context, amt btcutil.Amount, confTarget int32) (btcutil.Amount, error) ConfirmedWalletBalance(ctx context.Context) (btcutil.Amount, error) AddInvoice(ctx context.Context, in *invoicesrpc.AddInvoiceData) ( lntypes.Hash, string, error) // LookupInvoice looks up an invoice by hash. LookupInvoice(ctx context.Context, hash lntypes.Hash) (*Invoice, error) // ListTransactions returns all known transactions of the backing lnd // node. ListTransactions(ctx context.Context) ([]Transaction, error) // ListChannels retrieves all channels of the backing lnd node. ListChannels(ctx context.Context) ([]ChannelInfo, error) // ClosedChannels returns all closed channels of the backing lnd node. ClosedChannels(ctx context.Context) ([]ClosedChannel, error) // ForwardingHistory makes a paginated call to our forwarding history // endpoint. ForwardingHistory(ctx context.Context, req ForwardingHistoryRequest) (*ForwardingHistoryResponse, error) // ListInvoices makes a paginated call to our list invoices endpoint. ListInvoices(ctx context.Context, req ListInvoicesRequest) ( *ListInvoicesResponse, error) // ListPayments makes a paginated call to our list payments endpoint. ListPayments(ctx context.Context, req ListPaymentsRequest) (*ListPaymentsResponse, error) // ChannelBackup retrieves the backup for a particular channel. The // backup is returned as an encrypted chanbackup.Single payload. ChannelBackup(context.Context, wire.OutPoint) ([]byte, error) // ChannelBackups retrieves backups for all existing pending open and // open channels. The backups are returned as an encrypted // chanbackup.Multi payload. ChannelBackups(ctx context.Context) ([]byte, error) }
LightningClient exposes base lightning functionality.
type ListInvoicesRequest ¶
type ListInvoicesRequest struct { // MaxInvoices is the maximum number of invoices to return. MaxInvoices uint64 // Offset is the index from which to start querying. Offset uint64 // Reversed is set to query our invoices backwards. Reversed bool // PendingOnly is set if we only want pending invoices. PendingOnly bool }
ListInvoicesRequest contains the request parameters for a paginated list invoices call.
type ListInvoicesResponse ¶
type ListInvoicesResponse struct { // FirstIndexOffset is the index offset of the first item in our set. FirstIndexOffset uint64 // LastIndexOffset is the index offset of the last item in our set. LastIndexOffset uint64 // Invoices is the set of invoices that were returned. Invoices []Invoice }
ListInvoicesResponse contains the response to a list invoices query, including the index offsets required for paginated queries.
type ListPaymentsRequest ¶
type ListPaymentsRequest struct { // MaxPayments is the maximum number of payments to return. MaxPayments uint64 // Offset is the index from which to start querying. Offset uint64 // Reversed is set to query our payments backwards. Reversed bool // IncludeIncomplete is set if we want to include incomplete payments. IncludeIncomplete bool }
ListPaymentsRequest contains the request parameters for a paginated list payments call.
type ListPaymentsResponse ¶
type ListPaymentsResponse struct { // FirstIndexOffset is the index offset of the first item in our set. FirstIndexOffset uint64 // LastIndexOffset is the index offset of the last item in our set. LastIndexOffset uint64 // Payments is the set of invoices that were returned. Payments []Payment }
ListPaymentsResponse contains the response to a list payments query, including the index offsets required for paginated queries.
type LndServices ¶
type LndServices struct { Client LightningClient WalletKit WalletKitClient ChainNotifier ChainNotifierClient Signer SignerClient Invoices InvoicesClient Router RouterClient Versioner VersionerClient ChainParams *chaincfg.Params NodeAlias string NodePubkey [33]byte Version *verrpc.Version // contains filtered or unexported fields }
LndServices constitutes a set of required services.
type LndServicesConfig ¶
type LndServicesConfig struct { // LndAddress is the network address (host:port) of the lnd node to // connect to. LndAddress string // Network is the bitcoin network we expect the lnd node to operate on. Network Network // MacaroonDir is the directory where all lnd macaroons can be found. MacaroonDir string // TLSPath is the path to lnd's TLS certificate file. TLSPath string // CheckVersion is the minimum version the connected lnd node needs to // be in order to be compatible. The node will be checked against this // when connecting. If no version is supplied, the default minimum // version will be used. CheckVersion *verrpc.Version // Dialer is an optional dial function that can be passed in if the // default lncfg.ClientAddressDialer should not be used. Dialer DialerFunc }
LndServicesConfig holds all configuration settings that are needed to connect to an lnd node.
type Payment ¶
type Payment struct { // Hash is the payment hash used. Hash lntypes.Hash // Preimage is the preimage of the payment. It will have a non-nil value // if the payment is settled. Preimage *lntypes.Preimage // Amount is the amount in millisatoshis of the payment. Amount lnwire.MilliSatoshi // Fee is the amount in millisatoshis that was paid in fees. Fee lnwire.MilliSatoshi // Status describes the state of a payment. Status *PaymentStatus // Htlcs is the set of htlc attempts made by the payment. Htlcs []*lnrpc.HTLCAttempt // SequenceNumber is a unique id for each payment. SequenceNumber uint64 }
Payment represents a payment made by our node.
type PaymentResult ¶
type PaymentResult struct { Err error Preimage lntypes.Preimage PaidFee btcutil.Amount PaidAmt btcutil.Amount }
PaymentResult signals the result of a payment.
type PaymentStatus ¶
type PaymentStatus struct { State lnrpc.Payment_PaymentStatus // FailureReason is the reason why the payment failed. Only set when // State is Failed. FailureReason lnrpc.PaymentFailureReason Preimage lntypes.Preimage Fee lnwire.MilliSatoshi Value lnwire.MilliSatoshi InFlightAmt lnwire.MilliSatoshi InFlightHtlcs int }
PaymentStatus describe the state of a payment.
func (PaymentStatus) String ¶
func (p PaymentStatus) String() string
type RouterClient ¶
type RouterClient interface { // SendPayment attempts to route a payment to the final destination. The // call returns a payment update stream and an error stream. SendPayment(ctx context.Context, request SendPaymentRequest) ( chan PaymentStatus, chan error, error) // TrackPayment picks up a previously started payment and returns a // payment update stream and an error stream. TrackPayment(ctx context.Context, hash lntypes.Hash) ( chan PaymentStatus, chan error, error) }
RouterClient exposes payment functionality.
type SendPaymentRequest ¶
type SendPaymentRequest struct { // Invoice is an encoded payment request. The individual payment // parameters Target, Amount, PaymentHash, FinalCLTVDelta and RouteHints // are only processed when the Invoice field is empty. Invoice string // MaxFee is the fee limit for this payment. MaxFee btcutil.Amount // MaxCltv is the maximum timelock for this payment. If nil, there is no // maximum. MaxCltv *int32 // OutgoingChanIds is a restriction on the set of possible outgoing // channels. If nil or empty, there is no restriction. OutgoingChanIds []uint64 // Timeout is the payment loop timeout. After this time, no new payment // attempts will be started. Timeout time.Duration // Target is the node in which the payment should be routed towards. Target route.Vertex // Amount is the value of the payment to send through the network in // satoshis. Amount btcutil.Amount // PaymentHash is the r-hash value to use within the HTLC extended to // the first hop. PaymentHash *lntypes.Hash // FinalCLTVDelta is the CTLV expiry delta to use for the _final_ hop // in the route. This means that the final hop will have a CLTV delta // of at least: currentHeight + FinalCLTVDelta. FinalCLTVDelta uint16 // RouteHints represents the different routing hints that can be used to // assist a payment in reaching its destination successfully. These // hints will act as intermediate hops along the route. // // NOTE: This is optional unless required by the payment. When providing // multiple routes, ensure the hop hints within each route are chained // together and sorted in forward order in order to reach the // destination successfully. RouteHints [][]zpay32.HopHint // LastHopPubkey is the pubkey of the last hop of the route taken // for this payment. If empty, any hop may be used. LastHopPubkey *route.Vertex // MaxParts is the maximum number of partial payments that may be used // to complete the full amount. MaxParts uint32 // KeySend is set to true if the tlv payload will include the preimage. KeySend bool // CustomRecords holds the custom TLV records that will be added to the // payment. CustomRecords map[uint64][]byte }
SendPaymentRequest defines the payment parameters for a new payment.
type SignerClient ¶
type SignerClient interface { SignOutputRaw(ctx context.Context, tx *wire.MsgTx, signDescriptors []*input.SignDescriptor) ([][]byte, error) // ComputeInputScript generates the proper input script for P2WPKH // output and NP2WPKH outputs. This method only requires that the // `Output`, `HashType`, `SigHashes` and `InputIndex` fields are // populated within the sign descriptors. ComputeInputScript(ctx context.Context, tx *wire.MsgTx, signDescriptors []*input.SignDescriptor) ([]*input.Script, error) // SignMessage signs a message with the key specified in the key // locator. The returned signature is fixed-size LN wire format encoded. SignMessage(ctx context.Context, msg []byte, locator keychain.KeyLocator) ([]byte, error) // VerifyMessage verifies a signature over a message using the public // key provided. The signature must be fixed-size LN wire format // encoded. VerifyMessage(ctx context.Context, msg, sig []byte, pubkey [33]byte) ( bool, error) // Diffie-Hellman key derivation between the ephemeral public key and // the key specified by the key locator (or the node's identity private // key if no key locator is specified): // // P_shared = privKeyNode * ephemeralPubkey // // The resulting shared public key is serialized in the compressed // format and hashed with SHA256, resulting in a final key length of 256 // bits. DeriveSharedKey(ctx context.Context, ephemeralPubKey *btcec.PublicKey, keyLocator *keychain.KeyLocator) ([32]byte, error) }
SignerClient exposes sign functionality.
type Transaction ¶
type Transaction struct { // Tx is the on chain transaction. Tx *wire.MsgTx // TxHash is the transaction hash string. TxHash string // Timestamp is the timestamp our wallet has for the transaction. Timestamp time.Time // Amount is the balance change that this transaction had on addresses // controlled by our wallet. Amount btcutil.Amount // Fee is the amount of fees our wallet committed to this transaction. // Note that this field is not exhaustive, as it does not account for // fees taken from inputs that that wallet doesn't know it owns (for // example, the fees taken from our channel balance when we close a // channel). Fee btcutil.Amount // Confirmations is the number of confirmations the transaction has. Confirmations int32 // Label is an optional label set for on chain transactions. Label string }
Transaction represents an on chain transaction.
type VersionerClient ¶
type VersionerClient interface { // GetVersion returns the version and build information of the lnd // daemon. GetVersion(ctx context.Context) (*verrpc.Version, error) }
VersionerClient exposes the version of lnd.
type WalletKitClient ¶
type WalletKitClient interface { // ListUnspent returns a list of all utxos spendable by the wallet with // a number of confirmations between the specified minimum and maximum. ListUnspent(ctx context.Context, minConfs, maxConfs int32) ( []*lnwallet.Utxo, error) // LeaseOutput locks an output to the given ID, preventing it from being // available for any future coin selection attempts. The absolute time // of the lock's expiration is returned. The expiration of the lock can // be extended by successive invocations of this call. Outputs can be // unlocked before their expiration through `ReleaseOutput`. LeaseOutput(ctx context.Context, lockID wtxmgr.LockID, op wire.OutPoint) (time.Time, error) // ReleaseOutput unlocks an output, allowing it to be available for coin // selection if it remains unspent. The ID should match the one used to // originally lock the output. ReleaseOutput(ctx context.Context, lockID wtxmgr.LockID, op wire.OutPoint) error DeriveNextKey(ctx context.Context, family int32) ( *keychain.KeyDescriptor, error) DeriveKey(ctx context.Context, locator *keychain.KeyLocator) ( *keychain.KeyDescriptor, error) NextAddr(ctx context.Context) (btcutil.Address, error) PublishTransaction(ctx context.Context, tx *wire.MsgTx) error SendOutputs(ctx context.Context, outputs []*wire.TxOut, feeRate chainfee.SatPerKWeight) (*wire.MsgTx, error) EstimateFee(ctx context.Context, confTarget int32) (chainfee.SatPerKWeight, error) // ListSweeps returns a list of sweep transaction ids known to our node. // Note that this function only looks up transaction ids, and does not // query our wallet for the full set of transactions. ListSweeps(ctx context.Context) ([]string, error) }
WalletKitClient exposes wallet functionality.