sqlc

package
v1.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2025 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddV1ChannelProofParams added in v1.0.11

type AddV1ChannelProofParams struct {
	Scid              []byte
	Node1Signature    []byte
	Node2Signature    []byte
	Bitcoin1Signature []byte
	Bitcoin2Signature []byte
}

type AmpSubInvoice

type AmpSubInvoice struct {
	SetID       []byte
	State       int16
	CreatedAt   time.Time
	SettledAt   sql.NullTime
	SettleIndex sql.NullInt64
	InvoiceID   int64
}

type AmpSubInvoiceHtlc

type AmpSubInvoiceHtlc struct {
	InvoiceID  int64
	SetID      []byte
	HtlcID     int64
	RootShare  []byte
	ChildIndex int64
	Hash       []byte
	Preimage   []byte
}

type ChannelAndNodeIDs added in v1.0.11

type ChannelAndNodeIDs interface {
	// Channel returns the GraphChannel associated with this interface.
	Channel() GraphChannel

	// Node1Pub returns the public key of the first node as a byte slice.
	Node1Pub() []byte

	// Node2Pub returns the public key of the second node as a byte slice.
	Node2Pub() []byte
}

ChannelAndNodeIDs is an interface that provides access to a channel and its two node public keys.

type ChannelAndNodes added in v1.0.11

type ChannelAndNodes interface {
	// Channel returns the GraphChannel associated with this interface.
	Channel() GraphChannel

	// Node1 returns the first GraphNode associated with this channel.
	Node1() GraphNode

	// Node2 returns the second GraphNode associated with this channel.
	Node2() GraphNode
}

ChannelAndNodes is an interface that provides access to a channel and its two nodes.

type CreateChannelParams added in v1.0.10

type CreateChannelParams struct {
	Version           int16
	Scid              []byte
	NodeID1           int64
	NodeID2           int64
	Outpoint          string
	Capacity          sql.NullInt64
	BitcoinKey1       []byte
	BitcoinKey2       []byte
	Node1Signature    []byte
	Node2Signature    []byte
	Bitcoin1Signature []byte
	Bitcoin2Signature []byte
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteExtraNodeTypeParams added in v1.0.10

type DeleteExtraNodeTypeParams struct {
	NodeID int64
	Type   int64
}

type DeleteInvoiceParams

type DeleteInvoiceParams struct {
	AddIndex    sql.NullInt64
	Hash        []byte
	SettleIndex sql.NullInt64
	PaymentAddr []byte
}

type DeleteNodeByPubKeyParams added in v1.0.10

type DeleteNodeByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type DeleteNodeFeatureParams added in v1.0.10

type DeleteNodeFeatureParams struct {
	NodeID     int64
	FeatureBit int32
}

type DeletePruneLogEntriesInRangeParams added in v1.0.11

type DeletePruneLogEntriesInRangeParams struct {
	StartHeight int64
	EndHeight   int64
}

type DeleteZombieChannelParams added in v1.0.11

type DeleteZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type FetchAMPSubInvoiceHTLCsParams

type FetchAMPSubInvoiceHTLCsParams struct {
	InvoiceID int64
	SetID     []byte
}

type FetchAMPSubInvoiceHTLCsRow

type FetchAMPSubInvoiceHTLCsRow struct {
	SetID        []byte
	RootShare    []byte
	ChildIndex   int64
	Hash         []byte
	Preimage     []byte
	ID           int64
	ChanID       string
	HtlcID       int64
	AmountMsat   int64
	TotalMppMsat sql.NullInt64
	AcceptHeight int32
	AcceptTime   time.Time
	ExpiryHeight int32
	State        int16
	ResolveTime  sql.NullTime
	InvoiceID    int64
}

type FetchAMPSubInvoicesParams

type FetchAMPSubInvoicesParams struct {
	InvoiceID int64
	SetID     []byte
}

type FetchSettledAMPSubInvoicesParams

type FetchSettledAMPSubInvoicesParams struct {
	SettleIndexGet sql.NullInt64
	SettleIndexLet sql.NullInt64
}

type FetchSettledAMPSubInvoicesRow

type FetchSettledAMPSubInvoicesRow struct {
	SetID              []byte
	AmpSettleIndex     sql.NullInt64
	AmpSettledAt       sql.NullTime
	ID                 int64
	Hash               []byte
	Preimage           []byte
	SettleIndex        sql.NullInt64
	SettledAt          sql.NullTime
	Memo               sql.NullString
	AmountMsat         int64
	CltvDelta          sql.NullInt32
	Expiry             int32
	PaymentAddr        []byte
	PaymentRequest     sql.NullString
	PaymentRequestHash []byte
	State              int16
	AmountPaidMsat     int64
	IsAmp              bool
	IsHodl             bool
	IsKeysend          bool
	CreatedAt          time.Time
}

type FilterInvoicesParams

type FilterInvoicesParams struct {
	AddIndexGet    sql.NullInt64
	AddIndexLet    sql.NullInt64
	SettleIndexGet sql.NullInt64
	SettleIndexLet sql.NullInt64
	State          sql.NullInt16
	CreatedAfter   sql.NullTime
	CreatedBefore  sql.NullTime
	PendingOnly    interface{}
	Reverse        interface{}
	NumOffset      int32
	NumLimit       int32
}

type GetChannelAndNodesBySCIDParams added in v1.0.11

type GetChannelAndNodesBySCIDParams struct {
	Scid    []byte
	Version int16
}

type GetChannelAndNodesBySCIDRow added in v1.0.11

type GetChannelAndNodesBySCIDRow struct {
	ID                int64
	Version           int16
	Scid              []byte
	NodeID1           int64
	NodeID2           int64
	Outpoint          string
	Capacity          sql.NullInt64
	BitcoinKey1       []byte
	BitcoinKey2       []byte
	Node1Signature    []byte
	Node2Signature    []byte
	Bitcoin1Signature []byte
	Bitcoin2Signature []byte
	Node1PubKey       []byte
	Node2PubKey       []byte
}

type GetChannelByOutpointWithPoliciesParams added in v1.0.11

type GetChannelByOutpointWithPoliciesParams struct {
	Outpoint string
	Version  int16
}

type GetChannelByOutpointWithPoliciesRow added in v1.0.11

type GetChannelByOutpointWithPoliciesRow struct {
	GraphChannel                   GraphChannel
	Node1Pubkey                    []byte
	Node2Pubkey                    []byte
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type GetChannelBySCIDParams added in v1.0.10

type GetChannelBySCIDParams struct {
	Scid    []byte
	Version int16
}

type GetChannelBySCIDWithPoliciesParams added in v1.0.11

type GetChannelBySCIDWithPoliciesParams struct {
	Scid    []byte
	Version int16
}

type GetChannelBySCIDWithPoliciesRow added in v1.0.11

type GetChannelBySCIDWithPoliciesRow struct {
	GraphChannel                   GraphChannel
	GraphNode                      GraphNode
	GraphNode_2                    GraphNode
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type GetChannelPolicyByChannelAndNodeParams added in v1.0.11

type GetChannelPolicyByChannelAndNodeParams struct {
	ChannelID int64
	NodeID    int64
	Version   int16
}

type GetChannelPolicyExtraTypesBatchRow added in v1.0.11

type GetChannelPolicyExtraTypesBatchRow struct {
	PolicyID int64
	Type     int64
	Value    []byte
}

type GetChannelsByIDsRow added in v1.0.11

type GetChannelsByIDsRow struct {
	GraphChannel                   GraphChannel
	Node1ID                        int64
	Node1PubKey                    []byte
	Node2ID                        int64
	Node2PubKey                    []byte
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type GetChannelsByOutpointsRow added in v1.0.11

type GetChannelsByOutpointsRow struct {
	GraphChannel GraphChannel
	Node1Pubkey  []byte
	Node2Pubkey  []byte
}

func (GetChannelsByOutpointsRow) Channel added in v1.0.11

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsByOutpointsRow) Node1Pub added in v1.0.11

func (r GetChannelsByOutpointsRow) Node1Pub() []byte

Node1Pub returns the public key of the first node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsByOutpointsRow) Node2Pub added in v1.0.11

func (r GetChannelsByOutpointsRow) Node2Pub() []byte

Node2Pub returns the public key of the second node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

type GetChannelsByPolicyLastUpdateRangeParams added in v1.0.11

type GetChannelsByPolicyLastUpdateRangeParams struct {
	Version        int16
	StartTime      sql.NullInt64
	EndTime        sql.NullInt64
	LastUpdateTime sql.NullInt64
	LastID         sql.NullInt64
	MaxResults     interface{}
}

type GetChannelsByPolicyLastUpdateRangeRow added in v1.0.11

type GetChannelsByPolicyLastUpdateRangeRow struct {
	GraphChannel                   GraphChannel
	GraphNode                      GraphNode
	GraphNode_2                    GraphNode
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

func (GetChannelsByPolicyLastUpdateRangeRow) Channel added in v1.0.11

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsByPolicyLastUpdateRangeRow) Node1 added in v1.0.11

Node1 returns the first GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsByPolicyLastUpdateRangeRow) Node2 added in v1.0.11

Node2 returns the second GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

type GetChannelsBySCIDRangeParams added in v1.0.11

type GetChannelsBySCIDRangeParams struct {
	StartScid []byte
	EndScid   []byte
}

type GetChannelsBySCIDRangeRow added in v1.0.11

type GetChannelsBySCIDRangeRow struct {
	GraphChannel GraphChannel
	Node1PubKey  []byte
	Node2PubKey  []byte
}

func (GetChannelsBySCIDRangeRow) Channel added in v1.0.11

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDRangeRow) Node1Pub added in v1.0.11

func (r GetChannelsBySCIDRangeRow) Node1Pub() []byte

Node1Pub returns the public key of the first node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDRangeRow) Node2Pub added in v1.0.11

func (r GetChannelsBySCIDRangeRow) Node2Pub() []byte

Node2Pub returns the public key of the second node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

type GetChannelsBySCIDWithPoliciesParams added in v1.0.11

type GetChannelsBySCIDWithPoliciesParams struct {
	Version int16
	Scids   [][]byte
}

type GetChannelsBySCIDWithPoliciesRow added in v1.0.11

type GetChannelsBySCIDWithPoliciesRow struct {
	GraphChannel                   GraphChannel
	GraphNode                      GraphNode
	GraphNode_2                    GraphNode
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

func (GetChannelsBySCIDWithPoliciesRow) Channel added in v1.0.11

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDWithPoliciesRow) Node1 added in v1.0.11

Node1 returns the first GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsBySCIDWithPoliciesRow) Node1Pub added in v1.0.11

func (r GetChannelsBySCIDWithPoliciesRow) Node1Pub() []byte

Node1Pub returns the public key of the first node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDWithPoliciesRow) Node2 added in v1.0.11

Node2 returns the second GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsBySCIDWithPoliciesRow) Node2Pub added in v1.0.11

func (r GetChannelsBySCIDWithPoliciesRow) Node2Pub() []byte

Node2Pub returns the public key of the second node as a byte slice.

NOTE: This method is part of the ChannelAndNodeIDs interface.

type GetChannelsBySCIDsParams added in v1.0.11

type GetChannelsBySCIDsParams struct {
	Version int16
	Scids   [][]byte
}

type GetInvoiceHTLCCustomRecordsRow

type GetInvoiceHTLCCustomRecordsRow struct {
	HtlcID int64
	Key    int64
	Value  []byte
}

type GetInvoiceParams

type GetInvoiceParams struct {
	SetID       []byte
	AddIndex    sql.NullInt64
	Hash        []byte
	PaymentAddr []byte
}

type GetNodeAddressesRow added in v1.0.11

type GetNodeAddressesRow struct {
	Type    int16
	Address string
}

type GetNodeByPubKeyParams added in v1.0.10

type GetNodeByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodeFeaturesByPubKeyParams added in v1.0.10

type GetNodeFeaturesByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodeIDByPubKeyParams added in v1.0.11

type GetNodeIDByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodesByLastUpdateRangeParams added in v1.0.10

type GetNodesByLastUpdateRangeParams struct {
	StartTime  sql.NullInt64
	EndTime    sql.NullInt64
	LastUpdate sql.NullInt64
	LastPubKey []byte
	OnlyPublic interface{}
	MaxResults interface{}
}

type GetPublicV1ChannelsBySCIDParams added in v1.0.11

type GetPublicV1ChannelsBySCIDParams struct {
	StartScid []byte
	EndScid   []byte
}

type GetSCIDByOutpointParams added in v1.0.11

type GetSCIDByOutpointParams struct {
	Outpoint string
	Version  int16
}

type GetSourceNodesByVersionRow added in v1.0.10

type GetSourceNodesByVersionRow struct {
	NodeID int64
	PubKey []byte
}

type GetZombieChannelParams added in v1.0.11

type GetZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type GetZombieChannelsSCIDsParams added in v1.0.11

type GetZombieChannelsSCIDsParams struct {
	Version int16
	Scids   [][]byte
}

type GraphChannel added in v1.0.11

type GraphChannel struct {
	ID                int64
	Version           int16
	Scid              []byte
	NodeID1           int64
	NodeID2           int64
	Outpoint          string
	Capacity          sql.NullInt64
	BitcoinKey1       []byte
	BitcoinKey2       []byte
	Node1Signature    []byte
	Node2Signature    []byte
	Bitcoin1Signature []byte
	Bitcoin2Signature []byte
}

type GraphChannelExtraType added in v1.0.11

type GraphChannelExtraType struct {
	ChannelID int64
	Type      int64
	Value     []byte
}

type GraphChannelFeature added in v1.0.11

type GraphChannelFeature struct {
	ChannelID  int64
	FeatureBit int32
}

type GraphChannelPolicy added in v1.0.11

type GraphChannelPolicy struct {
	ID                      int64
	Version                 int16
	ChannelID               int64
	NodeID                  int64
	Timelock                int32
	FeePpm                  int64
	BaseFeeMsat             int64
	MinHtlcMsat             int64
	MaxHtlcMsat             sql.NullInt64
	LastUpdate              sql.NullInt64
	Disabled                sql.NullBool
	InboundBaseFeeMsat      sql.NullInt64
	InboundFeeRateMilliMsat sql.NullInt64
	MessageFlags            sql.NullInt16
	ChannelFlags            sql.NullInt16
	Signature               []byte
}

type GraphChannelPolicyExtraType added in v1.0.11

type GraphChannelPolicyExtraType struct {
	ChannelPolicyID int64
	Type            int64
	Value           []byte
}

type GraphClosedScid added in v1.0.11

type GraphClosedScid struct {
	Scid []byte
}

type GraphNode added in v1.0.11

type GraphNode struct {
	ID         int64
	Version    int16
	PubKey     []byte
	Alias      sql.NullString
	LastUpdate sql.NullInt64
	Color      sql.NullString
	Signature  []byte
}

type GraphNodeAddress added in v1.0.11

type GraphNodeAddress struct {
	NodeID   int64
	Type     int16
	Position int32
	Address  string
}

type GraphNodeExtraType added in v1.0.11

type GraphNodeExtraType struct {
	NodeID int64
	Type   int64
	Value  []byte
}

type GraphNodeFeature added in v1.0.11

type GraphNodeFeature struct {
	NodeID     int64
	FeatureBit int32
}

type GraphPruneLog added in v1.0.11

type GraphPruneLog struct {
	BlockHeight int64
	BlockHash   []byte
}

type GraphSourceNode added in v1.0.11

type GraphSourceNode struct {
	NodeID int64
}

type GraphZombieChannel added in v1.0.11

type GraphZombieChannel struct {
	Scid     []byte
	Version  int16
	NodeKey1 []byte
	NodeKey2 []byte
}

type InsertAMPSubInvoiceHTLCParams

type InsertAMPSubInvoiceHTLCParams struct {
	InvoiceID  int64
	SetID      []byte
	HtlcID     int64
	RootShare  []byte
	ChildIndex int64
	Hash       []byte
	Preimage   []byte
}

type InsertAMPSubInvoiceParams added in v1.0.7

type InsertAMPSubInvoiceParams struct {
	SetID       []byte
	State       int16
	CreatedAt   time.Time
	SettledAt   sql.NullTime
	SettleIndex sql.NullInt64
	InvoiceID   int64
}

type InsertChannelFeatureParams added in v1.0.10

type InsertChannelFeatureParams struct {
	ChannelID  int64
	FeatureBit int32
}

type InsertChannelMigParams added in v1.0.11

type InsertChannelMigParams struct {
	Version           int16
	Scid              []byte
	NodeID1           int64
	NodeID2           int64
	Outpoint          string
	Capacity          sql.NullInt64
	BitcoinKey1       []byte
	BitcoinKey2       []byte
	Node1Signature    []byte
	Node2Signature    []byte
	Bitcoin1Signature []byte
	Bitcoin2Signature []byte
}

type InsertEdgePolicyMigParams added in v1.0.11

type InsertEdgePolicyMigParams struct {
	Version                 int16
	ChannelID               int64
	NodeID                  int64
	Timelock                int32
	FeePpm                  int64
	BaseFeeMsat             int64
	MinHtlcMsat             int64
	LastUpdate              sql.NullInt64
	Disabled                sql.NullBool
	MaxHtlcMsat             sql.NullInt64
	InboundBaseFeeMsat      sql.NullInt64
	InboundFeeRateMilliMsat sql.NullInt64
	MessageFlags            sql.NullInt16
	ChannelFlags            sql.NullInt16
	Signature               []byte
}

type InsertInvoiceFeatureParams

type InsertInvoiceFeatureParams struct {
	InvoiceID int64
	Feature   int32
}

type InsertInvoiceHTLCCustomRecordParams

type InsertInvoiceHTLCCustomRecordParams struct {
	Key    int64
	Value  []byte
	HtlcID int64
}

type InsertInvoiceHTLCParams

type InsertInvoiceHTLCParams struct {
	HtlcID       int64
	ChanID       string
	AmountMsat   int64
	TotalMppMsat sql.NullInt64
	AcceptHeight int32
	AcceptTime   time.Time
	ExpiryHeight int32
	State        int16
	ResolveTime  sql.NullTime
	InvoiceID    int64
}

type InsertInvoiceParams

type InsertInvoiceParams struct {
	Hash               []byte
	Preimage           []byte
	Memo               sql.NullString
	AmountMsat         int64
	CltvDelta          sql.NullInt32
	Expiry             int32
	PaymentAddr        []byte
	PaymentRequest     sql.NullString
	PaymentRequestHash []byte
	State              int16
	AmountPaidMsat     int64
	IsAmp              bool
	IsHodl             bool
	IsKeysend          bool
	CreatedAt          time.Time
}

type InsertKVInvoiceKeyAndAddIndexParams added in v1.0.7

type InsertKVInvoiceKeyAndAddIndexParams struct {
	ID       int64
	AddIndex int64
}

type InsertMigratedInvoiceParams added in v1.0.7

type InsertMigratedInvoiceParams struct {
	Hash               []byte
	Preimage           []byte
	SettleIndex        sql.NullInt64
	SettledAt          sql.NullTime
	Memo               sql.NullString
	AmountMsat         int64
	CltvDelta          sql.NullInt32
	Expiry             int32
	PaymentAddr        []byte
	PaymentRequest     sql.NullString
	PaymentRequestHash []byte
	State              int16
	AmountPaidMsat     int64
	IsAmp              bool
	IsHodl             bool
	IsKeysend          bool
	CreatedAt          time.Time
}

type InsertNodeFeatureParams added in v1.0.10

type InsertNodeFeatureParams struct {
	NodeID     int64
	FeatureBit int32
}

type InsertNodeMigParams added in v1.0.11

type InsertNodeMigParams struct {
	Version    int16
	PubKey     []byte
	Alias      sql.NullString
	LastUpdate sql.NullInt64
	Color      sql.NullString
	Signature  []byte
}

type Invoice

type Invoice struct {
	ID                 int64
	Hash               []byte
	Preimage           []byte
	SettleIndex        sql.NullInt64
	SettledAt          sql.NullTime
	Memo               sql.NullString
	AmountMsat         int64
	CltvDelta          sql.NullInt32
	Expiry             int32
	PaymentAddr        []byte
	PaymentRequest     sql.NullString
	PaymentRequestHash []byte
	State              int16
	AmountPaidMsat     int64
	IsAmp              bool
	IsHodl             bool
	IsKeysend          bool
	CreatedAt          time.Time
}

type InvoiceEvent

type InvoiceEvent struct {
	ID        int64
	AddedAt   time.Time
	EventType int32
	InvoiceID int64
	SetID     []byte
}

type InvoiceEventType

type InvoiceEventType struct {
	ID          int64
	Description string
}

type InvoiceFeature

type InvoiceFeature struct {
	Feature   int32
	InvoiceID int64
}

type InvoiceHtlc

type InvoiceHtlc struct {
	ID           int64
	ChanID       string
	HtlcID       int64
	AmountMsat   int64
	TotalMppMsat sql.NullInt64
	AcceptHeight int32
	AcceptTime   time.Time
	ExpiryHeight int32
	State        int16
	ResolveTime  sql.NullTime
	InvoiceID    int64
}

type InvoiceHtlcCustomRecord

type InvoiceHtlcCustomRecord struct {
	Key    int64
	Value  []byte
	HtlcID int64
}

type InvoicePaymentHash added in v1.0.7

type InvoicePaymentHash struct {
	ID       int64
	AddIndex int64
	Hash     []byte
}

type InvoiceSequence

type InvoiceSequence struct {
	Name         string
	CurrentValue int64
}

type IsZombieChannelParams added in v1.0.11

type IsZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type ListChannelsByNodeIDParams added in v1.0.11

type ListChannelsByNodeIDParams struct {
	Version int16
	NodeID1 int64
}

type ListChannelsByNodeIDRow added in v1.0.11

type ListChannelsByNodeIDRow struct {
	GraphChannel                   GraphChannel
	Node1Pubkey                    []byte
	Node2Pubkey                    []byte
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type ListChannelsForNodeIDsParams added in v1.0.11

type ListChannelsForNodeIDsParams struct {
	Version  int16
	Node1Ids []int64
	Node2Ids []int64
}

type ListChannelsForNodeIDsRow added in v1.0.11

type ListChannelsForNodeIDsRow struct {
	GraphChannel                   GraphChannel
	Node1Pubkey                    []byte
	Node2Pubkey                    []byte
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type ListChannelsPaginatedParams added in v1.0.11

type ListChannelsPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsPaginatedRow added in v1.0.11

type ListChannelsPaginatedRow struct {
	ID          int64
	BitcoinKey1 []byte
	BitcoinKey2 []byte
	Outpoint    string
}

type ListChannelsWithPoliciesForCachePaginatedParams added in v1.0.11

type ListChannelsWithPoliciesForCachePaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsWithPoliciesForCachePaginatedRow added in v1.0.11

type ListChannelsWithPoliciesForCachePaginatedRow struct {
	ID                             int64
	Scid                           []byte
	Capacity                       sql.NullInt64
	Node1Pubkey                    []byte
	Node2Pubkey                    []byte
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
}

type ListChannelsWithPoliciesPaginatedParams added in v1.0.11

type ListChannelsWithPoliciesPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsWithPoliciesPaginatedRow added in v1.0.11

type ListChannelsWithPoliciesPaginatedRow struct {
	GraphChannel                   GraphChannel
	Node1Pubkey                    []byte
	Node2Pubkey                    []byte
	Policy1ID                      sql.NullInt64
	Policy1NodeID                  sql.NullInt64
	Policy1Version                 sql.NullInt16
	Policy1Timelock                sql.NullInt32
	Policy1FeePpm                  sql.NullInt64
	Policy1BaseFeeMsat             sql.NullInt64
	Policy1MinHtlcMsat             sql.NullInt64
	Policy1MaxHtlcMsat             sql.NullInt64
	Policy1LastUpdate              sql.NullInt64
	Policy1Disabled                sql.NullBool
	Policy1InboundBaseFeeMsat      sql.NullInt64
	Policy1InboundFeeRateMilliMsat sql.NullInt64
	Policy1MessageFlags            sql.NullInt16
	Policy1ChannelFlags            sql.NullInt16
	Policy1Signature               []byte
	Policy2ID                      sql.NullInt64
	Policy2NodeID                  sql.NullInt64
	Policy2Version                 sql.NullInt16
	Policy2Timelock                sql.NullInt32
	Policy2FeePpm                  sql.NullInt64
	Policy2BaseFeeMsat             sql.NullInt64
	Policy2MinHtlcMsat             sql.NullInt64
	Policy2MaxHtlcMsat             sql.NullInt64
	Policy2LastUpdate              sql.NullInt64
	Policy2Disabled                sql.NullBool
	Policy2InboundBaseFeeMsat      sql.NullInt64
	Policy2InboundFeeRateMilliMsat sql.NullInt64
	Policy2MessageFlags            sql.NullInt16
	Policy2ChannelFlags            sql.NullInt16
	Policy2Signature               []byte
}

type ListNodeIDsAndPubKeysParams added in v1.0.11

type ListNodeIDsAndPubKeysParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListNodeIDsAndPubKeysRow added in v1.0.11

type ListNodeIDsAndPubKeysRow struct {
	ID     int64
	PubKey []byte
}

type ListNodesPaginatedParams added in v1.0.11

type ListNodesPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type MigrationTracker added in v1.0.7

type MigrationTracker struct {
	Version       int32
	MigrationTime time.Time
}

type OnAMPSubInvoiceCanceledParams

type OnAMPSubInvoiceCanceledParams struct {
	AddedAt   time.Time
	InvoiceID int64
	SetID     []byte
}

type OnAMPSubInvoiceCreatedParams

type OnAMPSubInvoiceCreatedParams struct {
	AddedAt   time.Time
	InvoiceID int64
	SetID     []byte
}

type OnAMPSubInvoiceSettledParams

type OnAMPSubInvoiceSettledParams struct {
	AddedAt   time.Time
	InvoiceID int64
	SetID     []byte
}

type OnInvoiceCanceledParams

type OnInvoiceCanceledParams struct {
	AddedAt   time.Time
	InvoiceID int64
}

type OnInvoiceCreatedParams

type OnInvoiceCreatedParams struct {
	AddedAt   time.Time
	InvoiceID int64
}

type OnInvoiceSettledParams

type OnInvoiceSettledParams struct {
	AddedAt   time.Time
	InvoiceID int64
}

type Querier

type Querier interface {
	AddSourceNode(ctx context.Context, nodeID int64) error
	AddV1ChannelProof(ctx context.Context, arg AddV1ChannelProofParams) (sql.Result, error)
	ClearKVInvoiceHashIndex(ctx context.Context) error
	CountZombieChannels(ctx context.Context, version int16) (int64, error)
	CreateChannel(ctx context.Context, arg CreateChannelParams) (int64, error)
	DeleteCanceledInvoices(ctx context.Context) (sql.Result, error)
	DeleteChannelPolicyExtraTypes(ctx context.Context, channelPolicyID int64) error
	DeleteChannels(ctx context.Context, ids []int64) error
	DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error
	DeleteInvoice(ctx context.Context, arg DeleteInvoiceParams) (sql.Result, error)
	DeleteNode(ctx context.Context, id int64) error
	DeleteNodeAddresses(ctx context.Context, nodeID int64) error
	DeleteNodeByPubKey(ctx context.Context, arg DeleteNodeByPubKeyParams) (sql.Result, error)
	DeleteNodeFeature(ctx context.Context, arg DeleteNodeFeatureParams) error
	DeletePruneLogEntriesInRange(ctx context.Context, arg DeletePruneLogEntriesInRangeParams) error
	DeleteUnconnectedNodes(ctx context.Context) ([][]byte, error)
	DeleteZombieChannel(ctx context.Context, arg DeleteZombieChannelParams) (sql.Result, error)
	FetchAMPSubInvoiceHTLCs(ctx context.Context, arg FetchAMPSubInvoiceHTLCsParams) ([]FetchAMPSubInvoiceHTLCsRow, error)
	FetchAMPSubInvoices(ctx context.Context, arg FetchAMPSubInvoicesParams) ([]AmpSubInvoice, error)
	FetchSettledAMPSubInvoices(ctx context.Context, arg FetchSettledAMPSubInvoicesParams) ([]FetchSettledAMPSubInvoicesRow, error)
	FilterInvoices(ctx context.Context, arg FilterInvoicesParams) ([]Invoice, error)
	GetAMPInvoiceID(ctx context.Context, setID []byte) (int64, error)
	GetChannelAndNodesBySCID(ctx context.Context, arg GetChannelAndNodesBySCIDParams) (GetChannelAndNodesBySCIDRow, error)
	GetChannelByOutpointWithPolicies(ctx context.Context, arg GetChannelByOutpointWithPoliciesParams) (GetChannelByOutpointWithPoliciesRow, error)
	GetChannelBySCID(ctx context.Context, arg GetChannelBySCIDParams) (GraphChannel, error)
	GetChannelBySCIDWithPolicies(ctx context.Context, arg GetChannelBySCIDWithPoliciesParams) (GetChannelBySCIDWithPoliciesRow, error)
	GetChannelExtrasBatch(ctx context.Context, chanIds []int64) ([]GraphChannelExtraType, error)
	GetChannelFeaturesBatch(ctx context.Context, chanIds []int64) ([]GraphChannelFeature, error)
	GetChannelPolicyByChannelAndNode(ctx context.Context, arg GetChannelPolicyByChannelAndNodeParams) (GraphChannelPolicy, error)
	GetChannelPolicyExtraTypesBatch(ctx context.Context, policyIds []int64) ([]GetChannelPolicyExtraTypesBatchRow, error)
	GetChannelsByIDs(ctx context.Context, ids []int64) ([]GetChannelsByIDsRow, error)
	GetChannelsByOutpoints(ctx context.Context, outpoints []string) ([]GetChannelsByOutpointsRow, error)
	GetChannelsByPolicyLastUpdateRange(ctx context.Context, arg GetChannelsByPolicyLastUpdateRangeParams) ([]GetChannelsByPolicyLastUpdateRangeRow, error)
	GetChannelsBySCIDRange(ctx context.Context, arg GetChannelsBySCIDRangeParams) ([]GetChannelsBySCIDRangeRow, error)
	GetChannelsBySCIDWithPolicies(ctx context.Context, arg GetChannelsBySCIDWithPoliciesParams) ([]GetChannelsBySCIDWithPoliciesRow, error)
	GetChannelsBySCIDs(ctx context.Context, arg GetChannelsBySCIDsParams) ([]GraphChannel, error)
	GetClosedChannelsSCIDs(ctx context.Context, scids [][]byte) ([][]byte, error)
	GetDatabaseVersion(ctx context.Context) (int32, error)
	GetExtraNodeTypes(ctx context.Context, nodeID int64) ([]GraphNodeExtraType, error)
	// This method may return more than one invoice if filter using multiple fields
	// from different invoices. It is the caller's responsibility to ensure that
	// we bubble up an error in those cases.
	GetInvoice(ctx context.Context, arg GetInvoiceParams) ([]Invoice, error)
	GetInvoiceByHash(ctx context.Context, hash []byte) (Invoice, error)
	GetInvoiceBySetID(ctx context.Context, setID []byte) ([]Invoice, error)
	GetInvoiceFeatures(ctx context.Context, invoiceID int64) ([]InvoiceFeature, error)
	GetInvoiceHTLCCustomRecords(ctx context.Context, invoiceID int64) ([]GetInvoiceHTLCCustomRecordsRow, error)
	GetInvoiceHTLCs(ctx context.Context, invoiceID int64) ([]InvoiceHtlc, error)
	GetKVInvoicePaymentHashByAddIndex(ctx context.Context, addIndex int64) ([]byte, error)
	GetMigration(ctx context.Context, version int32) (time.Time, error)
	GetNodeAddresses(ctx context.Context, nodeID int64) ([]GetNodeAddressesRow, error)
	GetNodeAddressesBatch(ctx context.Context, ids []int64) ([]GraphNodeAddress, error)
	GetNodeByPubKey(ctx context.Context, arg GetNodeByPubKeyParams) (GraphNode, error)
	GetNodeExtraTypesBatch(ctx context.Context, ids []int64) ([]GraphNodeExtraType, error)
	GetNodeFeatures(ctx context.Context, nodeID int64) ([]GraphNodeFeature, error)
	GetNodeFeaturesBatch(ctx context.Context, ids []int64) ([]GraphNodeFeature, error)
	GetNodeFeaturesByPubKey(ctx context.Context, arg GetNodeFeaturesByPubKeyParams) ([]int32, error)
	GetNodeIDByPubKey(ctx context.Context, arg GetNodeIDByPubKeyParams) (int64, error)
	GetNodesByIDs(ctx context.Context, ids []int64) ([]GraphNode, error)
	GetNodesByLastUpdateRange(ctx context.Context, arg GetNodesByLastUpdateRangeParams) ([]GraphNode, error)
	GetPruneEntriesForHeights(ctx context.Context, heights []int64) ([]GraphPruneLog, error)
	GetPruneHashByHeight(ctx context.Context, blockHeight int64) ([]byte, error)
	GetPruneTip(ctx context.Context) (GraphPruneLog, error)
	GetPublicV1ChannelsBySCID(ctx context.Context, arg GetPublicV1ChannelsBySCIDParams) ([]GraphChannel, error)
	GetSCIDByOutpoint(ctx context.Context, arg GetSCIDByOutpointParams) ([]byte, error)
	GetSourceNodesByVersion(ctx context.Context, version int16) ([]GetSourceNodesByVersionRow, error)
	// NOTE: this is V1 specific since for V1, disabled is a
	// simple, single boolean. The proposed V2 policy
	// structure will have a more complex disabled bit vector
	// and so the query for V2 may differ.
	GetV1DisabledSCIDs(ctx context.Context) ([][]byte, error)
	GetZombieChannel(ctx context.Context, arg GetZombieChannelParams) (GraphZombieChannel, error)
	GetZombieChannelsSCIDs(ctx context.Context, arg GetZombieChannelsSCIDsParams) ([]GraphZombieChannel, error)
	HighestSCID(ctx context.Context, version int16) ([]byte, error)
	InsertAMPSubInvoice(ctx context.Context, arg InsertAMPSubInvoiceParams) error
	InsertAMPSubInvoiceHTLC(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) error
	InsertChannelFeature(ctx context.Context, arg InsertChannelFeatureParams) error
	// NOTE: This query is only meant to be used by the graph SQL migration since
	// for that migration, in order to be retry-safe, we don't want to error out if
	// we re-insert the same channel again (which would error if the normal
	// CreateChannel query is used because of the uniqueness constraint on the scid
	// and version columns).
	InsertChannelMig(ctx context.Context, arg InsertChannelMigParams) (int64, error)
	InsertClosedChannel(ctx context.Context, scid []byte) error
	// NOTE: This query is only meant to be used by the graph SQL migration since
	// for that migration, in order to be retry-safe, we don't want to error out if
	// we re-insert the same policy (which would error if the normal
	// UpsertEdgePolicy query is used because of the constraint in that query that
	// requires a policy update to have a newer last_update than the existing one).
	InsertEdgePolicyMig(ctx context.Context, arg InsertEdgePolicyMigParams) (int64, error)
	InsertInvoice(ctx context.Context, arg InsertInvoiceParams) (int64, error)
	InsertInvoiceFeature(ctx context.Context, arg InsertInvoiceFeatureParams) error
	InsertInvoiceHTLC(ctx context.Context, arg InsertInvoiceHTLCParams) (int64, error)
	InsertInvoiceHTLCCustomRecord(ctx context.Context, arg InsertInvoiceHTLCCustomRecordParams) error
	InsertKVInvoiceKeyAndAddIndex(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error
	InsertMigratedInvoice(ctx context.Context, arg InsertMigratedInvoiceParams) (int64, error)
	InsertNodeFeature(ctx context.Context, arg InsertNodeFeatureParams) error
	// NOTE: This query is only meant to be used by the graph SQL migration since
	// for that migration, in order to be retry-safe, we don't want to error out if
	// we re-insert the same node (which would error if the normal UpsertNode query
	// is used because of the constraint in that query that requires a node update
	// to have a newer last_update than the existing node).
	InsertNodeMig(ctx context.Context, arg InsertNodeMigParams) (int64, error)
	IsClosedChannel(ctx context.Context, scid []byte) (bool, error)
	IsPublicV1Node(ctx context.Context, pubKey []byte) (bool, error)
	IsZombieChannel(ctx context.Context, arg IsZombieChannelParams) (bool, error)
	ListChannelsByNodeID(ctx context.Context, arg ListChannelsByNodeIDParams) ([]ListChannelsByNodeIDRow, error)
	ListChannelsForNodeIDs(ctx context.Context, arg ListChannelsForNodeIDsParams) ([]ListChannelsForNodeIDsRow, error)
	ListChannelsPaginated(ctx context.Context, arg ListChannelsPaginatedParams) ([]ListChannelsPaginatedRow, error)
	ListChannelsWithPoliciesForCachePaginated(ctx context.Context, arg ListChannelsWithPoliciesForCachePaginatedParams) ([]ListChannelsWithPoliciesForCachePaginatedRow, error)
	ListChannelsWithPoliciesPaginated(ctx context.Context, arg ListChannelsWithPoliciesPaginatedParams) ([]ListChannelsWithPoliciesPaginatedRow, error)
	ListNodeIDsAndPubKeys(ctx context.Context, arg ListNodeIDsAndPubKeysParams) ([]ListNodeIDsAndPubKeysRow, error)
	ListNodesPaginated(ctx context.Context, arg ListNodesPaginatedParams) ([]GraphNode, error)
	NextInvoiceSettleIndex(ctx context.Context) (int64, error)
	OnAMPSubInvoiceCanceled(ctx context.Context, arg OnAMPSubInvoiceCanceledParams) error
	OnAMPSubInvoiceCreated(ctx context.Context, arg OnAMPSubInvoiceCreatedParams) error
	OnAMPSubInvoiceSettled(ctx context.Context, arg OnAMPSubInvoiceSettledParams) error
	OnInvoiceCanceled(ctx context.Context, arg OnInvoiceCanceledParams) error
	OnInvoiceCreated(ctx context.Context, arg OnInvoiceCreatedParams) error
	OnInvoiceSettled(ctx context.Context, arg OnInvoiceSettledParams) error
	SetKVInvoicePaymentHash(ctx context.Context, arg SetKVInvoicePaymentHashParams) error
	SetMigration(ctx context.Context, arg SetMigrationParams) error
	UpdateAMPSubInvoiceHTLCPreimage(ctx context.Context, arg UpdateAMPSubInvoiceHTLCPreimageParams) (sql.Result, error)
	UpdateAMPSubInvoiceState(ctx context.Context, arg UpdateAMPSubInvoiceStateParams) error
	UpdateInvoiceAmountPaid(ctx context.Context, arg UpdateInvoiceAmountPaidParams) (sql.Result, error)
	UpdateInvoiceHTLC(ctx context.Context, arg UpdateInvoiceHTLCParams) error
	UpdateInvoiceHTLCs(ctx context.Context, arg UpdateInvoiceHTLCsParams) error
	UpdateInvoiceState(ctx context.Context, arg UpdateInvoiceStateParams) (sql.Result, error)
	UpsertAMPSubInvoice(ctx context.Context, arg UpsertAMPSubInvoiceParams) (sql.Result, error)
	UpsertChanPolicyExtraType(ctx context.Context, arg UpsertChanPolicyExtraTypeParams) error
	UpsertChannelExtraType(ctx context.Context, arg UpsertChannelExtraTypeParams) error
	UpsertEdgePolicy(ctx context.Context, arg UpsertEdgePolicyParams) (int64, error)
	UpsertNode(ctx context.Context, arg UpsertNodeParams) (int64, error)
	UpsertNodeAddress(ctx context.Context, arg UpsertNodeAddressParams) error
	UpsertNodeExtraType(ctx context.Context, arg UpsertNodeExtraTypeParams) error
	UpsertPruneLogEntry(ctx context.Context, arg UpsertPruneLogEntryParams) error
	UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error
}

type Queries

type Queries struct {
	// contains filtered or unexported fields
}

func New

func New(db DBTX) *Queries

func (*Queries) AddSourceNode added in v1.0.10

func (q *Queries) AddSourceNode(ctx context.Context, nodeID int64) error

func (*Queries) AddV1ChannelProof added in v1.0.11

func (q *Queries) AddV1ChannelProof(ctx context.Context, arg AddV1ChannelProofParams) (sql.Result, error)

func (*Queries) ClearKVInvoiceHashIndex added in v1.0.7

func (q *Queries) ClearKVInvoiceHashIndex(ctx context.Context) error

func (*Queries) CountZombieChannels added in v1.0.11

func (q *Queries) CountZombieChannels(ctx context.Context, version int16) (int64, error)

func (*Queries) CreateChannel added in v1.0.10

func (q *Queries) CreateChannel(ctx context.Context, arg CreateChannelParams) (int64, error)

func (*Queries) DeleteCanceledInvoices

func (q *Queries) DeleteCanceledInvoices(ctx context.Context) (sql.Result, error)

func (*Queries) DeleteChannelPolicyExtraTypes added in v1.0.11

func (q *Queries) DeleteChannelPolicyExtraTypes(ctx context.Context, channelPolicyID int64) error

func (*Queries) DeleteChannels added in v1.0.11

func (q *Queries) DeleteChannels(ctx context.Context, ids []int64) error

func (*Queries) DeleteExtraNodeType added in v1.0.10

func (q *Queries) DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error

func (*Queries) DeleteInvoice

func (q *Queries) DeleteInvoice(ctx context.Context, arg DeleteInvoiceParams) (sql.Result, error)

func (*Queries) DeleteNode added in v1.0.11

func (q *Queries) DeleteNode(ctx context.Context, id int64) error

func (*Queries) DeleteNodeAddresses added in v1.0.10

func (q *Queries) DeleteNodeAddresses(ctx context.Context, nodeID int64) error

func (*Queries) DeleteNodeByPubKey added in v1.0.10

func (q *Queries) DeleteNodeByPubKey(ctx context.Context, arg DeleteNodeByPubKeyParams) (sql.Result, error)

func (*Queries) DeleteNodeFeature added in v1.0.10

func (q *Queries) DeleteNodeFeature(ctx context.Context, arg DeleteNodeFeatureParams) error

func (*Queries) DeletePruneLogEntriesInRange added in v1.0.11

func (q *Queries) DeletePruneLogEntriesInRange(ctx context.Context, arg DeletePruneLogEntriesInRangeParams) error

func (*Queries) DeleteUnconnectedNodes added in v1.0.11

func (q *Queries) DeleteUnconnectedNodes(ctx context.Context) ([][]byte, error)

func (*Queries) DeleteZombieChannel added in v1.0.11

func (q *Queries) DeleteZombieChannel(ctx context.Context, arg DeleteZombieChannelParams) (sql.Result, error)

func (*Queries) FetchAMPSubInvoiceHTLCs

func (q *Queries) FetchAMPSubInvoiceHTLCs(ctx context.Context, arg FetchAMPSubInvoiceHTLCsParams) ([]FetchAMPSubInvoiceHTLCsRow, error)

func (*Queries) FetchAMPSubInvoices

func (q *Queries) FetchAMPSubInvoices(ctx context.Context, arg FetchAMPSubInvoicesParams) ([]AmpSubInvoice, error)

func (*Queries) FetchSettledAMPSubInvoices

func (q *Queries) FetchSettledAMPSubInvoices(ctx context.Context, arg FetchSettledAMPSubInvoicesParams) ([]FetchSettledAMPSubInvoicesRow, error)

func (*Queries) FilterInvoices

func (q *Queries) FilterInvoices(ctx context.Context, arg FilterInvoicesParams) ([]Invoice, error)

func (*Queries) GetAMPInvoiceID

func (q *Queries) GetAMPInvoiceID(ctx context.Context, setID []byte) (int64, error)

func (*Queries) GetChannelAndNodesBySCID added in v1.0.11

func (*Queries) GetChannelByOutpointWithPolicies added in v1.0.11

func (*Queries) GetChannelBySCID added in v1.0.10

func (q *Queries) GetChannelBySCID(ctx context.Context, arg GetChannelBySCIDParams) (GraphChannel, error)

func (*Queries) GetChannelBySCIDWithPolicies added in v1.0.11

func (*Queries) GetChannelExtrasBatch added in v1.0.11

func (q *Queries) GetChannelExtrasBatch(ctx context.Context, chanIds []int64) ([]GraphChannelExtraType, error)

func (*Queries) GetChannelFeaturesBatch added in v1.0.11

func (q *Queries) GetChannelFeaturesBatch(ctx context.Context, chanIds []int64) ([]GraphChannelFeature, error)

func (*Queries) GetChannelPolicyByChannelAndNode added in v1.0.11

func (q *Queries) GetChannelPolicyByChannelAndNode(ctx context.Context, arg GetChannelPolicyByChannelAndNodeParams) (GraphChannelPolicy, error)

func (*Queries) GetChannelPolicyExtraTypesBatch added in v1.0.11

func (q *Queries) GetChannelPolicyExtraTypesBatch(ctx context.Context, policyIds []int64) ([]GetChannelPolicyExtraTypesBatchRow, error)

func (*Queries) GetChannelsByIDs added in v1.0.11

func (q *Queries) GetChannelsByIDs(ctx context.Context, ids []int64) ([]GetChannelsByIDsRow, error)

func (*Queries) GetChannelsByOutpoints added in v1.0.11

func (q *Queries) GetChannelsByOutpoints(ctx context.Context, outpoints []string) ([]GetChannelsByOutpointsRow, error)

func (*Queries) GetChannelsByPolicyLastUpdateRange added in v1.0.11

func (*Queries) GetChannelsBySCIDRange added in v1.0.11

func (q *Queries) GetChannelsBySCIDRange(ctx context.Context, arg GetChannelsBySCIDRangeParams) ([]GetChannelsBySCIDRangeRow, error)

func (*Queries) GetChannelsBySCIDWithPolicies added in v1.0.11

func (q *Queries) GetChannelsBySCIDWithPolicies(ctx context.Context, arg GetChannelsBySCIDWithPoliciesParams) ([]GetChannelsBySCIDWithPoliciesRow, error)

func (*Queries) GetChannelsBySCIDs added in v1.0.11

func (q *Queries) GetChannelsBySCIDs(ctx context.Context, arg GetChannelsBySCIDsParams) ([]GraphChannel, error)

func (*Queries) GetClosedChannelsSCIDs added in v1.0.11

func (q *Queries) GetClosedChannelsSCIDs(ctx context.Context, scids [][]byte) ([][]byte, error)

func (*Queries) GetDatabaseVersion added in v1.0.7

func (q *Queries) GetDatabaseVersion(ctx context.Context) (int32, error)

func (*Queries) GetExtraNodeTypes added in v1.0.10

func (q *Queries) GetExtraNodeTypes(ctx context.Context, nodeID int64) ([]GraphNodeExtraType, error)

func (*Queries) GetInvoice

func (q *Queries) GetInvoice(ctx context.Context, arg GetInvoiceParams) ([]Invoice, error)

This method may return more than one invoice if filter using multiple fields from different invoices. It is the caller's responsibility to ensure that we bubble up an error in those cases.

func (*Queries) GetInvoiceByHash added in v1.0.7

func (q *Queries) GetInvoiceByHash(ctx context.Context, hash []byte) (Invoice, error)

func (*Queries) GetInvoiceBySetID added in v1.0.4

func (q *Queries) GetInvoiceBySetID(ctx context.Context, setID []byte) ([]Invoice, error)

func (*Queries) GetInvoiceFeatures

func (q *Queries) GetInvoiceFeatures(ctx context.Context, invoiceID int64) ([]InvoiceFeature, error)

func (*Queries) GetInvoiceHTLCCustomRecords

func (q *Queries) GetInvoiceHTLCCustomRecords(ctx context.Context, invoiceID int64) ([]GetInvoiceHTLCCustomRecordsRow, error)

func (*Queries) GetInvoiceHTLCs

func (q *Queries) GetInvoiceHTLCs(ctx context.Context, invoiceID int64) ([]InvoiceHtlc, error)

func (*Queries) GetKVInvoicePaymentHashByAddIndex added in v1.0.7

func (q *Queries) GetKVInvoicePaymentHashByAddIndex(ctx context.Context, addIndex int64) ([]byte, error)

func (*Queries) GetMigration added in v1.0.7

func (q *Queries) GetMigration(ctx context.Context, version int32) (time.Time, error)

func (*Queries) GetNodeAddresses added in v1.0.11

func (q *Queries) GetNodeAddresses(ctx context.Context, nodeID int64) ([]GetNodeAddressesRow, error)

func (*Queries) GetNodeAddressesBatch added in v1.0.11

func (q *Queries) GetNodeAddressesBatch(ctx context.Context, ids []int64) ([]GraphNodeAddress, error)

func (*Queries) GetNodeByPubKey added in v1.0.10

func (q *Queries) GetNodeByPubKey(ctx context.Context, arg GetNodeByPubKeyParams) (GraphNode, error)

func (*Queries) GetNodeExtraTypesBatch added in v1.0.11

func (q *Queries) GetNodeExtraTypesBatch(ctx context.Context, ids []int64) ([]GraphNodeExtraType, error)

func (*Queries) GetNodeFeatures added in v1.0.10

func (q *Queries) GetNodeFeatures(ctx context.Context, nodeID int64) ([]GraphNodeFeature, error)

func (*Queries) GetNodeFeaturesBatch added in v1.0.11

func (q *Queries) GetNodeFeaturesBatch(ctx context.Context, ids []int64) ([]GraphNodeFeature, error)

func (*Queries) GetNodeFeaturesByPubKey added in v1.0.10

func (q *Queries) GetNodeFeaturesByPubKey(ctx context.Context, arg GetNodeFeaturesByPubKeyParams) ([]int32, error)

func (*Queries) GetNodeIDByPubKey added in v1.0.11

func (q *Queries) GetNodeIDByPubKey(ctx context.Context, arg GetNodeIDByPubKeyParams) (int64, error)

func (*Queries) GetNodesByIDs added in v1.0.11

func (q *Queries) GetNodesByIDs(ctx context.Context, ids []int64) ([]GraphNode, error)

func (*Queries) GetNodesByLastUpdateRange added in v1.0.10

func (q *Queries) GetNodesByLastUpdateRange(ctx context.Context, arg GetNodesByLastUpdateRangeParams) ([]GraphNode, error)

func (*Queries) GetPruneEntriesForHeights added in v1.0.11

func (q *Queries) GetPruneEntriesForHeights(ctx context.Context, heights []int64) ([]GraphPruneLog, error)

func (*Queries) GetPruneHashByHeight added in v1.0.11

func (q *Queries) GetPruneHashByHeight(ctx context.Context, blockHeight int64) ([]byte, error)

func (*Queries) GetPruneTip added in v1.0.11

func (q *Queries) GetPruneTip(ctx context.Context) (GraphPruneLog, error)

func (*Queries) GetPublicV1ChannelsBySCID added in v1.0.11

func (q *Queries) GetPublicV1ChannelsBySCID(ctx context.Context, arg GetPublicV1ChannelsBySCIDParams) ([]GraphChannel, error)

func (*Queries) GetSCIDByOutpoint added in v1.0.11

func (q *Queries) GetSCIDByOutpoint(ctx context.Context, arg GetSCIDByOutpointParams) ([]byte, error)

func (*Queries) GetSourceNodesByVersion added in v1.0.10

func (q *Queries) GetSourceNodesByVersion(ctx context.Context, version int16) ([]GetSourceNodesByVersionRow, error)

func (*Queries) GetV1DisabledSCIDs added in v1.0.11

func (q *Queries) GetV1DisabledSCIDs(ctx context.Context) ([][]byte, error)

NOTE: this is V1 specific since for V1, disabled is a simple, single boolean. The proposed V2 policy structure will have a more complex disabled bit vector and so the query for V2 may differ.

func (*Queries) GetZombieChannel added in v1.0.11

func (q *Queries) GetZombieChannel(ctx context.Context, arg GetZombieChannelParams) (GraphZombieChannel, error)

func (*Queries) GetZombieChannelsSCIDs added in v1.0.11

func (q *Queries) GetZombieChannelsSCIDs(ctx context.Context, arg GetZombieChannelsSCIDsParams) ([]GraphZombieChannel, error)

func (*Queries) HighestSCID added in v1.0.10

func (q *Queries) HighestSCID(ctx context.Context, version int16) ([]byte, error)

func (*Queries) InsertAMPSubInvoice added in v1.0.7

func (q *Queries) InsertAMPSubInvoice(ctx context.Context, arg InsertAMPSubInvoiceParams) error

func (*Queries) InsertAMPSubInvoiceHTLC

func (q *Queries) InsertAMPSubInvoiceHTLC(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) error

func (*Queries) InsertChannelFeature added in v1.0.10

func (q *Queries) InsertChannelFeature(ctx context.Context, arg InsertChannelFeatureParams) error

func (*Queries) InsertChannelMig added in v1.0.11

func (q *Queries) InsertChannelMig(ctx context.Context, arg InsertChannelMigParams) (int64, error)

NOTE: This query is only meant to be used by the graph SQL migration since for that migration, in order to be retry-safe, we don't want to error out if we re-insert the same channel again (which would error if the normal CreateChannel query is used because of the uniqueness constraint on the scid and version columns).

func (*Queries) InsertClosedChannel added in v1.0.11

func (q *Queries) InsertClosedChannel(ctx context.Context, scid []byte) error

func (*Queries) InsertEdgePolicyMig added in v1.0.11

func (q *Queries) InsertEdgePolicyMig(ctx context.Context, arg InsertEdgePolicyMigParams) (int64, error)

NOTE: This query is only meant to be used by the graph SQL migration since for that migration, in order to be retry-safe, we don't want to error out if we re-insert the same policy (which would error if the normal UpsertEdgePolicy query is used because of the constraint in that query that requires a policy update to have a newer last_update than the existing one).

func (*Queries) InsertInvoice

func (q *Queries) InsertInvoice(ctx context.Context, arg InsertInvoiceParams) (int64, error)

func (*Queries) InsertInvoiceFeature

func (q *Queries) InsertInvoiceFeature(ctx context.Context, arg InsertInvoiceFeatureParams) error

func (*Queries) InsertInvoiceHTLC

func (q *Queries) InsertInvoiceHTLC(ctx context.Context, arg InsertInvoiceHTLCParams) (int64, error)

func (*Queries) InsertInvoiceHTLCCustomRecord

func (q *Queries) InsertInvoiceHTLCCustomRecord(ctx context.Context, arg InsertInvoiceHTLCCustomRecordParams) error

func (*Queries) InsertKVInvoiceKeyAndAddIndex added in v1.0.7

func (q *Queries) InsertKVInvoiceKeyAndAddIndex(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error

func (*Queries) InsertMigratedInvoice added in v1.0.7

func (q *Queries) InsertMigratedInvoice(ctx context.Context, arg InsertMigratedInvoiceParams) (int64, error)

func (*Queries) InsertNodeFeature added in v1.0.10

func (q *Queries) InsertNodeFeature(ctx context.Context, arg InsertNodeFeatureParams) error

func (*Queries) InsertNodeMig added in v1.0.11

func (q *Queries) InsertNodeMig(ctx context.Context, arg InsertNodeMigParams) (int64, error)

NOTE: This query is only meant to be used by the graph SQL migration since for that migration, in order to be retry-safe, we don't want to error out if we re-insert the same node (which would error if the normal UpsertNode query is used because of the constraint in that query that requires a node update to have a newer last_update than the existing node).

func (*Queries) IsClosedChannel added in v1.0.11

func (q *Queries) IsClosedChannel(ctx context.Context, scid []byte) (bool, error)

func (*Queries) IsPublicV1Node added in v1.0.11

func (q *Queries) IsPublicV1Node(ctx context.Context, pubKey []byte) (bool, error)

func (*Queries) IsZombieChannel added in v1.0.11

func (q *Queries) IsZombieChannel(ctx context.Context, arg IsZombieChannelParams) (bool, error)

func (*Queries) ListChannelsByNodeID added in v1.0.11

func (q *Queries) ListChannelsByNodeID(ctx context.Context, arg ListChannelsByNodeIDParams) ([]ListChannelsByNodeIDRow, error)

func (*Queries) ListChannelsForNodeIDs added in v1.0.11

func (q *Queries) ListChannelsForNodeIDs(ctx context.Context, arg ListChannelsForNodeIDsParams) ([]ListChannelsForNodeIDsRow, error)

func (*Queries) ListChannelsPaginated added in v1.0.11

func (q *Queries) ListChannelsPaginated(ctx context.Context, arg ListChannelsPaginatedParams) ([]ListChannelsPaginatedRow, error)

func (*Queries) ListChannelsWithPoliciesForCachePaginated added in v1.0.11

func (*Queries) ListChannelsWithPoliciesPaginated added in v1.0.11

func (*Queries) ListNodeIDsAndPubKeys added in v1.0.11

func (q *Queries) ListNodeIDsAndPubKeys(ctx context.Context, arg ListNodeIDsAndPubKeysParams) ([]ListNodeIDsAndPubKeysRow, error)

func (*Queries) ListNodesPaginated added in v1.0.11

func (q *Queries) ListNodesPaginated(ctx context.Context, arg ListNodesPaginatedParams) ([]GraphNode, error)

func (*Queries) NextInvoiceSettleIndex

func (q *Queries) NextInvoiceSettleIndex(ctx context.Context) (int64, error)

func (*Queries) OnAMPSubInvoiceCanceled

func (q *Queries) OnAMPSubInvoiceCanceled(ctx context.Context, arg OnAMPSubInvoiceCanceledParams) error

func (*Queries) OnAMPSubInvoiceCreated

func (q *Queries) OnAMPSubInvoiceCreated(ctx context.Context, arg OnAMPSubInvoiceCreatedParams) error

func (*Queries) OnAMPSubInvoiceSettled

func (q *Queries) OnAMPSubInvoiceSettled(ctx context.Context, arg OnAMPSubInvoiceSettledParams) error

func (*Queries) OnInvoiceCanceled

func (q *Queries) OnInvoiceCanceled(ctx context.Context, arg OnInvoiceCanceledParams) error

func (*Queries) OnInvoiceCreated

func (q *Queries) OnInvoiceCreated(ctx context.Context, arg OnInvoiceCreatedParams) error

func (*Queries) OnInvoiceSettled

func (q *Queries) OnInvoiceSettled(ctx context.Context, arg OnInvoiceSettledParams) error

func (*Queries) SetKVInvoicePaymentHash added in v1.0.7

func (q *Queries) SetKVInvoicePaymentHash(ctx context.Context, arg SetKVInvoicePaymentHashParams) error

func (*Queries) SetMigration added in v1.0.7

func (q *Queries) SetMigration(ctx context.Context, arg SetMigrationParams) error

func (*Queries) UpdateAMPSubInvoiceHTLCPreimage

func (q *Queries) UpdateAMPSubInvoiceHTLCPreimage(ctx context.Context, arg UpdateAMPSubInvoiceHTLCPreimageParams) (sql.Result, error)

func (*Queries) UpdateAMPSubInvoiceState

func (q *Queries) UpdateAMPSubInvoiceState(ctx context.Context, arg UpdateAMPSubInvoiceStateParams) error

func (*Queries) UpdateInvoiceAmountPaid

func (q *Queries) UpdateInvoiceAmountPaid(ctx context.Context, arg UpdateInvoiceAmountPaidParams) (sql.Result, error)

func (*Queries) UpdateInvoiceHTLC

func (q *Queries) UpdateInvoiceHTLC(ctx context.Context, arg UpdateInvoiceHTLCParams) error

func (*Queries) UpdateInvoiceHTLCs

func (q *Queries) UpdateInvoiceHTLCs(ctx context.Context, arg UpdateInvoiceHTLCsParams) error

func (*Queries) UpdateInvoiceState

func (q *Queries) UpdateInvoiceState(ctx context.Context, arg UpdateInvoiceStateParams) (sql.Result, error)

func (*Queries) UpsertAMPSubInvoice

func (q *Queries) UpsertAMPSubInvoice(ctx context.Context, arg UpsertAMPSubInvoiceParams) (sql.Result, error)

func (*Queries) UpsertChanPolicyExtraType added in v1.0.11

func (q *Queries) UpsertChanPolicyExtraType(ctx context.Context, arg UpsertChanPolicyExtraTypeParams) error

func (*Queries) UpsertChannelExtraType added in v1.0.11

func (q *Queries) UpsertChannelExtraType(ctx context.Context, arg UpsertChannelExtraTypeParams) error

func (*Queries) UpsertEdgePolicy added in v1.0.11

func (q *Queries) UpsertEdgePolicy(ctx context.Context, arg UpsertEdgePolicyParams) (int64, error)

func (*Queries) UpsertNode added in v1.0.10

func (q *Queries) UpsertNode(ctx context.Context, arg UpsertNodeParams) (int64, error)

func (*Queries) UpsertNodeAddress added in v1.0.11

func (q *Queries) UpsertNodeAddress(ctx context.Context, arg UpsertNodeAddressParams) error

func (*Queries) UpsertNodeExtraType added in v1.0.10

func (q *Queries) UpsertNodeExtraType(ctx context.Context, arg UpsertNodeExtraTypeParams) error

func (*Queries) UpsertPruneLogEntry added in v1.0.11

func (q *Queries) UpsertPruneLogEntry(ctx context.Context, arg UpsertPruneLogEntryParams) error

func (*Queries) UpsertZombieChannel added in v1.0.11

func (q *Queries) UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type SetKVInvoicePaymentHashParams added in v1.0.7

type SetKVInvoicePaymentHashParams struct {
	ID   int64
	Hash []byte
}

type SetMigrationParams added in v1.0.7

type SetMigrationParams struct {
	Version       int32
	MigrationTime time.Time
}

type UpdateAMPSubInvoiceHTLCPreimageParams

type UpdateAMPSubInvoiceHTLCPreimageParams struct {
	InvoiceID int64
	SetID     []byte
	ChanID    string
	HtlcID    int64
	Preimage  []byte
}

type UpdateAMPSubInvoiceStateParams

type UpdateAMPSubInvoiceStateParams struct {
	SetID       []byte
	State       int16
	SettleIndex sql.NullInt64
	SettledAt   sql.NullTime
}

type UpdateInvoiceAmountPaidParams

type UpdateInvoiceAmountPaidParams struct {
	ID             int64
	AmountPaidMsat int64
}

type UpdateInvoiceHTLCParams

type UpdateInvoiceHTLCParams struct {
	HtlcID      int64
	ChanID      string
	InvoiceID   int64
	State       int16
	ResolveTime sql.NullTime
}

type UpdateInvoiceHTLCsParams

type UpdateInvoiceHTLCsParams struct {
	InvoiceID   int64
	State       int16
	ResolveTime sql.NullTime
}

type UpdateInvoiceStateParams

type UpdateInvoiceStateParams struct {
	ID          int64
	State       int16
	Preimage    []byte
	SettleIndex sql.NullInt64
	SettledAt   sql.NullTime
}

type UpsertAMPSubInvoiceParams

type UpsertAMPSubInvoiceParams struct {
	SetID     []byte
	State     int16
	CreatedAt time.Time
	InvoiceID int64
}

type UpsertChanPolicyExtraTypeParams added in v1.0.11

type UpsertChanPolicyExtraTypeParams struct {
	ChannelPolicyID int64
	Type            int64
	Value           []byte
}

type UpsertChannelExtraTypeParams added in v1.0.11

type UpsertChannelExtraTypeParams struct {
	ChannelID int64
	Type      int64
	Value     []byte
}

type UpsertEdgePolicyParams added in v1.0.11

type UpsertEdgePolicyParams struct {
	Version                 int16
	ChannelID               int64
	NodeID                  int64
	Timelock                int32
	FeePpm                  int64
	BaseFeeMsat             int64
	MinHtlcMsat             int64
	LastUpdate              sql.NullInt64
	Disabled                sql.NullBool
	MaxHtlcMsat             sql.NullInt64
	InboundBaseFeeMsat      sql.NullInt64
	InboundFeeRateMilliMsat sql.NullInt64
	MessageFlags            sql.NullInt16
	ChannelFlags            sql.NullInt16
	Signature               []byte
}

type UpsertNodeAddressParams added in v1.0.11

type UpsertNodeAddressParams struct {
	NodeID   int64
	Type     int16
	Address  string
	Position int32
}

type UpsertNodeExtraTypeParams added in v1.0.10

type UpsertNodeExtraTypeParams struct {
	NodeID int64
	Type   int64
	Value  []byte
}

type UpsertNodeParams added in v1.0.10

type UpsertNodeParams struct {
	Version    int16
	PubKey     []byte
	Alias      sql.NullString
	LastUpdate sql.NullInt64
	Color      sql.NullString
	Signature  []byte
}

type UpsertPruneLogEntryParams added in v1.0.11

type UpsertPruneLogEntryParams struct {
	BlockHeight int64
	BlockHash   []byte
}

type UpsertZombieChannelParams added in v1.0.11

type UpsertZombieChannelParams struct {
	Scid     []byte
	Version  int16
	NodeKey1 []byte
	NodeKey2 []byte
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL