Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

migration_01_to_11

package

Go to main page

Versions in this module

v0

v0.7.1

May 27, 2024

v0.7.0

May 16, 2024

v0.6.0

Feb 22, 2024

v0.5.0

Dec 4, 2023

Changes in this version

+ const DefaultDBTimeout

type Options

+ DBTimeout time.Duration

v0.4.0

Jun 9, 2023

v0.3.8

Apr 7, 2023

v0.3.7

Oct 10, 2022

v0.3.6

Aug 5, 2022

v0.3.5

Aug 4, 2022

v0.3.4

Jan 20, 2022

v0.3.4-rc2

Jan 5, 2022

v0.3.4-rc1

Dec 22, 2021

v0.3.3

Apr 23, 2021

v0.3.1

Feb 19, 2021

v0.3.0

Jan 21, 2021

Changes in this version

+ const DefaultChannelCacheSize

+ const DefaultRejectCacheSize

+ const MaxAllowedExtraOpaqueBytes

+ const MaxMemoSize

+ const MaxPaymentRequestSize

+ const MaxReceiptSize

+ const VertexSize

+ var ErrEdgeNotFound = fmt.Errorf("edge not found")

+ var ErrEdgePolicyOptionalFieldNotFound = fmt.Errorf(...)

+ var ErrGraphNodeNotFound = fmt.Errorf("unable to find node")

+ var ErrGraphNotFound = fmt.Errorf("graph bucket not initialized")

+ var ErrNoClosedChannels = fmt.Errorf("no channel have been closed yet")

+ var ErrNoInvoicesCreated = fmt.Errorf("there are no existing invoices")

+ var ErrNoPaymentsCreated = fmt.Errorf("there are no existing payments")

+ var ErrNoRouteHopsProvided = fmt.Errorf("empty route hops provided")

+ var ErrSourceNodeNotSet = fmt.Errorf("source node does not exist")

+ var ErrUnknownAddressType = fmt.Errorf("address type cannot be resolved")

+ func ErrTooManyExtraOpaqueBytes(numBytes int) error

+ func MigrateEdgePolicies(tx kvdb.RwTx) error

+ func MigrateGossipMessageStoreKeys(tx kvdb.RwTx) error

+ func MigrateInvoiceTimeSeries(tx kvdb.RwTx) error

+ func MigrateInvoiceTimeSeriesOutgoingPayments(tx kvdb.RwTx) error

+ func MigrateInvoices(tx kvdb.RwTx) error

+ func MigrateNodeAndEdgeUpdateIndex(tx kvdb.RwTx) error

+ func MigrateOptionalChannelCloseSummaryFields(tx kvdb.RwTx) error

+ func MigrateOutgoingPayments(tx kvdb.RwTx) error

+ func MigratePruneEdgeUpdateIndex(tx kvdb.RwTx) error

+ func MigrateRouteSerialization(tx kvdb.RwTx) error

+ func PaymentStatusesMigration(tx kvdb.RwTx) error

+ func ReadElement(r io.Reader, element interface{}) error

+ func ReadElements(r io.Reader, elements ...interface{}) error

+ func SerializeRoute(w io.Writer, r Route) error

+ func UseLogger(logger slog.Logger)

+ func WriteElement(w io.Writer, element interface{}) error

+ func WriteElements(w io.Writer, elements ...interface{}) error

+ type ChannelAuthProof struct

+ DecredSig1Bytes []byte

+ DecredSig2Bytes []byte

+ NodeSig1Bytes []byte

+ NodeSig2Bytes []byte

+ func (c *ChannelAuthProof) IsEmpty() bool

+ type ChannelCloseSummary struct

+ Capacity dcrutil.Amount

+ ChainHash chainhash.Hash

+ ChanPoint wire.OutPoint

+ CloseHeight uint32

+ CloseType ClosureType

+ ClosingTXID chainhash.Hash

+ IsPending bool

+ LastChanSyncMsg *lnwire.ChannelReestablish

+ LocalChanConfig ChannelConfig

+ RemoteCurrentRevocation *secp256k1.PublicKey

+ RemoteNextRevocation *secp256k1.PublicKey

+ RemotePub *secp256k1.PublicKey

+ SettledBalance dcrutil.Amount

+ ShortChanID lnwire.ShortChannelID

+ TimeLockedBalance dcrutil.Amount

+ type ChannelCommitment struct

+ CommitFee dcrutil.Amount

+ CommitHeight uint64

+ CommitSig []byte

+ CommitTx *wire.MsgTx

+ FeePerKB dcrutil.Amount

+ Htlcs []HTLC

+ LocalBalance lnwire.MilliAtom

+ LocalHtlcIndex uint64

+ LocalLogIndex uint64

+ RemoteBalance lnwire.MilliAtom

+ 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 dcrutil.Amount

+ CsvDelay uint16

+ DustLimit dcrutil.Amount

+ MaxAcceptedHtlcs uint16

+ MaxPendingAmount lnwire.MilliAtom

+ MinHTLC lnwire.MilliAtom

+ type ChannelEdgeInfo struct

+ AuthProof *ChannelAuthProof

+ Capacity dcrutil.Amount

+ ChainHash chainhash.Hash

+ ChannelID uint64

+ ChannelPoint wire.OutPoint

+ DecredKey1Bytes [33]byte

+ DecredKey2Bytes [33]byte

+ ExtraOpaqueData []byte

+ Features []byte

+ NodeKey1Bytes [33]byte

+ NodeKey2Bytes [33]byte

+ type ChannelEdgePolicy struct

+ ChannelFlags lnwire.ChanUpdateChanFlags

+ ChannelID uint64

+ ExtraOpaqueData []byte

+ FeeBaseMAtoms lnwire.MilliAtom

+ FeeProportionalMillionths lnwire.MilliAtom

+ LastUpdate time.Time

+ MaxHTLC lnwire.MilliAtom

+ MessageFlags lnwire.ChanUpdateMsgFlags

+ MinHTLC lnwire.MilliAtom

+ Node *LightningNode

+ SigBytes []byte

+ TimeLockDelta uint16

+ func (c *ChannelEdgePolicy) IsDisabled() bool

+ type ChannelGraph struct

+ func (c *ChannelGraph) SetSourceNode(node *LightningNode) error

+ func (c *ChannelGraph) SourceNode() (*LightningNode, error)

+ 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

+ const SingleFunderBit

+ type CircuitKey struct

+ ChanID lnwire.ShortChannelID

+ HtlcID uint64

+ func (k CircuitKey) String() string

+ type ClosureType uint8

+ const RemoteForceClose

+ 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.MilliAtom

+ type DB struct

+ func Open(dbPath string, modifiers ...OptionModifier) (*DB, error)

+ func (d *DB) ChannelGraph() *ChannelGraph

+ func (d *DB) CompareAndStoreAccountID(id []byte) error

+ func (d *DB) FetchAllInvoices(pendingOnly bool) ([]Invoice, error)

+ func (d *DB) FetchClosedChannels(pendingOnly bool) ([]*ChannelCloseSummary, error)

+ func (d *DB) NextKeyFamilyIndex(keyFamily uint32) (uint32, error)

+ func (db *DB) FetchPayments() ([]*Payment, error)

+ type FailureReason byte

+ const FailureReasonError

+ const FailureReasonIncorrectPaymentDetails

+ const FailureReasonNoRoute

+ const FailureReasonTimeout

+ func (r FailureReason) String() string

+ type HTLC struct

+ Amt lnwire.MilliAtom

+ HtlcIndex uint64

+ Incoming bool

+ LogIndex uint64

+ OnionBlob []byte

+ OutputIndex int32

+ RHash [32]byte

+ RefundTimeout uint32

+ Signature []byte

+ type Hop struct

+ AmtToForward lnwire.MilliAtom

+ ChannelID uint64

+ LegacyPayload bool

+ OutgoingTimeLock uint32

+ PubKeyBytes Vertex

+ TLVRecords []tlv.Record

+ func (h *Hop) PackHopPayload(w io.Writer, nextChanID uint64) error

+ type HtlcState uint8

+ type Invoice struct

+ AddIndex uint64

+ AmtPaid lnwire.MilliAtom

+ CreationDate time.Time

+ Expiry time.Duration

+ FinalCltvDelta int32

+ Htlcs map[CircuitKey]*InvoiceHTLC

+ Memo []byte

+ PaymentRequest []byte

+ Receipt []byte

+ SettleDate time.Time

+ SettleIndex uint64

+ Terms ContractTerm

+ type InvoiceHTLC struct

+ AcceptHeight uint32

+ AcceptTime time.Time

+ Amt lnwire.MilliAtom

+ Expiry uint32

+ ResolveTime time.Time

+ State HtlcState

+ 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) PubKey() (*secp256k1.PublicKey, error)

+ type Meta struct

+ DbVersionNumber uint32

+ type OpenChannel struct

+ Capacity dcrutil.Amount

+ ChainHash chainhash.Hash

+ ChanType ChannelType

+ ChannelFlags lnwire.FundingFlag

+ Db *DB

+ FundingBroadcastHeight uint32

+ FundingOutpoint wire.OutPoint

+ FundingTxn *wire.MsgTx

+ IdentityPub *secp256k1.PublicKey

+ IsInitiator bool

+ IsPending bool

+ LocalChanCfg ChannelConfig

+ LocalCommitment ChannelCommitment

+ NumConfsRequired uint16

+ RemoteChanCfg ChannelConfig

+ RemoteCommitment ChannelCommitment

+ RemoteCurrentRevocation *secp256k1.PublicKey

+ RemoteNextRevocation *secp256k1.PublicKey

+ RevocationProducer shachain.Producer

+ RevocationStore shachain.Store

+ ShortChannelID lnwire.ShortChannelID

+ TotalMAtomsReceived lnwire.MilliAtom

+ TotalMAtomsSent lnwire.MilliAtom

+ func (c *OpenChannel) ShortChanID() lnwire.ShortChannelID

+ type OptionModifier func(*Options)

+ type Options struct

+ ChannelCacheSize int

+ NoFreelistSync bool

+ RejectCacheSize int

+ func DefaultOptions() Options

+ type Payment struct

+ Attempt *PaymentAttemptInfo

+ Failure *FailureReason

+ Info *PaymentCreationInfo

+ PaymentPreimage *lntypes.Preimage

+ Status PaymentStatus

+ type PaymentAttemptInfo struct

+ PaymentID uint64

+ Route Route

+ SessionKey *secp256k1.PrivateKey

+ type PaymentCreationInfo struct

+ CreationDate time.Time

+ PaymentHash lntypes.Hash

+ PaymentRequest []byte

+ Value lnwire.MilliAtom

+ type PaymentStatus byte

+ const StatusFailed

+ const StatusInFlight

+ const StatusSucceeded

+ const StatusUnknown

+ func (ps *PaymentStatus) FromBytes(status []byte) error

+ func (ps PaymentStatus) Bytes() []byte

+ func (ps PaymentStatus) String() string

+ type Route struct

+ Hops []*Hop

+ SourcePubKey Vertex

+ TotalAmount lnwire.MilliAtom

+ TotalTimeLock uint32

+ func DeserializeRoute(r io.Reader) (Route, error)

+ func NewRouteFromHops(amtToSend lnwire.MilliAtom, timeLock uint32, sourceVertex Vertex, hops []*Hop) (*Route, error)

+ func (r *Route) HopFee(hopIndex int) lnwire.MilliAtom

+ func (r *Route) String() string

+ func (r *Route) ToSphinxPath() (*sphinx.PaymentPath, error)

+ func (r *Route) TotalFees() lnwire.MilliAtom

+ type UnknownElementType struct

+ func (e UnknownElementType) Error() string

+ type Vertex [VertexSize]byte

+ func NewVertex(pub *secp256k1.PublicKey) Vertex

+ func NewVertexFromBytes(b []byte) (Vertex, error)

+ func NewVertexFromStr(v string) (Vertex, error)

+ func (v Vertex) String() string

v0.3.0-rc4

Nov 24, 2020

v0.3.0-rc3

Nov 12, 2020

v0.3.0-rc2

Oct 30, 2020

v0.3.0-rc1

Oct 16, 2020