Versions in this module Expand all Collapse all v1 v1.0.0 May 10, 2019 Changes in this version + const DefaultChannelCacheSize + const DefaultRejectCacheSize + const DualFunder + const MaxAllowedExtraOpaqueBytes + const MaxMemoSize + const MaxPaymentRequestSize + const MaxReceiptSize + const MaxResponseEvents + const SingleFunder + var ErrChanAlreadyExists = fmt.Errorf("channel already exists") + var ErrChanBorked = fmt.Errorf("cannot mutate borked channel") + var ErrChannelNotFound = fmt.Errorf("channel not found") + var ErrClosedChannelNotFound = errors.New("unable to find closed channel summary") + var ErrCorruptedFwdPkg = errors.New("fwding package db has been corrupted") + var ErrDBReversion = fmt.Errorf("channel db cannot revert to prior version") + var ErrDuplicateInvoice = fmt.Errorf("invoice with payment hash already exists") + var ErrEdgeAlreadyExist = fmt.Errorf("edge already exist") + var ErrEdgeNotFound = fmt.Errorf("edge not found") + var ErrEdgePolicyOptionalFieldNotFound = fmt.Errorf(...) + var ErrGraphNeverPruned = fmt.Errorf("graph never pruned") + var ErrGraphNoEdgesFound = fmt.Errorf("no graph edges exist") + var ErrGraphNodeNotFound = fmt.Errorf("unable to find node") + var ErrGraphNodesNotFound = fmt.Errorf("no graph nodes exist") + var ErrGraphNotFound = fmt.Errorf("graph bucket not initialized") + var ErrInvalidCircuitKeyLen = fmt.Errorf("length of serialized circuit key must be 16 bytes") + var ErrInvoiceAlreadyAccepted = errors.New("invoice already accepted") + var ErrInvoiceAlreadyCanceled = errors.New("invoice already canceled") + var ErrInvoiceAlreadySettled = errors.New("invoice already settled") + var ErrInvoiceNotFound = fmt.Errorf("unable to locate invoice") + var ErrInvoiceStillOpen = errors.New("invoice still open") + var ErrLinkNodesNotFound = fmt.Errorf("no link nodes exist") + var ErrMetaNotFound = fmt.Errorf("unable to locate meta information") + var ErrNoActiveChannels = fmt.Errorf("no active channels exist") + var ErrNoChanDBExists = fmt.Errorf("channel db has not yet been created") + var ErrNoChanInfoFound = fmt.Errorf("no chan info found") + var ErrNoClosedChannels = fmt.Errorf("no channel have been closed yet") + var ErrNoCommitPoint = fmt.Errorf("no commit point found") + var ErrNoCommitmentsFound = fmt.Errorf("no commitments found") + var ErrNoForwardingEvents = fmt.Errorf("no recorded forwarding events") + var ErrNoInvoicesCreated = fmt.Errorf("there are no existing invoices") + var ErrNoPastDeltas = fmt.Errorf("channel has no recorded deltas") + var ErrNoPaymentsCreated = fmt.Errorf("there are no existing payments") + var ErrNoPendingCommit = fmt.Errorf("no pending commits found") + var ErrNoRestoredChannelMutation = fmt.Errorf(...) + var ErrNoRevocationsFound = fmt.Errorf("no revocations found") + var ErrNoWitnesses = fmt.Errorf("no witnesses") + var ErrNodeAliasNotFound = fmt.Errorf("alias for node not found") + var ErrNodeNotFound = fmt.Errorf("link node with target identity not found") + var ErrSourceNodeNotSet = fmt.Errorf("source node does not exist") + var ErrUnknownAddressType = fmt.Errorf("address type cannot be resolved") + var ErrUnknownWitnessType = fmt.Errorf("unknown witness type") + var ErrWaitingProofAlreadyExist = errors.New(...) + var ErrWaitingProofNotFound = errors.New(...) + var ErrZombieEdge = errors.New("edge marked as zombie") + var UnknownPreimage lntypes.Preimage + func DisableLog() + func ErrTooManyExtraOpaqueBytes(numBytes int) error + func ReadElement(r io.Reader, element interface{}) error + func ReadElements(r io.Reader, elements ...interface{}) error + func SerializeHtlcs(b io.Writer, htlcs ...HTLC) error + func UpdatePaymentStatusTx(tx *bbolt.Tx, paymentHash [32]byte, status PaymentStatus) error + func UseLogger(logger btclog.Logger) + func WriteElement(w io.Writer, element interface{}) error + func WriteElements(w io.Writer, elements ...interface{}) error + type AddRef struct + Height uint64 + Index uint16 + func (a *AddRef) Decode(r io.Reader) error + func (a *AddRef) Encode(w io.Writer) error + type ChannelAuthProof struct + BitcoinSig1Bytes []byte + BitcoinSig2Bytes []byte + NodeSig1Bytes []byte + NodeSig2Bytes []byte + func (c *ChannelAuthProof) BitcoinSig1() (*btcec.Signature, error) + func (c *ChannelAuthProof) BitcoinSig2() (*btcec.Signature, error) + func (c *ChannelAuthProof) IsEmpty() bool + func (c *ChannelAuthProof) Node1Sig() (*btcec.Signature, error) + func (c *ChannelAuthProof) Node2Sig() (*btcec.Signature, error) + type ChannelCloseSummary struct + Capacity btcutil.Amount + ChainHash chainhash.Hash + ChanPoint wire.OutPoint + CloseHeight uint32 + CloseType ClosureType + ClosingTXID chainhash.Hash + IsPending bool + LastChanSyncMsg *lnwire.ChannelReestablish + LocalChanConfig ChannelConfig + RemoteCurrentRevocation *btcec.PublicKey + RemoteNextRevocation *btcec.PublicKey + RemotePub *btcec.PublicKey + SettledBalance btcutil.Amount + ShortChanID lnwire.ShortChannelID + TimeLockedBalance btcutil.Amount + type ChannelCommitment struct + CommitFee btcutil.Amount + CommitHeight uint64 + CommitSig []byte + CommitTx *wire.MsgTx + FeePerKw btcutil.Amount + Htlcs []HTLC + LocalBalance lnwire.MilliSatoshi + LocalHtlcIndex uint64 + LocalLogIndex uint64 + RemoteBalance lnwire.MilliSatoshi + RemoteHtlcIndex uint64 + RemoteLogIndex uint64 + type ChannelConfig struct + DelayBasePoint keychain.KeyDescriptor + HtlcBasePoint keychain.KeyDescriptor + MultiSigKey keychain.KeyDescriptor + PaymentBasePoint keychain.KeyDescriptor + RevocationBasePoint keychain.KeyDescriptor + type ChannelConstraints struct + ChanReserve btcutil.Amount + CsvDelay uint16 + DustLimit btcutil.Amount + MaxAcceptedHtlcs uint16 + MaxPendingAmount lnwire.MilliSatoshi + MinHTLC lnwire.MilliSatoshi + type ChannelEdge struct + Info *ChannelEdgeInfo + Policy1 *ChannelEdgePolicy + Policy2 *ChannelEdgePolicy + type ChannelEdgeInfo struct + AuthProof *ChannelAuthProof + BitcoinKey1Bytes [33]byte + BitcoinKey2Bytes [33]byte + Capacity btcutil.Amount + ChainHash chainhash.Hash + ChannelID uint64 + ChannelPoint wire.OutPoint + ExtraOpaqueData []byte + Features []byte + NodeKey1Bytes [33]byte + NodeKey2Bytes [33]byte + func (c *ChannelEdgeInfo) AddNodeKeys(nodeKey1, nodeKey2, bitcoinKey1, bitcoinKey2 *btcec.PublicKey) + func (c *ChannelEdgeInfo) BitcoinKey1() (*btcec.PublicKey, error) + func (c *ChannelEdgeInfo) BitcoinKey2() (*btcec.PublicKey, error) + func (c *ChannelEdgeInfo) FetchOtherNode(tx *bbolt.Tx, thisNodeKey []byte) (*LightningNode, error) + func (c *ChannelEdgeInfo) NodeKey1() (*btcec.PublicKey, error) + func (c *ChannelEdgeInfo) NodeKey2() (*btcec.PublicKey, error) + func (c *ChannelEdgeInfo) OtherNodeKeyBytes(thisNodeKey []byte) ([]byte, error) + type ChannelEdgePolicy struct + ChannelFlags lnwire.ChanUpdateChanFlags + ChannelID uint64 + ExtraOpaqueData []byte + FeeBaseMSat lnwire.MilliSatoshi + FeeProportionalMillionths lnwire.MilliSatoshi + LastUpdate time.Time + MaxHTLC lnwire.MilliSatoshi + MessageFlags lnwire.ChanUpdateMsgFlags + MinHTLC lnwire.MilliSatoshi + Node *LightningNode + SigBytes []byte + TimeLockDelta uint16 + func (c *ChannelEdgePolicy) IsDisabled() bool + func (c *ChannelEdgePolicy) Signature() (*btcec.Signature, error) + type ChannelGraph struct + func (c *ChannelGraph) AddChannelEdge(edge *ChannelEdgeInfo) error + func (c *ChannelGraph) AddLightningNode(node *LightningNode) error + func (c *ChannelGraph) ChanUpdatesInHorizon(startTime, endTime time.Time) ([]ChannelEdge, error) + func (c *ChannelGraph) ChannelID(chanPoint *wire.OutPoint) (uint64, error) + func (c *ChannelGraph) ChannelView() ([]EdgePoint, error) + func (c *ChannelGraph) Database() *DB + func (c *ChannelGraph) DeleteChannelEdges(chanIDs ...uint64) error + func (c *ChannelGraph) DeleteLightningNode(nodePub *btcec.PublicKey) error + func (c *ChannelGraph) DisconnectBlockAtHeight(height uint32) ([]*ChannelEdgeInfo, error) + func (c *ChannelGraph) FetchChanInfos(chanIDs []uint64) ([]ChannelEdge, error) + func (c *ChannelGraph) FetchChannelEdgesByID(chanID uint64) (*ChannelEdgeInfo, *ChannelEdgePolicy, *ChannelEdgePolicy, error) + func (c *ChannelGraph) FetchChannelEdgesByOutpoint(op *wire.OutPoint) (*ChannelEdgeInfo, *ChannelEdgePolicy, *ChannelEdgePolicy, error) + func (c *ChannelGraph) FetchLightningNode(pub *btcec.PublicKey) (*LightningNode, error) + func (c *ChannelGraph) FilterChannelRange(startHeight, endHeight uint32) ([]uint64, error) + func (c *ChannelGraph) FilterKnownChanIDs(chanIDs []uint64) ([]uint64, error) + func (c *ChannelGraph) ForEachChannel(cb func(*ChannelEdgeInfo, *ChannelEdgePolicy, *ChannelEdgePolicy) error) error + func (c *ChannelGraph) ForEachNode(tx *bbolt.Tx, cb func(*bbolt.Tx, *LightningNode) error) error + func (c *ChannelGraph) HasChannelEdge(chanID uint64) (time.Time, time.Time, bool, bool, error) + func (c *ChannelGraph) HasLightningNode(nodePub [33]byte) (time.Time, bool, error) + func (c *ChannelGraph) HighestChanID() (uint64, error) + func (c *ChannelGraph) IsPublicNode(pubKey [33]byte) (bool, error) + func (c *ChannelGraph) IsZombieEdge(chanID uint64) (bool, [33]byte, [33]byte) + func (c *ChannelGraph) LookupAlias(pub *btcec.PublicKey) (string, error) + func (c *ChannelGraph) MarkEdgeLive(chanID uint64) error + func (c *ChannelGraph) NewChannelEdgePolicy() *ChannelEdgePolicy + func (c *ChannelGraph) NodeUpdatesInHorizon(startTime, endTime time.Time) ([]LightningNode, error) + func (c *ChannelGraph) PruneGraph(spentOutputs []*wire.OutPoint, blockHash *chainhash.Hash, blockHeight uint32) ([]*ChannelEdgeInfo, error) + func (c *ChannelGraph) PruneGraphNodes() error + func (c *ChannelGraph) PruneTip() (*chainhash.Hash, uint32, error) + func (c *ChannelGraph) SetSourceNode(node *LightningNode) error + func (c *ChannelGraph) SourceNode() (*LightningNode, error) + func (c *ChannelGraph) UpdateChannelEdge(edge *ChannelEdgeInfo) error + func (c *ChannelGraph) UpdateEdgePolicy(edge *ChannelEdgePolicy) error + type ChannelPackager struct + func NewChannelPackager(source lnwire.ShortChannelID) *ChannelPackager + func (*ChannelPackager) AddFwdPkg(tx *bbolt.Tx, fwdPkg *FwdPkg) error + func (p *ChannelPackager) AckAddHtlcs(tx *bbolt.Tx, addRefs ...AddRef) error + func (p *ChannelPackager) AckSettleFails(tx *bbolt.Tx, settleFailRefs ...SettleFailRef) error + func (p *ChannelPackager) LoadFwdPkgs(tx *bbolt.Tx) ([]*FwdPkg, error) + func (p *ChannelPackager) RemovePkg(tx *bbolt.Tx, height uint64) error + func (p *ChannelPackager) SetFwdFilter(tx *bbolt.Tx, height uint64, fwdFilter *PkgFilter) error + type ChannelShell struct + Chan *OpenChannel + NodeAddrs []net.Addr + type ChannelSnapshot struct + Capacity btcutil.Amount + ChainHash chainhash.Hash + ChannelPoint wire.OutPoint + RemoteIdentity btcec.PublicKey + TotalMSatReceived lnwire.MilliSatoshi + TotalMSatSent lnwire.MilliSatoshi + type ChannelStatus uint8 + var ChanStatusBorked ChannelStatus = 1 + var ChanStatusCommitBroadcasted ChannelStatus = 1 << 1 + var ChanStatusDefault ChannelStatus + var ChanStatusLocalDataLoss ChannelStatus = 1 << 2 + var ChanStatusRestored ChannelStatus = 1 << 3 + func (c ChannelStatus) String() string + type ChannelType uint8 + type CircuitKey struct + ChanID lnwire.ShortChannelID + HtlcID uint64 + func (k *CircuitKey) Decode(r io.Reader) error + func (k *CircuitKey) Encode(w io.Writer) error + func (k *CircuitKey) SetBytes(bs []byte) error + func (k CircuitKey) Bytes() []byte + func (k CircuitKey) String() string + type ClosureType uint8 + const Abandoned + const BreachClose + const CooperativeClose + const FundingCanceled + const LocalForceClose + const RemoteForceClose + type CommitDiff struct + AddAcks []AddRef + ClosedCircuitKeys []CircuitKey + CommitSig *lnwire.CommitSig + Commitment ChannelCommitment + LogUpdates []LogUpdate + OpenedCircuitKeys []CircuitKey + SettleFailAcks []SettleFailRef + type ContractState uint8 + const ContractAccepted + const ContractCanceled + const ContractOpen + const ContractSettled + func (c ContractState) String() string + type ContractTerm struct + PaymentPreimage lntypes.Preimage + State ContractState + Value lnwire.MilliSatoshi + type DB struct + func Open(dbPath string, modifiers ...OptionModifier) (*DB, error) + func (d *DB) AcceptOrSettleInvoice(paymentHash [32]byte, amtPaid lnwire.MilliSatoshi) (*Invoice, error) + func (d *DB) AddInvoice(newInvoice *Invoice, paymentHash lntypes.Hash) (uint64, error) + func (d *DB) AddrsForNode(nodePub *btcec.PublicKey) ([]net.Addr, error) + func (d *DB) CancelInvoice(paymentHash lntypes.Hash) (*Invoice, error) + func (d *DB) ChannelGraph() *ChannelGraph + func (d *DB) FetchAllChannels() ([]*OpenChannel, error) + func (d *DB) FetchAllInvoices(pendingOnly bool) ([]Invoice, error) + func (d *DB) FetchAllOpenChannels() ([]*OpenChannel, error) + func (d *DB) FetchChannel(chanPoint wire.OutPoint) (*OpenChannel, error) + func (d *DB) FetchClosedChannel(chanID *wire.OutPoint) (*ChannelCloseSummary, error) + func (d *DB) FetchClosedChannelForID(cid lnwire.ChannelID) (*ChannelCloseSummary, error) + func (d *DB) FetchClosedChannels(pendingOnly bool) ([]*ChannelCloseSummary, error) + func (d *DB) FetchMeta(tx *bbolt.Tx) (*Meta, error) + func (d *DB) FetchOpenChannels(nodeID *btcec.PublicKey) ([]*OpenChannel, error) + func (d *DB) FetchPendingChannels() ([]*OpenChannel, error) + func (d *DB) FetchWaitingCloseChannels() ([]*OpenChannel, error) + func (d *DB) ForwardingLog() *ForwardingLog + func (d *DB) InvoicesAddedSince(sinceAddIndex uint64) ([]Invoice, error) + func (d *DB) InvoicesSettledSince(sinceSettleIndex uint64) ([]Invoice, error) + func (d *DB) LookupInvoice(paymentHash [32]byte) (Invoice, error) + func (d *DB) MarkChanFullyClosed(chanPoint *wire.OutPoint) error + func (d *DB) NewWitnessCache() *WitnessCache + func (d *DB) Path() string + func (d *DB) PruneLinkNodes() error + func (d *DB) PutMeta(meta *Meta) error + func (d *DB) QueryInvoices(q InvoiceQuery) (InvoiceSlice, error) + func (d *DB) RestoreChannelShells(channelShells ...*ChannelShell) error + func (d *DB) SettleHoldInvoice(preimage lntypes.Preimage) (*Invoice, error) + func (d *DB) Wipe() error + func (db *DB) AddPayment(payment *OutgoingPayment) error + func (db *DB) DeleteAllPayments() error + func (db *DB) DeleteLinkNode(identity *btcec.PublicKey) error + func (db *DB) FetchAllLinkNodes() ([]*LinkNode, error) + func (db *DB) FetchAllPayments() ([]*OutgoingPayment, error) + func (db *DB) FetchLinkNode(identity *btcec.PublicKey) (*LinkNode, error) + func (db *DB) FetchPaymentStatus(paymentHash [32]byte) (PaymentStatus, error) + func (db *DB) NewLinkNode(bitNet wire.BitcoinNet, pub *btcec.PublicKey, addrs ...net.Addr) *LinkNode + func (db *DB) UpdatePaymentStatus(paymentHash [32]byte, status PaymentStatus) error + type EdgePoint struct + FundingPkScript []byte + OutPoint wire.OutPoint + func (e *EdgePoint) String() string + type ForwardingEvent struct + AmtIn lnwire.MilliSatoshi + AmtOut lnwire.MilliSatoshi + IncomingChanID lnwire.ShortChannelID + OutgoingChanID lnwire.ShortChannelID + Timestamp time.Time + type ForwardingEventQuery struct + EndTime time.Time + IndexOffset uint32 + NumMaxEvents uint32 + StartTime time.Time + type ForwardingLog struct + func (f *ForwardingLog) AddForwardingEvents(events []ForwardingEvent) error + func (f *ForwardingLog) Query(q ForwardingEventQuery) (ForwardingLogTimeSlice, error) + type ForwardingLogTimeSlice struct + ForwardingEvents []ForwardingEvent + LastIndexOffset uint32 + type FwdOperator interface + type FwdPackager interface + AckAddHtlcs func(tx *bbolt.Tx, addRefs ...AddRef) error + AddFwdPkg func(tx *bbolt.Tx, fwdPkg *FwdPkg) error + LoadFwdPkgs func(tx *bbolt.Tx) ([]*FwdPkg, error) + RemovePkg func(tx *bbolt.Tx, height uint64) error + SetFwdFilter func(tx *bbolt.Tx, height uint64, fwdFilter *PkgFilter) error + type FwdPkg struct + AckFilter *PkgFilter + Adds []LogUpdate + FwdFilter *PkgFilter + Height uint64 + SettleFailFilter *PkgFilter + SettleFails []LogUpdate + Source lnwire.ShortChannelID + State FwdState + func NewFwdPkg(source lnwire.ShortChannelID, height uint64, ...) *FwdPkg + func (f *FwdPkg) ID() []byte + func (f *FwdPkg) String() string + type FwdState byte + const FwdStateCompleted + const FwdStateLockedIn + const FwdStateProcessed + type GlobalFwdPkgReader interface + LoadChannelFwdPkgs func(tx *bbolt.Tx, source lnwire.ShortChannelID) ([]*FwdPkg, error) + type HTLC struct + Amt lnwire.MilliSatoshi + HtlcIndex uint64 + Incoming bool + LogIndex uint64 + OnionBlob []byte + OutputIndex int32 + RHash [32]byte + RefundTimeout uint32 + Signature []byte + func DeserializeHtlcs(r io.Reader) ([]HTLC, error) + func (h *HTLC) Copy() HTLC + type Invoice struct + AddIndex uint64 + AmtPaid lnwire.MilliSatoshi + CreationDate time.Time + Memo []byte + PaymentRequest []byte + Receipt []byte + SettleDate time.Time + SettleIndex uint64 + Terms ContractTerm + type InvoiceQuery struct + IndexOffset uint64 + NumMaxInvoices uint64 + PendingOnly bool + Reversed bool + type InvoiceSlice struct + FirstIndexOffset uint64 + Invoices []Invoice + LastIndexOffset uint64 + type LightningNode struct + Addresses []net.Addr + Alias string + AuthSigBytes []byte + Color color.RGBA + ExtraOpaqueData []byte + Features *lnwire.FeatureVector + HaveNodeAnnouncement bool + LastUpdate time.Time + PubKeyBytes [33]byte + func (l *LightningNode) AddPubKey(key *btcec.PublicKey) + func (l *LightningNode) AuthSig() (*btcec.Signature, error) + func (l *LightningNode) ForEachChannel(tx *bbolt.Tx, ...) error + func (l *LightningNode) NodeAnnouncement(signed bool) (*lnwire.NodeAnnouncement, error) + func (l *LightningNode) PubKey() (*btcec.PublicKey, error) + type LinkNode struct + Addresses []net.Addr + IdentityPub *btcec.PublicKey + LastSeen time.Time + Network wire.BitcoinNet + func (l *LinkNode) AddAddress(addr net.Addr) error + func (l *LinkNode) Sync() error + func (l *LinkNode) UpdateLastSeen(lastSeen time.Time) error + type LogUpdate struct + LogIndex uint64 + UpdateMsg lnwire.Message + func (l *LogUpdate) Decode(r io.Reader) error + func (l *LogUpdate) Encode(w io.Writer) error + type Meta struct + DbVersionNumber uint32 + type OpenChannel struct + Capacity btcutil.Amount + ChainHash chainhash.Hash + ChanType ChannelType + ChannelFlags lnwire.FundingFlag + Db *DB + FundingBroadcastHeight uint32 + FundingOutpoint wire.OutPoint + FundingTxn *wire.MsgTx + IdentityPub *btcec.PublicKey + IsInitiator bool + IsPending bool + LocalChanCfg ChannelConfig + LocalCommitment ChannelCommitment + NumConfsRequired uint16 + Packager FwdPackager + RemoteChanCfg ChannelConfig + RemoteCommitment ChannelCommitment + RemoteCurrentRevocation *btcec.PublicKey + RemoteNextRevocation *btcec.PublicKey + RevocationProducer shachain.Producer + RevocationStore shachain.Store + ShortChannelID lnwire.ShortChannelID + TotalMSatReceived lnwire.MilliSatoshi + TotalMSatSent lnwire.MilliSatoshi + func (c *OpenChannel) AckAddHtlcs(addRefs ...AddRef) error + func (c *OpenChannel) AckSettleFails(settleFailRefs ...SettleFailRef) error + func (c *OpenChannel) AdvanceCommitChainTail(fwdPkg *FwdPkg) error + func (c *OpenChannel) AppendRemoteCommitChain(diff *CommitDiff) error + func (c *OpenChannel) ApplyChanStatus(status ChannelStatus) error + func (c *OpenChannel) ChanStatus() ChannelStatus + func (c *OpenChannel) ClearChanStatus(status ChannelStatus) error + func (c *OpenChannel) CloseChannel(summary *ChannelCloseSummary) error + func (c *OpenChannel) CommitmentHeight() (uint64, error) + func (c *OpenChannel) DataLossCommitPoint() (*btcec.PublicKey, error) + func (c *OpenChannel) FindPreviousState(updateNum uint64) (*ChannelCommitment, error) + func (c *OpenChannel) FullSync() error + func (c *OpenChannel) HasChanStatus(status ChannelStatus) bool + func (c *OpenChannel) InsertNextRevocation(revKey *btcec.PublicKey) error + func (c *OpenChannel) LatestCommitments() (*ChannelCommitment, *ChannelCommitment, error) + func (c *OpenChannel) LoadFwdPkgs() ([]*FwdPkg, error) + func (c *OpenChannel) MarkAsOpen(openLoc lnwire.ShortChannelID) error + func (c *OpenChannel) MarkBorked() error + func (c *OpenChannel) MarkCommitmentBroadcasted() error + func (c *OpenChannel) MarkDataLoss(commitPoint *btcec.PublicKey) error + func (c *OpenChannel) NextLocalHtlcIndex() (uint64, error) + func (c *OpenChannel) RefreshShortChanID() error + func (c *OpenChannel) RemoteCommitChainTip() (*CommitDiff, error) + func (c *OpenChannel) RemoteRevocationStore() (shachain.Store, error) + func (c *OpenChannel) RemoveFwdPkg(height uint64) error + func (c *OpenChannel) RevocationLogTail() (*ChannelCommitment, error) + func (c *OpenChannel) SetFwdFilter(height uint64, fwdFilter *PkgFilter) error + func (c *OpenChannel) ShortChanID() lnwire.ShortChannelID + func (c *OpenChannel) Snapshot() *ChannelSnapshot + func (c *OpenChannel) SyncPending(addr net.Addr, pendingHeight uint32) error + func (c *OpenChannel) UpdateCommitment(newCommitment *ChannelCommitment) error + type OptionModifier func(*Options) + func OptionSetChannelCacheSize(n int) OptionModifier + func OptionSetRejectCacheSize(n int) OptionModifier + type Options struct + ChannelCacheSize int + RejectCacheSize int + func DefaultOptions() Options + type OutgoingPayment struct + Fee lnwire.MilliSatoshi + Path [][33]byte + PaymentPreimage [32]byte + TimeLockLength uint32 + type PaymentStatus byte + const StatusCompleted + const StatusGrounded + const StatusInFlight + func FetchPaymentStatusTx(tx *bbolt.Tx, paymentHash [32]byte) (PaymentStatus, error) + func (ps *PaymentStatus) FromBytes(status []byte) error + func (ps PaymentStatus) Bytes() []byte + func (ps PaymentStatus) String() string + type PkgFilter struct + func NewPkgFilter(count uint16) *PkgFilter + func (f *PkgFilter) Contains(i uint16) bool + func (f *PkgFilter) Count() uint16 + func (f *PkgFilter) Decode(r io.Reader) error + func (f *PkgFilter) Encode(w io.Writer) error + func (f *PkgFilter) Equal(f2 *PkgFilter) bool + func (f *PkgFilter) IsFull() bool + func (f *PkgFilter) Set(i uint16) + func (f *PkgFilter) Size() uint16 + type SettleFailAcker interface + AckSettleFails func(tx *bbolt.Tx, settleFailRefs ...SettleFailRef) error + type SettleFailRef struct + Height uint64 + Index uint16 + Source lnwire.ShortChannelID + type SwitchPackager struct + func NewSwitchPackager() *SwitchPackager + func (*SwitchPackager) AckSettleFails(tx *bbolt.Tx, settleFailRefs ...SettleFailRef) error + func (*SwitchPackager) LoadChannelFwdPkgs(tx *bbolt.Tx, source lnwire.ShortChannelID) ([]*FwdPkg, error) + type UnknownElementType struct + func NewUnknownElementType(method string, el interface{}) UnknownElementType + func (e UnknownElementType) Error() string + type WaitingProof struct + func NewWaitingProof(isRemote bool, proof *lnwire.AnnounceSignatures) *WaitingProof + func (p *WaitingProof) Decode(r io.Reader) error + func (p *WaitingProof) Encode(w io.Writer) error + func (p *WaitingProof) Key() WaitingProofKey + func (p *WaitingProof) OppositeKey() WaitingProofKey + type WaitingProofKey [9]byte + type WaitingProofStore struct + func NewWaitingProofStore(db *DB) (*WaitingProofStore, error) + func (s *WaitingProofStore) Add(proof *WaitingProof) error + func (s *WaitingProofStore) ForAll(cb func(*WaitingProof) error) error + func (s *WaitingProofStore) Get(key WaitingProofKey) (*WaitingProof, error) + func (s *WaitingProofStore) Remove(key WaitingProofKey) error + type WitnessCache struct + func (w *WitnessCache) AddSha256Witnesses(preimages ...lntypes.Preimage) error + func (w *WitnessCache) DeleteSha256Witness(hash lntypes.Hash) error + func (w *WitnessCache) DeleteWitnessClass(wType WitnessType) error + func (w *WitnessCache) LookupSha256Witness(hash lntypes.Hash) (lntypes.Preimage, error) + type WitnessType uint8 + var Sha256HashWitness WitnessType = 1