sqlc

package

Go to main page

Versions in this module

v1

v1.0.13

May 28, 2026

Changes in this version

+ type AddV2ChannelProofParams struct

+ Scid []byte

+ Signature []byte

+ type ChainParam struct

+ Network string

+ SingleRow bool

type CreateChannelParams

+ FundingPkScript []byte

+ MerkleRootHash []byte

+ Signature []byte

+ type FailAttemptParams struct

+ AttemptIndex int64

+ FailureMsg []byte

+ FailureSourceIndex sql.NullInt32

+ HtlcFailReason sql.NullInt32

+ ResolutionTime time.Time

+ ResolutionType int32

+ type FailPaymentParams struct

+ FailReason sql.NullInt32

+ PaymentIdentifier []byte

+ type FetchHopsForAttemptsRow struct

+ AmpChildIndex sql.NullInt32

+ AmpRootShare []byte

+ AmpSetID []byte

+ AmtToForward int64

+ BlindedPathTotalAmt sql.NullInt64

+ BlindingPoint []byte

+ EncryptedData []byte

+ HopIndex int32

+ HtlcAttemptIndex int64

+ ID int64

+ MetaData []byte

+ MppPaymentAddr []byte

+ MppTotalMsat sql.NullInt64

+ OutgoingTimeLock int32

+ PubKey []byte

+ Scid string

+ type FetchHtlcAttemptResolutionsForPaymentsRow struct

+ PaymentID int64

+ ResolutionType sql.NullInt32

+ type FetchHtlcAttemptsForPaymentsRow struct

+ AttemptIndex int64

+ AttemptTime time.Time

+ FailureMsg []byte

+ FailureSourceIndex sql.NullInt32

+ FirstHopAmountMsat int64

+ HtlcFailReason sql.NullInt32

+ ID int64

+ PaymentHash []byte

+ PaymentID int64

+ ResolutionTime sql.NullTime

+ ResolutionType sql.NullInt32

+ RouteSourceKey []byte

+ RouteTotalAmount int64

+ RouteTotalTimeLock int32

+ SessionKey []byte

+ SettlePreimage []byte

+ type FetchNonTerminalPaymentsParams struct

+ ID int64

+ Limit int32

+ type FetchNonTerminalPaymentsRow struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ ID int64

+ IntentPayload []byte

+ IntentType sql.NullInt16

+ PaymentIdentifier []byte

+ func (r FetchNonTerminalPaymentsRow) GetPayment() Payment

+ func (r FetchNonTerminalPaymentsRow) GetPaymentIntent() PaymentIntent

+ type FetchPaymentRow struct

+ IntentPayload []byte

+ IntentType sql.NullInt16

+ Payment Payment

+ func (r FetchPaymentRow) GetPayment() Payment

+ func (r FetchPaymentRow) GetPaymentIntent() PaymentIntent

+ type FetchPaymentsByIDsMigRow struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ HtlcAttemptCount int64

+ ID int64

+ PaymentIdentifier []byte

+ type FetchPaymentsByIDsRow struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ ID int64

+ IntentPayload []byte

+ IntentType sql.NullInt16

+ PaymentIdentifier []byte

+ func (r FetchPaymentsByIDsRow) GetPayment() Payment

+ func (r FetchPaymentsByIDsRow) GetPaymentIntent() PaymentIntent

+ type FetchPendingInvoicesParams struct

+ IDCursor int64

+ NumLimit int32

+ type FilterInvoicesByAddIndexParams struct

+ AddIndexGet int64

+ NumLimit int32

+ type FilterInvoicesBySettleIndexParams struct

+ IDCursor int64

+ NumLimit int32

+ SettleIndexGet sql.NullInt64

+ type FilterInvoicesForwardParams struct

+ AddIndexGet int64

+ CreatedAfter time.Time

+ CreatedBefore time.Time

+ NumLimit int32

+ PendingOnly interface{}

+ type FilterInvoicesReverseParams struct

+ AddIndexLet int64

+ CreatedAfter time.Time

+ CreatedBefore time.Time

+ NumLimit int32

+ PendingOnly interface{}

+ type FilterPaymentsDescParams struct

+ CreatedAfter time.Time

+ CreatedBefore time.Time

+ IndexOffsetGet sql.NullInt64

+ IndexOffsetLet sql.NullInt64

+ IntentType sql.NullInt16

+ NumLimit int32

+ type FilterPaymentsDescRow struct

+ IntentPayload []byte

+ IntentType sql.NullInt16

+ Payment Payment

+ type FilterPaymentsParams struct

+ CreatedAfter time.Time

+ CreatedBefore time.Time

+ IndexOffsetGet sql.NullInt64

+ IndexOffsetLet sql.NullInt64

+ IntentType sql.NullInt16

+ NumLimit int32

+ type FilterPaymentsRow struct

+ IntentPayload []byte

+ IntentType sql.NullInt16

+ Payment Payment

+ func (r FilterPaymentsRow) GetPayment() Payment

+ func (r FilterPaymentsRow) GetPaymentIntent() PaymentIntent

type GetChannelAndNodesBySCIDRow

+ FundingPkScript []byte

+ MerkleRootHash []byte

+ Signature []byte

type GetChannelByOutpointWithPoliciesRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

type GetChannelBySCIDWithPoliciesRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

type GetChannelsByIDsRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

+ type GetChannelsByPolicyBlockRangeParams struct

+ EndHeight sql.NullInt64

+ LastBlockHeight sql.NullInt64

+ LastID sql.NullInt64

+ MaxResults interface{}

+ StartHeight sql.NullInt64

+ Version int16

+ type GetChannelsByPolicyBlockRangeRow struct

+ GraphChannel GraphChannel

+ GraphNode GraphNode

+ GraphNode_2 GraphNode

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1BlockHeight sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1DisableFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2BlockHeight sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2DisableFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

type GetChannelsByPolicyLastUpdateRangeRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

type GetChannelsBySCIDWithPoliciesRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

+ type GetNodesByBlockHeightRangeParams struct

+ EndHeight sql.NullInt64

+ LastBlockHeight sql.NullInt64

+ LastPubKey []byte

+ MaxResults interface{}

+ OnlyPublic interface{}

+ StartHeight sql.NullInt64

+ Version int16

+ type GetPublicNodesByLastUpdateRangeParams struct

+ EndTime sql.NullInt64

+ LastPubKey []byte

+ LastUpdate sql.NullInt64

+ MaxResults interface{}

+ StartTime sql.NullInt64

+ type GetPublicV2ChannelsBySCIDParams struct

+ EndScid []byte

+ StartScid []byte

type GraphChannel

+ FundingPkScript []byte

+ MerkleRootHash []byte

+ Signature []byte

type GraphChannelPolicy

+ BlockHeight sql.NullInt64

+ DisableFlags sql.NullInt16

type GraphNode

+ BlockHeight sql.NullInt64

+ type InsertHtlcAttemptParams struct

+ AttemptIndex int64

+ AttemptTime time.Time

+ FirstHopAmountMsat int64

+ PaymentHash []byte

+ PaymentID int64

+ RouteSourceKey []byte

+ RouteTotalAmount int64

+ RouteTotalTimeLock int32

+ SessionKey []byte

+ type InsertPaymentAttemptFirstHopCustomRecordParams struct

+ HtlcAttemptIndex int64

+ Key int64

+ Value []byte

+ type InsertPaymentDuplicateMigParams struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ PaymentID int64

+ SettlePreimage []byte

+ SettleTime sql.NullTime

+ type InsertPaymentFirstHopCustomRecordParams struct

+ Key int64

+ PaymentID int64

+ Value []byte

+ type InsertPaymentHopCustomRecordParams struct

+ HopID int64

+ Key int64

+ Value []byte

+ type InsertPaymentIntentParams struct

+ IntentPayload []byte

+ IntentType int16

+ PaymentID int64

+ type InsertPaymentMigParams struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ PaymentIdentifier []byte

+ type InsertPaymentParams struct

+ AmountMsat int64

+ CreatedAt time.Time

+ PaymentIdentifier []byte

+ type InsertRouteHopAmpParams struct

+ ChildIndex int32

+ HopID int64

+ RootShare []byte

+ SetID []byte

+ type InsertRouteHopBlindedParams struct

+ BlindedPathTotalAmt sql.NullInt64

+ BlindingPoint []byte

+ EncryptedData []byte

+ HopID int64

+ type InsertRouteHopMppParams struct

+ HopID int64

+ PaymentAddr []byte

+ TotalMsat int64

+ type InsertRouteHopParams struct

+ AmtToForward int64

+ HopIndex int32

+ HtlcAttemptIndex int64

+ MetaData []byte

+ OutgoingTimeLock int32

+ PubKey []byte

+ Scid string

type ListChannelsByNodeIDRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

type ListChannelsForNodeIDsRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

+ type ListChannelsPaginatedV2Params struct

+ ID int64

+ Limit int32

+ type ListChannelsPaginatedV2Row struct

+ FundingPkScript []byte

+ ID int64

+ Outpoint string

type ListChannelsWithPoliciesForCachePaginatedRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy1Version sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

+ Policy2Version sql.NullInt16

type ListChannelsWithPoliciesPaginatedRow

+ Policy1BlockHeight sql.NullInt64

+ Policy1DisableFlags sql.NullInt16

+ Policy2BlockHeight sql.NullInt64

+ Policy2DisableFlags sql.NullInt16

+ type NodeExistsParams struct

+ PubKey []byte

+ Version int16

+ type Payment struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ ID int64

+ PaymentIdentifier []byte

+ type PaymentAndIntent interface

+ GetPayment func() Payment

+ GetPaymentIntent func() PaymentIntent

+ type PaymentAttemptFirstHopCustomRecord struct

+ HtlcAttemptIndex int64

+ ID int64

+ Key int64

+ Value []byte

+ type PaymentDuplicate struct

+ AmountMsat int64

+ CreatedAt time.Time

+ FailReason sql.NullInt32

+ ID int64

+ PaymentID int64

+ SettlePreimage []byte

+ SettleTime sql.NullTime

+ type PaymentFirstHopCustomRecord struct

+ ID int64

+ Key int64

+ PaymentID int64

+ Value []byte

+ type PaymentHopCustomRecord struct

+ HopID int64

+ ID int64

+ Key int64

+ Value []byte

+ type PaymentHtlcAttempt struct

+ AttemptIndex int64

+ AttemptTime time.Time

+ FirstHopAmountMsat int64

+ ID int64

+ PaymentHash []byte

+ PaymentID int64

+ RouteSourceKey []byte

+ RouteTotalAmount int64

+ RouteTotalTimeLock int32

+ SessionKey []byte

+ type PaymentHtlcAttemptResolution struct

+ AttemptIndex int64

+ FailureMsg []byte

+ FailureSourceIndex sql.NullInt32

+ HtlcFailReason sql.NullInt32

+ ResolutionTime time.Time

+ ResolutionType int32

+ SettlePreimage []byte

+ type PaymentIntent struct

+ ID int64

+ IntentPayload []byte

+ IntentType int16

+ PaymentID int64

+ type PaymentRouteHop struct

+ AmtToForward int64

+ HopIndex int32

+ HtlcAttemptIndex int64

+ ID int64

+ MetaData []byte

+ OutgoingTimeLock int32

+ PubKey []byte

+ Scid string

+ type PaymentRouteHopAmp struct

+ ChildIndex int32

+ HopID int64

+ RootShare []byte

+ SetID []byte

+ type PaymentRouteHopBlinded struct

+ BlindedPathTotalAmt sql.NullInt64

+ BlindingPoint []byte

+ EncryptedData []byte

+ HopID int64

+ type PaymentRouteHopMpp struct

+ HopID int64

+ PaymentAddr []byte

+ TotalMsat int64

type Querier

+ AddV2ChannelProof func(ctx context.Context, arg AddV2ChannelProofParams) (sql.Result, error)

+ CountPayments func(ctx context.Context) (int64, error)

+ DeleteFailedAttempts func(ctx context.Context, paymentID int64) error

+ DeletePayment func(ctx context.Context, id int64) error

+ FailAttempt func(ctx context.Context, arg FailAttemptParams) error

+ FailPayment func(ctx context.Context, arg FailPaymentParams) (sql.Result, error)

+ FetchHopLevelCustomRecords func(ctx context.Context, hopIds []int64) ([]PaymentHopCustomRecord, error)

+ FetchHopsForAttempts func(ctx context.Context, htlcAttemptIndices []int64) ([]FetchHopsForAttemptsRow, error)

+ FetchHtlcAttemptResolutionsForPayments func(ctx context.Context, paymentIds []int64) ([]FetchHtlcAttemptResolutionsForPaymentsRow, error)

+ FetchHtlcAttemptsForPayments func(ctx context.Context, paymentIds []int64) ([]FetchHtlcAttemptsForPaymentsRow, error)

+ FetchNonTerminalPayments func(ctx context.Context, arg FetchNonTerminalPaymentsParams) ([]FetchNonTerminalPaymentsRow, error)

+ FetchPayment func(ctx context.Context, paymentIdentifier []byte) (FetchPaymentRow, error)

+ FetchPaymentDuplicates func(ctx context.Context, paymentID int64) ([]PaymentDuplicate, error)

+ FetchPaymentLevelFirstHopCustomRecords func(ctx context.Context, paymentIds []int64) ([]PaymentFirstHopCustomRecord, error)

+ FetchPaymentsByIDs func(ctx context.Context, paymentIds []int64) ([]FetchPaymentsByIDsRow, error)

+ FetchPaymentsByIDsMig func(ctx context.Context, paymentIds []int64) ([]FetchPaymentsByIDsMigRow, error)

+ FetchPendingInvoices func(ctx context.Context, arg FetchPendingInvoicesParams) ([]Invoice, error)

+ FetchRouteLevelFirstHopCustomRecords func(ctx context.Context, htlcAttemptIndices []int64) ([]PaymentAttemptFirstHopCustomRecord, error)

+ FilterInvoicesByAddIndex func(ctx context.Context, arg FilterInvoicesByAddIndexParams) ([]Invoice, error)

+ FilterInvoicesBySettleIndex func(ctx context.Context, arg FilterInvoicesBySettleIndexParams) ([]Invoice, error)

+ FilterInvoicesForward func(ctx context.Context, arg FilterInvoicesForwardParams) ([]Invoice, error)

+ FilterInvoicesReverse func(ctx context.Context, arg FilterInvoicesReverseParams) ([]Invoice, error)

+ FilterPayments func(ctx context.Context, arg FilterPaymentsParams) ([]FilterPaymentsRow, error)

+ FilterPaymentsDesc func(ctx context.Context, arg FilterPaymentsDescParams) ([]FilterPaymentsDescRow, error)

+ GetChainNetwork func(ctx context.Context) (string, error)

+ GetChannelsByPolicyBlockRange func(ctx context.Context, arg GetChannelsByPolicyBlockRangeParams) ([]GetChannelsByPolicyBlockRangeRow, error)

+ GetInvoiceByAddr func(ctx context.Context, paymentAddr []byte) (Invoice, error)

+ GetNodesByBlockHeightRange func(ctx context.Context, arg GetNodesByBlockHeightRangeParams) ([]GraphNode, error)

+ GetPublicNodesByLastUpdateRange func(ctx context.Context, arg GetPublicNodesByLastUpdateRangeParams) ([]GraphNode, error)

+ GetPublicV2ChannelsBySCID func(ctx context.Context, arg GetPublicV2ChannelsBySCIDParams) ([]GraphChannel, error)

+ GetV2DisabledSCIDs func(ctx context.Context) ([][]byte, error)

+ InsertChainNetwork func(ctx context.Context, network string) error

+ InsertHtlcAttempt func(ctx context.Context, arg InsertHtlcAttemptParams) (int64, error)

+ InsertPayment func(ctx context.Context, arg InsertPaymentParams) (int64, error)

+ InsertPaymentAttemptFirstHopCustomRecord func(ctx context.Context, arg InsertPaymentAttemptFirstHopCustomRecordParams) error

+ InsertPaymentDuplicateMig func(ctx context.Context, arg InsertPaymentDuplicateMigParams) (int64, error)

+ InsertPaymentFirstHopCustomRecord func(ctx context.Context, arg InsertPaymentFirstHopCustomRecordParams) error

+ InsertPaymentHopCustomRecord func(ctx context.Context, arg InsertPaymentHopCustomRecordParams) error

+ InsertPaymentIntent func(ctx context.Context, arg InsertPaymentIntentParams) (int64, error)

+ InsertPaymentMig func(ctx context.Context, arg InsertPaymentMigParams) (int64, error)

+ InsertRouteHop func(ctx context.Context, arg InsertRouteHopParams) (int64, error)

+ InsertRouteHopAmp func(ctx context.Context, arg InsertRouteHopAmpParams) error

+ InsertRouteHopBlinded func(ctx context.Context, arg InsertRouteHopBlindedParams) error

+ InsertRouteHopMpp func(ctx context.Context, arg InsertRouteHopMppParams) error

+ IsPublicV2Node func(ctx context.Context, pubKey []byte) (bool, error)

+ ListChannelsPaginatedV2 func(ctx context.Context, arg ListChannelsPaginatedV2Params) ([]ListChannelsPaginatedV2Row, error)

+ NodeExists func(ctx context.Context, arg NodeExistsParams) (bool, error)

+ SettleAttempt func(ctx context.Context, arg SettleAttemptParams) error

type Queries

+ func (q *Queries) AddV2ChannelProof(ctx context.Context, arg AddV2ChannelProofParams) (sql.Result, error)

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

+ func (q *Queries) DeleteFailedAttempts(ctx context.Context, paymentID int64) error

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

+ func (q *Queries) FailAttempt(ctx context.Context, arg FailAttemptParams) error

+ func (q *Queries) FailPayment(ctx context.Context, arg FailPaymentParams) (sql.Result, error)

+ func (q *Queries) FetchHopLevelCustomRecords(ctx context.Context, hopIds []int64) ([]PaymentHopCustomRecord, error)

+ func (q *Queries) FetchHopsForAttempts(ctx context.Context, htlcAttemptIndices []int64) ([]FetchHopsForAttemptsRow, error)

+ func (q *Queries) FetchHtlcAttemptResolutionsForPayments(ctx context.Context, paymentIds []int64) ([]FetchHtlcAttemptResolutionsForPaymentsRow, error)

+ func (q *Queries) FetchHtlcAttemptsForPayments(ctx context.Context, paymentIds []int64) ([]FetchHtlcAttemptsForPaymentsRow, error)

+ func (q *Queries) FetchNonTerminalPayments(ctx context.Context, arg FetchNonTerminalPaymentsParams) ([]FetchNonTerminalPaymentsRow, error)

+ func (q *Queries) FetchPayment(ctx context.Context, paymentIdentifier []byte) (FetchPaymentRow, error)

+ func (q *Queries) FetchPaymentDuplicates(ctx context.Context, paymentID int64) ([]PaymentDuplicate, error)

+ func (q *Queries) FetchPaymentLevelFirstHopCustomRecords(ctx context.Context, paymentIds []int64) ([]PaymentFirstHopCustomRecord, error)

+ func (q *Queries) FetchPaymentsByIDs(ctx context.Context, paymentIds []int64) ([]FetchPaymentsByIDsRow, error)

+ func (q *Queries) FetchPaymentsByIDsMig(ctx context.Context, paymentIds []int64) ([]FetchPaymentsByIDsMigRow, error)

+ func (q *Queries) FetchPendingInvoices(ctx context.Context, arg FetchPendingInvoicesParams) ([]Invoice, error)

+ func (q *Queries) FetchRouteLevelFirstHopCustomRecords(ctx context.Context, htlcAttemptIndices []int64) ([]PaymentAttemptFirstHopCustomRecord, error)

+ func (q *Queries) FilterInvoicesByAddIndex(ctx context.Context, arg FilterInvoicesByAddIndexParams) ([]Invoice, error)

+ func (q *Queries) FilterInvoicesBySettleIndex(ctx context.Context, arg FilterInvoicesBySettleIndexParams) ([]Invoice, error)

+ func (q *Queries) FilterInvoicesForward(ctx context.Context, arg FilterInvoicesForwardParams) ([]Invoice, error)

+ func (q *Queries) FilterInvoicesReverse(ctx context.Context, arg FilterInvoicesReverseParams) ([]Invoice, error)

+ func (q *Queries) FilterPayments(ctx context.Context, arg FilterPaymentsParams) ([]FilterPaymentsRow, error)

+ func (q *Queries) FilterPaymentsDesc(ctx context.Context, arg FilterPaymentsDescParams) ([]FilterPaymentsDescRow, error)

+ func (q *Queries) GetChainNetwork(ctx context.Context) (string, error)

+ func (q *Queries) GetChannelsByPolicyBlockRange(ctx context.Context, arg GetChannelsByPolicyBlockRangeParams) ([]GetChannelsByPolicyBlockRangeRow, error)

+ func (q *Queries) GetInvoiceByAddr(ctx context.Context, paymentAddr []byte) (Invoice, error)

+ func (q *Queries) GetNodesByBlockHeightRange(ctx context.Context, arg GetNodesByBlockHeightRangeParams) ([]GraphNode, error)

+ func (q *Queries) GetPublicNodesByLastUpdateRange(ctx context.Context, arg GetPublicNodesByLastUpdateRangeParams) ([]GraphNode, error)

+ func (q *Queries) GetPublicV2ChannelsBySCID(ctx context.Context, arg GetPublicV2ChannelsBySCIDParams) ([]GraphChannel, error)

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

+ func (q *Queries) InsertChainNetwork(ctx context.Context, network string) error

+ func (q *Queries) InsertHtlcAttempt(ctx context.Context, arg InsertHtlcAttemptParams) (int64, error)

+ func (q *Queries) InsertPayment(ctx context.Context, arg InsertPaymentParams) (int64, error)

+ func (q *Queries) InsertPaymentAttemptFirstHopCustomRecord(ctx context.Context, arg InsertPaymentAttemptFirstHopCustomRecordParams) error

+ func (q *Queries) InsertPaymentDuplicateMig(ctx context.Context, arg InsertPaymentDuplicateMigParams) (int64, error)

+ func (q *Queries) InsertPaymentFirstHopCustomRecord(ctx context.Context, arg InsertPaymentFirstHopCustomRecordParams) error

+ func (q *Queries) InsertPaymentHopCustomRecord(ctx context.Context, arg InsertPaymentHopCustomRecordParams) error

+ func (q *Queries) InsertPaymentIntent(ctx context.Context, arg InsertPaymentIntentParams) (int64, error)

+ func (q *Queries) InsertPaymentMig(ctx context.Context, arg InsertPaymentMigParams) (int64, error)

+ func (q *Queries) InsertRouteHop(ctx context.Context, arg InsertRouteHopParams) (int64, error)

+ func (q *Queries) InsertRouteHopAmp(ctx context.Context, arg InsertRouteHopAmpParams) error

+ func (q *Queries) InsertRouteHopBlinded(ctx context.Context, arg InsertRouteHopBlindedParams) error

+ func (q *Queries) InsertRouteHopMpp(ctx context.Context, arg InsertRouteHopMppParams) error

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

+ func (q *Queries) ListChannelsPaginatedV2(ctx context.Context, arg ListChannelsPaginatedV2Params) ([]ListChannelsPaginatedV2Row, error)

+ func (q *Queries) NodeExists(ctx context.Context, arg NodeExistsParams) (bool, error)

+ func (q *Queries) SettleAttempt(ctx context.Context, arg SettleAttemptParams) error

+ type SettleAttemptParams struct

+ AttemptIndex int64

+ ResolutionTime time.Time

+ ResolutionType int32

+ SettlePreimage []byte

type UpsertEdgePolicyParams

+ BlockHeight sql.NullInt64

+ DisableFlags sql.NullInt16

type UpsertNodeParams

+ BlockHeight sql.NullInt64

type UpsertSourceNodeParams

+ BlockHeight sql.NullInt64

v1.0.12

Jan 7, 2026

Changes in this version

type Querier

+ UpsertSourceNode func(ctx context.Context, arg UpsertSourceNodeParams) (int64, error)

type Queries

+ func (q *Queries) GetTx() DBTX

+ func (q *Queries) UpsertSourceNode(ctx context.Context, arg UpsertSourceNodeParams) (int64, error)

+ type UpsertSourceNodeParams struct

+ Alias sql.NullString

+ Color sql.NullString

+ LastUpdate sql.NullInt64

+ PubKey []byte

+ Signature []byte

+ Version int16

v1.0.11

Oct 6, 2025

Changes in this version

+ type AddV1ChannelProofParams struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ Node1Signature []byte

+ Node2Signature []byte

+ Scid []byte

+ type ChannelAndNodeIDs interface

+ Channel func() GraphChannel

+ Node1Pub func() []byte

+ Node2Pub func() []byte

+ type ChannelAndNodes interface

+ Channel func() GraphChannel

+ Node1 func() GraphNode

+ Node2 func() GraphNode

+ type DeletePruneLogEntriesInRangeParams struct

+ EndHeight int64

+ StartHeight int64

+ type DeleteZombieChannelParams struct

+ Scid []byte

+ Version int16

+ type GetChannelAndNodesBySCIDParams struct

+ Scid []byte

+ Version int16

+ type GetChannelAndNodesBySCIDRow struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ Capacity sql.NullInt64

+ ID int64

+ Node1PubKey []byte

+ Node1Signature []byte

+ Node2PubKey []byte

+ Node2Signature []byte

+ NodeID1 int64

+ NodeID2 int64

+ Outpoint string

+ Scid []byte

+ Version int16

+ type GetChannelByOutpointWithPoliciesParams struct

+ Outpoint string

+ Version int16

+ type GetChannelByOutpointWithPoliciesRow struct

+ GraphChannel GraphChannel

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type GetChannelBySCIDWithPoliciesParams struct

+ Scid []byte

+ Version int16

+ type GetChannelBySCIDWithPoliciesRow struct

+ GraphChannel GraphChannel

+ GraphNode GraphNode

+ GraphNode_2 GraphNode

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type GetChannelPolicyByChannelAndNodeParams struct

+ ChannelID int64

+ NodeID int64

+ Version int16

+ type GetChannelPolicyExtraTypesBatchRow struct

+ PolicyID int64

+ Type int64

+ Value []byte

+ type GetChannelsByIDsRow struct

+ GraphChannel GraphChannel

+ Node1ID int64

+ Node1PubKey []byte

+ Node2ID int64

+ Node2PubKey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type GetChannelsByOutpointsRow struct

+ GraphChannel GraphChannel

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ func (r GetChannelsByOutpointsRow) Channel() GraphChannel

+ func (r GetChannelsByOutpointsRow) Node1Pub() []byte

+ func (r GetChannelsByOutpointsRow) Node2Pub() []byte

+ type GetChannelsByPolicyLastUpdateRangeParams struct

+ EndTime sql.NullInt64

+ LastID sql.NullInt64

+ LastUpdateTime sql.NullInt64

+ MaxResults interface{}

+ StartTime sql.NullInt64

+ Version int16

+ type GetChannelsByPolicyLastUpdateRangeRow struct

+ GraphChannel GraphChannel

+ GraphNode GraphNode

+ GraphNode_2 GraphNode

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ func (r GetChannelsByPolicyLastUpdateRangeRow) Channel() GraphChannel

+ func (r GetChannelsByPolicyLastUpdateRangeRow) Node1() GraphNode

+ func (r GetChannelsByPolicyLastUpdateRangeRow) Node2() GraphNode

+ type GetChannelsBySCIDRangeParams struct

+ EndScid []byte

+ StartScid []byte

+ type GetChannelsBySCIDRangeRow struct

+ GraphChannel GraphChannel

+ Node1PubKey []byte

+ Node2PubKey []byte

+ func (r GetChannelsBySCIDRangeRow) Channel() GraphChannel

+ func (r GetChannelsBySCIDRangeRow) Node1Pub() []byte

+ func (r GetChannelsBySCIDRangeRow) Node2Pub() []byte

+ type GetChannelsBySCIDWithPoliciesParams struct

+ Scids [][]byte

+ Version int16

+ type GetChannelsBySCIDWithPoliciesRow struct

+ GraphChannel GraphChannel

+ GraphNode GraphNode

+ GraphNode_2 GraphNode

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ func (r GetChannelsBySCIDWithPoliciesRow) Channel() GraphChannel

+ func (r GetChannelsBySCIDWithPoliciesRow) Node1() GraphNode

+ func (r GetChannelsBySCIDWithPoliciesRow) Node1Pub() []byte

+ func (r GetChannelsBySCIDWithPoliciesRow) Node2() GraphNode

+ func (r GetChannelsBySCIDWithPoliciesRow) Node2Pub() []byte

+ type GetChannelsBySCIDsParams struct

+ Scids [][]byte

+ Version int16

+ type GetNodeAddressesRow struct

+ Address string

+ Type int16

+ type GetNodeIDByPubKeyParams struct

+ PubKey []byte

+ Version int16

type GetNodesByLastUpdateRangeParams

+ LastPubKey []byte

+ LastUpdate sql.NullInt64

+ MaxResults interface{}

+ OnlyPublic interface{}

+ type GetPublicV1ChannelsBySCIDParams struct

+ EndScid []byte

+ StartScid []byte

+ type GetSCIDByOutpointParams struct

+ Outpoint string

+ Version int16

+ type GetZombieChannelParams struct

+ Scid []byte

+ Version int16

+ type GetZombieChannelsSCIDsParams struct

+ Scids [][]byte

+ Version int16

+ type GraphChannel struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ Capacity sql.NullInt64

+ ID int64

+ Node1Signature []byte

+ Node2Signature []byte

+ NodeID1 int64

+ NodeID2 int64

+ Outpoint string

+ Scid []byte

+ Version int16

+ type GraphChannelExtraType struct

+ ChannelID int64

+ Type int64

+ Value []byte

+ type GraphChannelFeature struct

+ ChannelID int64

+ FeatureBit int32

+ type GraphChannelPolicy struct

+ BaseFeeMsat int64

+ ChannelFlags sql.NullInt16

+ ChannelID int64

+ Disabled sql.NullBool

+ FeePpm int64

+ ID int64

+ InboundBaseFeeMsat sql.NullInt64

+ InboundFeeRateMilliMsat sql.NullInt64

+ LastUpdate sql.NullInt64

+ MaxHtlcMsat sql.NullInt64

+ MessageFlags sql.NullInt16

+ MinHtlcMsat int64

+ NodeID int64

+ Signature []byte

+ Timelock int32

+ Version int16

+ type GraphChannelPolicyExtraType struct

+ ChannelPolicyID int64

+ Type int64

+ Value []byte

+ type GraphClosedScid struct

+ Scid []byte

+ type GraphNode struct

+ Alias sql.NullString

+ Color sql.NullString

+ ID int64

+ LastUpdate sql.NullInt64

+ PubKey []byte

+ Signature []byte

+ Version int16

+ type GraphNodeAddress struct

+ Address string

+ NodeID int64

+ Position int32

+ Type int16

+ type GraphNodeExtraType struct

+ NodeID int64

+ Type int64

+ Value []byte

+ type GraphNodeFeature struct

+ FeatureBit int32

+ NodeID int64

+ type GraphPruneLog struct

+ BlockHash []byte

+ BlockHeight int64

+ type GraphSourceNode struct

+ NodeID int64

+ type GraphZombieChannel struct

+ NodeKey1 []byte

+ NodeKey2 []byte

+ Scid []byte

+ Version int16

+ type InsertChannelMigParams struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ Capacity sql.NullInt64

+ Node1Signature []byte

+ Node2Signature []byte

+ NodeID1 int64

+ NodeID2 int64

+ Outpoint string

+ Scid []byte

+ Version int16

+ type InsertEdgePolicyMigParams struct

+ BaseFeeMsat int64

+ ChannelFlags sql.NullInt16

+ ChannelID int64

+ Disabled sql.NullBool

+ FeePpm int64

+ InboundBaseFeeMsat sql.NullInt64

+ InboundFeeRateMilliMsat sql.NullInt64

+ LastUpdate sql.NullInt64

+ MaxHtlcMsat sql.NullInt64

+ MessageFlags sql.NullInt16

+ MinHtlcMsat int64

+ NodeID int64

+ Signature []byte

+ Timelock int32

+ Version int16

+ type InsertNodeMigParams struct

+ Alias sql.NullString

+ Color sql.NullString

+ LastUpdate sql.NullInt64

+ PubKey []byte

+ Signature []byte

+ Version int16

+ type IsZombieChannelParams struct

+ Scid []byte

+ Version int16

+ type ListChannelsByNodeIDParams struct

+ NodeID1 int64

+ Version int16

+ type ListChannelsByNodeIDRow struct

+ GraphChannel GraphChannel

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type ListChannelsForNodeIDsParams struct

+ Node1Ids []int64

+ Node2Ids []int64

+ Version int16

+ type ListChannelsForNodeIDsRow struct

+ GraphChannel GraphChannel

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type ListChannelsPaginatedParams struct

+ ID int64

+ Limit int32

+ Version int16

+ type ListChannelsPaginatedRow struct

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ ID int64

+ Outpoint string

+ type ListChannelsWithPoliciesForCachePaginatedParams struct

+ ID int64

+ Limit int32

+ Version int16

+ type ListChannelsWithPoliciesForCachePaginatedRow struct

+ Capacity sql.NullInt64

+ ID int64

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1Timelock sql.NullInt32

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2Timelock sql.NullInt32

+ Scid []byte

+ type ListChannelsWithPoliciesPaginatedParams struct

+ ID int64

+ Limit int32

+ Version int16

+ type ListChannelsWithPoliciesPaginatedRow struct

+ GraphChannel GraphChannel

+ Node1Pubkey []byte

+ Node2Pubkey []byte

+ Policy1BaseFeeMsat sql.NullInt64

+ Policy1ChannelFlags sql.NullInt16

+ Policy1Disabled sql.NullBool

+ Policy1FeePpm sql.NullInt64

+ Policy1ID sql.NullInt64

+ Policy1InboundBaseFeeMsat sql.NullInt64

+ Policy1InboundFeeRateMilliMsat sql.NullInt64

+ Policy1LastUpdate sql.NullInt64

+ Policy1MaxHtlcMsat sql.NullInt64

+ Policy1MessageFlags sql.NullInt16

+ Policy1MinHtlcMsat sql.NullInt64

+ Policy1NodeID sql.NullInt64

+ Policy1Signature []byte

+ Policy1Timelock sql.NullInt32

+ Policy1Version sql.NullInt16

+ Policy2BaseFeeMsat sql.NullInt64

+ Policy2ChannelFlags sql.NullInt16

+ Policy2Disabled sql.NullBool

+ Policy2FeePpm sql.NullInt64

+ Policy2ID sql.NullInt64

+ Policy2InboundBaseFeeMsat sql.NullInt64

+ Policy2InboundFeeRateMilliMsat sql.NullInt64

+ Policy2LastUpdate sql.NullInt64

+ Policy2MaxHtlcMsat sql.NullInt64

+ Policy2MessageFlags sql.NullInt16

+ Policy2MinHtlcMsat sql.NullInt64

+ Policy2NodeID sql.NullInt64

+ Policy2Signature []byte

+ Policy2Timelock sql.NullInt32

+ Policy2Version sql.NullInt16

+ type ListNodeIDsAndPubKeysParams struct

+ ID int64

+ Limit int32

+ Version int16

+ type ListNodeIDsAndPubKeysRow struct

+ ID int64

+ PubKey []byte

+ type ListNodesPaginatedParams struct

+ ID int64

+ Limit int32

+ Version int16

type Querier

+ AddV1ChannelProof func(ctx context.Context, arg AddV1ChannelProofParams) (sql.Result, error)

+ CountZombieChannels func(ctx context.Context, version int16) (int64, error)

+ DeleteChannelPolicyExtraTypes func(ctx context.Context, channelPolicyID int64) error

+ DeleteChannels func(ctx context.Context, ids []int64) error

+ DeleteNode func(ctx context.Context, id int64) error

+ DeletePruneLogEntriesInRange func(ctx context.Context, arg DeletePruneLogEntriesInRangeParams) error

+ DeleteUnconnectedNodes func(ctx context.Context) ([][]byte, error)

+ DeleteZombieChannel func(ctx context.Context, arg DeleteZombieChannelParams) (sql.Result, error)

+ GetChannelAndNodesBySCID func(ctx context.Context, arg GetChannelAndNodesBySCIDParams) (GetChannelAndNodesBySCIDRow, error)

+ GetChannelByOutpointWithPolicies func(ctx context.Context, arg GetChannelByOutpointWithPoliciesParams) (GetChannelByOutpointWithPoliciesRow, error)

+ GetChannelBySCIDWithPolicies func(ctx context.Context, arg GetChannelBySCIDWithPoliciesParams) (GetChannelBySCIDWithPoliciesRow, error)

+ GetChannelExtrasBatch func(ctx context.Context, chanIds []int64) ([]GraphChannelExtraType, error)

+ GetChannelFeaturesBatch func(ctx context.Context, chanIds []int64) ([]GraphChannelFeature, error)

+ GetChannelPolicyByChannelAndNode func(ctx context.Context, arg GetChannelPolicyByChannelAndNodeParams) (GraphChannelPolicy, error)

+ GetChannelPolicyExtraTypesBatch func(ctx context.Context, policyIds []int64) ([]GetChannelPolicyExtraTypesBatchRow, error)

+ GetChannelsByIDs func(ctx context.Context, ids []int64) ([]GetChannelsByIDsRow, error)

+ GetChannelsByOutpoints func(ctx context.Context, outpoints []string) ([]GetChannelsByOutpointsRow, error)

+ GetChannelsByPolicyLastUpdateRange func(ctx context.Context, arg GetChannelsByPolicyLastUpdateRangeParams) ([]GetChannelsByPolicyLastUpdateRangeRow, error)

+ GetChannelsBySCIDRange func(ctx context.Context, arg GetChannelsBySCIDRangeParams) ([]GetChannelsBySCIDRangeRow, error)

+ GetChannelsBySCIDWithPolicies func(ctx context.Context, arg GetChannelsBySCIDWithPoliciesParams) ([]GetChannelsBySCIDWithPoliciesRow, error)

+ GetChannelsBySCIDs func(ctx context.Context, arg GetChannelsBySCIDsParams) ([]GraphChannel, error)

+ GetClosedChannelsSCIDs func(ctx context.Context, scids [][]byte) ([][]byte, error)

+ GetNodeAddresses func(ctx context.Context, nodeID int64) ([]GetNodeAddressesRow, error)

+ GetNodeAddressesBatch func(ctx context.Context, ids []int64) ([]GraphNodeAddress, error)

+ GetNodeExtraTypesBatch func(ctx context.Context, ids []int64) ([]GraphNodeExtraType, error)

+ GetNodeFeaturesBatch func(ctx context.Context, ids []int64) ([]GraphNodeFeature, error)

+ GetNodeIDByPubKey func(ctx context.Context, arg GetNodeIDByPubKeyParams) (int64, error)

+ GetNodesByIDs func(ctx context.Context, ids []int64) ([]GraphNode, error)

+ GetPruneEntriesForHeights func(ctx context.Context, heights []int64) ([]GraphPruneLog, error)

+ GetPruneHashByHeight func(ctx context.Context, blockHeight int64) ([]byte, error)

+ GetPruneTip func(ctx context.Context) (GraphPruneLog, error)

+ GetPublicV1ChannelsBySCID func(ctx context.Context, arg GetPublicV1ChannelsBySCIDParams) ([]GraphChannel, error)

+ GetSCIDByOutpoint func(ctx context.Context, arg GetSCIDByOutpointParams) ([]byte, error)

+ GetV1DisabledSCIDs func(ctx context.Context) ([][]byte, error)

+ GetZombieChannel func(ctx context.Context, arg GetZombieChannelParams) (GraphZombieChannel, error)

+ GetZombieChannelsSCIDs func(ctx context.Context, arg GetZombieChannelsSCIDsParams) ([]GraphZombieChannel, error)

+ InsertChannelMig func(ctx context.Context, arg InsertChannelMigParams) (int64, error)

+ InsertClosedChannel func(ctx context.Context, scid []byte) error

+ InsertEdgePolicyMig func(ctx context.Context, arg InsertEdgePolicyMigParams) (int64, error)

+ InsertNodeMig func(ctx context.Context, arg InsertNodeMigParams) (int64, error)

+ IsClosedChannel func(ctx context.Context, scid []byte) (bool, error)

+ IsPublicV1Node func(ctx context.Context, pubKey []byte) (bool, error)

+ IsZombieChannel func(ctx context.Context, arg IsZombieChannelParams) (bool, error)

+ ListChannelsByNodeID func(ctx context.Context, arg ListChannelsByNodeIDParams) ([]ListChannelsByNodeIDRow, error)

+ ListChannelsForNodeIDs func(ctx context.Context, arg ListChannelsForNodeIDsParams) ([]ListChannelsForNodeIDsRow, error)

+ ListChannelsPaginated func(ctx context.Context, arg ListChannelsPaginatedParams) ([]ListChannelsPaginatedRow, error)

+ ListChannelsWithPoliciesForCachePaginated func(ctx context.Context, arg ListChannelsWithPoliciesForCachePaginatedParams) ([]ListChannelsWithPoliciesForCachePaginatedRow, error)

+ ListChannelsWithPoliciesPaginated func(ctx context.Context, arg ListChannelsWithPoliciesPaginatedParams) ([]ListChannelsWithPoliciesPaginatedRow, error)

+ ListNodeIDsAndPubKeys func(ctx context.Context, arg ListNodeIDsAndPubKeysParams) ([]ListNodeIDsAndPubKeysRow, error)

+ ListNodesPaginated func(ctx context.Context, arg ListNodesPaginatedParams) ([]GraphNode, error)

+ UpsertChanPolicyExtraType func(ctx context.Context, arg UpsertChanPolicyExtraTypeParams) error

+ UpsertChannelExtraType func(ctx context.Context, arg UpsertChannelExtraTypeParams) error

+ UpsertEdgePolicy func(ctx context.Context, arg UpsertEdgePolicyParams) (int64, error)

+ UpsertNodeAddress func(ctx context.Context, arg UpsertNodeAddressParams) error

+ UpsertPruneLogEntry func(ctx context.Context, arg UpsertPruneLogEntryParams) error

+ UpsertZombieChannel func(ctx context.Context, arg UpsertZombieChannelParams) error

type Queries

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

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

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

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

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

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

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

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

+ func (q *Queries) GetChannelAndNodesBySCID(ctx context.Context, arg GetChannelAndNodesBySCIDParams) (GetChannelAndNodesBySCIDRow, error)

+ func (q *Queries) GetChannelByOutpointWithPolicies(ctx context.Context, arg GetChannelByOutpointWithPoliciesParams) (GetChannelByOutpointWithPoliciesRow, error)

+ func (q *Queries) GetChannelBySCIDWithPolicies(ctx context.Context, arg GetChannelBySCIDWithPoliciesParams) (GetChannelBySCIDWithPoliciesRow, error)

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

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

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

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

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

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

+ func (q *Queries) GetChannelsByPolicyLastUpdateRange(ctx context.Context, arg GetChannelsByPolicyLastUpdateRangeParams) ([]GetChannelsByPolicyLastUpdateRangeRow, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) ListChannelsWithPoliciesForCachePaginated(ctx context.Context, arg ListChannelsWithPoliciesForCachePaginatedParams) ([]ListChannelsWithPoliciesForCachePaginatedRow, error)

+ func (q *Queries) ListChannelsWithPoliciesPaginated(ctx context.Context, arg ListChannelsWithPoliciesPaginatedParams) ([]ListChannelsWithPoliciesPaginatedRow, error)

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

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

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

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

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

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

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

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

+ type UpsertChanPolicyExtraTypeParams struct

+ ChannelPolicyID int64

+ Type int64

+ Value []byte

+ type UpsertChannelExtraTypeParams struct

+ ChannelID int64

+ Type int64

+ Value []byte

+ type UpsertEdgePolicyParams struct

+ BaseFeeMsat int64

+ ChannelFlags sql.NullInt16

+ ChannelID int64

+ Disabled sql.NullBool

+ FeePpm int64

+ InboundBaseFeeMsat sql.NullInt64

+ InboundFeeRateMilliMsat sql.NullInt64

+ LastUpdate sql.NullInt64

+ MaxHtlcMsat sql.NullInt64

+ MessageFlags sql.NullInt16

+ MinHtlcMsat int64

+ NodeID int64

+ Signature []byte

+ Timelock int32

+ Version int16

+ type UpsertNodeAddressParams struct

+ Address string

+ NodeID int64

+ Position int32

+ Type int16

+ type UpsertPruneLogEntryParams struct

+ BlockHash []byte

+ BlockHeight int64

+ type UpsertZombieChannelParams struct

+ NodeKey1 []byte

+ NodeKey2 []byte

+ Scid []byte

+ Version int16

v1.0.10

Jun 10, 2025

Changes in this version

+ type Channel struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ Capacity sql.NullInt64

+ ID int64

+ Node1Signature []byte

+ Node2Signature []byte

+ NodeID1 int64

+ NodeID2 int64

+ Outpoint string

+ Scid []byte

+ Version int16

+ type ChannelExtraType struct

+ ChannelID int64

+ Type int64

+ Value []byte

+ type ChannelFeature struct

+ ChannelID int64

+ FeatureBit int32

+ type CreateChannelExtraTypeParams struct

+ ChannelID int64

+ Type int64

+ Value []byte

+ type CreateChannelParams struct

+ Bitcoin1Signature []byte

+ Bitcoin2Signature []byte

+ BitcoinKey1 []byte

+ BitcoinKey2 []byte

+ Capacity sql.NullInt64

+ Node1Signature []byte

+ Node2Signature []byte

+ NodeID1 int64

+ NodeID2 int64

+ Outpoint string

+ Scid []byte

+ Version int16

+ type DeleteExtraNodeTypeParams struct

+ NodeID int64

+ Type int64

+ type DeleteNodeByPubKeyParams struct

+ PubKey []byte

+ Version int16

+ type DeleteNodeFeatureParams struct

+ FeatureBit int32

+ NodeID int64

+ type GetChannelBySCIDParams struct

+ Scid []byte

+ Version int16

+ type GetNodeAddressesByPubKeyParams struct

+ PubKey []byte

+ Version int16

+ type GetNodeAddressesByPubKeyRow struct

+ Address sql.NullString

+ Type sql.NullInt16

+ type GetNodeByPubKeyParams struct

+ PubKey []byte

+ Version int16

+ type GetNodeFeaturesByPubKeyParams struct

+ PubKey []byte

+ Version int16

+ type GetNodesByLastUpdateRangeParams struct

+ EndTime sql.NullInt64

+ StartTime sql.NullInt64

+ type GetSourceNodesByVersionRow struct

+ NodeID int64

+ PubKey []byte

+ type InsertChannelFeatureParams struct

+ ChannelID int64

+ FeatureBit int32

+ type InsertNodeAddressParams struct

+ Address string

+ NodeID int64

+ Position int32

+ Type int16

+ type InsertNodeFeatureParams struct

+ FeatureBit int32

+ NodeID int64

+ type Node struct

+ Alias sql.NullString

+ Color sql.NullString

+ ID int64

+ LastUpdate sql.NullInt64

+ PubKey []byte

+ Signature []byte

+ Version int16

+ type NodeAddress struct

+ Address string

+ NodeID int64

+ Position int32

+ Type int16

+ type NodeExtraType struct

+ NodeID int64

+ Type int64

+ Value []byte

+ type NodeFeature struct

+ FeatureBit int32

+ NodeID int64

type Querier

+ AddSourceNode func(ctx context.Context, nodeID int64) error

+ CreateChannel func(ctx context.Context, arg CreateChannelParams) (int64, error)

+ CreateChannelExtraType func(ctx context.Context, arg CreateChannelExtraTypeParams) error

+ DeleteExtraNodeType func(ctx context.Context, arg DeleteExtraNodeTypeParams) error

+ DeleteNodeAddresses func(ctx context.Context, nodeID int64) error

+ DeleteNodeByPubKey func(ctx context.Context, arg DeleteNodeByPubKeyParams) (sql.Result, error)

+ DeleteNodeFeature func(ctx context.Context, arg DeleteNodeFeatureParams) error

+ GetChannelBySCID func(ctx context.Context, arg GetChannelBySCIDParams) (Channel, error)

+ GetExtraNodeTypes func(ctx context.Context, nodeID int64) ([]NodeExtraType, error)

+ GetNodeAddressesByPubKey func(ctx context.Context, arg GetNodeAddressesByPubKeyParams) ([]GetNodeAddressesByPubKeyRow, error)

+ GetNodeByPubKey func(ctx context.Context, arg GetNodeByPubKeyParams) (Node, error)

+ GetNodeFeatures func(ctx context.Context, nodeID int64) ([]NodeFeature, error)

+ GetNodeFeaturesByPubKey func(ctx context.Context, arg GetNodeFeaturesByPubKeyParams) ([]int32, error)

+ GetNodesByLastUpdateRange func(ctx context.Context, arg GetNodesByLastUpdateRangeParams) ([]Node, error)

+ GetSourceNodesByVersion func(ctx context.Context, version int16) ([]GetSourceNodesByVersionRow, error)

+ HighestSCID func(ctx context.Context, version int16) ([]byte, error)

+ InsertChannelFeature func(ctx context.Context, arg InsertChannelFeatureParams) error

+ InsertNodeAddress func(ctx context.Context, arg InsertNodeAddressParams) error

+ InsertNodeFeature func(ctx context.Context, arg InsertNodeFeatureParams) error

+ UpsertNode func(ctx context.Context, arg UpsertNodeParams) (int64, error)

+ UpsertNodeExtraType func(ctx context.Context, arg UpsertNodeExtraTypeParams) error

type Queries

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

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

+ func (q *Queries) CreateChannelExtraType(ctx context.Context, arg CreateChannelExtraTypeParams) error

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

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

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

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

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

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

+ func (q *Queries) GetNodeAddressesByPubKey(ctx context.Context, arg GetNodeAddressesByPubKeyParams) ([]GetNodeAddressesByPubKeyRow, error)

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

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

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

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

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

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

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

+ func (q *Queries) InsertNodeAddress(ctx context.Context, arg InsertNodeAddressParams) error

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

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

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

+ type SourceNode struct

+ NodeID int64

+ type UpsertNodeExtraTypeParams struct

+ NodeID int64

+ Type int64

+ Value []byte

+ type UpsertNodeParams struct

+ Alias sql.NullString

+ Color sql.NullString

+ LastUpdate sql.NullInt64

+ PubKey []byte

+ Signature []byte

+ Version int16

v1.0.9

Apr 5, 2025

v1.0.8

Mar 28, 2025

v1.0.7

Jan 31, 2025

Changes in this version

+ type InsertAMPSubInvoiceParams struct

+ CreatedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type InsertKVInvoiceKeyAndAddIndexParams struct

+ AddIndex int64

+ ID int64

+ type InsertMigratedInvoiceParams struct

+ AmountMsat int64

+ AmountPaidMsat int64

+ CltvDelta sql.NullInt32

+ CreatedAt time.Time

+ Expiry int32

+ Hash []byte

+ IsAmp bool

+ IsHodl bool

+ IsKeysend bool

+ Memo sql.NullString

+ PaymentAddr []byte

+ PaymentRequest sql.NullString

+ PaymentRequestHash []byte

+ Preimage []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type InvoicePaymentHash struct

+ AddIndex int64

+ Hash []byte

+ ID int64

+ type MigrationTracker struct

+ MigrationTime time.Time

+ Version int32

type Querier

+ ClearKVInvoiceHashIndex func(ctx context.Context) error

+ GetDatabaseVersion func(ctx context.Context) (int32, error)

+ GetInvoiceByHash func(ctx context.Context, hash []byte) (Invoice, error)

+ GetKVInvoicePaymentHashByAddIndex func(ctx context.Context, addIndex int64) ([]byte, error)

+ GetMigration func(ctx context.Context, version int32) (time.Time, error)

+ InsertAMPSubInvoice func(ctx context.Context, arg InsertAMPSubInvoiceParams) error

+ InsertKVInvoiceKeyAndAddIndex func(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error

+ InsertMigratedInvoice func(ctx context.Context, arg InsertMigratedInvoiceParams) (int64, error)

+ SetKVInvoicePaymentHash func(ctx context.Context, arg SetKVInvoicePaymentHashParams) error

+ SetMigration func(ctx context.Context, arg SetMigrationParams) error

type Queries

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

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

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

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

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

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

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

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

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

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

+ type SetKVInvoicePaymentHashParams struct

+ Hash []byte

+ ID int64

+ type SetMigrationParams struct

+ MigrationTime time.Time

+ Version int32

v1.0.6

Dec 19, 2024

v1.0.5

Oct 28, 2024

v1.0.4

Sep 3, 2024

Changes in this version

type Querier

+ GetInvoiceBySetID func(ctx context.Context, setID []byte) ([]Invoice, error)

type Queries

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

type UpdateAMPSubInvoiceHTLCPreimageParams

+ ChanID string

v1.0.3

Jul 9, 2024

v1.0.2

Apr 26, 2024

v1.0.1

Apr 11, 2024

v1.0.0

Apr 10, 2024

Changes in this version

+ type AmpSubInvoice struct

+ CreatedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type AmpSubInvoiceHtlc struct

+ ChildIndex int64

+ Hash []byte

+ HtlcID int64

+ InvoiceID int64

+ Preimage []byte

+ RootShare []byte

+ SetID []byte

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type DeleteInvoiceParams struct

+ AddIndex sql.NullInt64

+ Hash []byte

+ PaymentAddr []byte

+ SettleIndex sql.NullInt64

+ type FetchAMPSubInvoiceHTLCsParams struct

+ InvoiceID int64

+ SetID []byte

+ type FetchAMPSubInvoiceHTLCsRow struct

+ AcceptHeight int32

+ AcceptTime time.Time

+ AmountMsat int64

+ ChanID string

+ ChildIndex int64

+ ExpiryHeight int32

+ Hash []byte

+ HtlcID int64

+ ID int64

+ InvoiceID int64

+ Preimage []byte

+ ResolveTime sql.NullTime

+ RootShare []byte

+ SetID []byte

+ State int16

+ TotalMppMsat sql.NullInt64

+ type FetchAMPSubInvoicesParams struct

+ InvoiceID int64

+ SetID []byte

+ type FetchSettledAMPSubInvoicesParams struct

+ SettleIndexGet sql.NullInt64

+ SettleIndexLet sql.NullInt64

+ type FetchSettledAMPSubInvoicesRow struct

+ AmountMsat int64

+ AmountPaidMsat int64

+ AmpSettleIndex sql.NullInt64

+ AmpSettledAt sql.NullTime

+ CltvDelta sql.NullInt32

+ CreatedAt time.Time

+ Expiry int32

+ Hash []byte

+ ID int64

+ IsAmp bool

+ IsHodl bool

+ IsKeysend bool

+ Memo sql.NullString

+ PaymentAddr []byte

+ PaymentRequest sql.NullString

+ PaymentRequestHash []byte

+ Preimage []byte

+ SetID []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type FilterInvoicesParams struct

+ AddIndexGet sql.NullInt64

+ AddIndexLet sql.NullInt64

+ CreatedAfter sql.NullTime

+ CreatedBefore sql.NullTime

+ NumLimit int32

+ NumOffset int32

+ PendingOnly interface{}

+ Reverse interface{}

+ SettleIndexGet sql.NullInt64

+ SettleIndexLet sql.NullInt64

+ State sql.NullInt16

+ type GetInvoiceHTLCCustomRecordsRow struct

+ HtlcID int64

+ Key int64

+ Value []byte

+ type GetInvoiceParams struct

+ AddIndex sql.NullInt64

+ Hash []byte

+ PaymentAddr []byte

+ Preimage []byte

+ SetID []byte

+ type InsertAMPSubInvoiceHTLCParams struct

+ ChildIndex int64

+ Hash []byte

+ HtlcID int64

+ InvoiceID int64

+ Preimage []byte

+ RootShare []byte

+ SetID []byte

+ type InsertInvoiceFeatureParams struct

+ Feature int32

+ InvoiceID int64

+ type InsertInvoiceHTLCCustomRecordParams struct

+ HtlcID int64

+ Key int64

+ Value []byte

+ type InsertInvoiceHTLCParams struct

+ AcceptHeight int32

+ AcceptTime time.Time

+ AmountMsat int64

+ ChanID string

+ ExpiryHeight int32

+ HtlcID int64

+ InvoiceID int64

+ ResolveTime sql.NullTime

+ State int16

+ TotalMppMsat sql.NullInt64

+ type InsertInvoiceParams struct

+ AmountMsat int64

+ AmountPaidMsat int64

+ CltvDelta sql.NullInt32

+ CreatedAt time.Time

+ Expiry int32

+ Hash []byte

+ IsAmp bool

+ IsHodl bool

+ IsKeysend bool

+ Memo sql.NullString

+ PaymentAddr []byte

+ PaymentRequest sql.NullString

+ PaymentRequestHash []byte

+ Preimage []byte

+ State int16

+ type Invoice struct

+ AmountMsat int64

+ AmountPaidMsat int64

+ CltvDelta sql.NullInt32

+ CreatedAt time.Time

+ Expiry int32

+ Hash []byte

+ ID int64

+ IsAmp bool

+ IsHodl bool

+ IsKeysend bool

+ Memo sql.NullString

+ PaymentAddr []byte

+ PaymentRequest sql.NullString

+ PaymentRequestHash []byte

+ Preimage []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type InvoiceEvent struct

+ AddedAt time.Time

+ EventType int32

+ ID int64

+ InvoiceID int64

+ SetID []byte

+ type InvoiceEventType struct

+ Description string

+ ID int32

+ type InvoiceFeature struct

+ Feature int32

+ InvoiceID int64

+ type InvoiceHtlc struct

+ AcceptHeight int32

+ AcceptTime time.Time

+ AmountMsat int64

+ ChanID string

+ ExpiryHeight int32

+ HtlcID int64

+ ID int64

+ InvoiceID int64

+ ResolveTime sql.NullTime

+ State int16

+ TotalMppMsat sql.NullInt64

+ type InvoiceHtlcCustomRecord struct

+ HtlcID int64

+ Key int64

+ Value []byte

+ type InvoiceSequence struct

+ CurrentValue int64

+ Name string

+ type OnAMPSubInvoiceCanceledParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ type OnAMPSubInvoiceCreatedParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ type OnAMPSubInvoiceSettledParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ type OnInvoiceCanceledParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ type OnInvoiceCreatedParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ type OnInvoiceSettledParams struct

+ AddedAt time.Time

+ InvoiceID int64

+ type Querier interface

+ DeleteCanceledInvoices func(ctx context.Context) (sql.Result, error)

+ DeleteInvoice func(ctx context.Context, arg DeleteInvoiceParams) (sql.Result, error)

+ FetchAMPSubInvoiceHTLCs func(ctx context.Context, arg FetchAMPSubInvoiceHTLCsParams) ([]FetchAMPSubInvoiceHTLCsRow, error)

+ FetchAMPSubInvoices func(ctx context.Context, arg FetchAMPSubInvoicesParams) ([]AmpSubInvoice, error)

+ FetchSettledAMPSubInvoices func(ctx context.Context, arg FetchSettledAMPSubInvoicesParams) ([]FetchSettledAMPSubInvoicesRow, error)

+ FilterInvoices func(ctx context.Context, arg FilterInvoicesParams) ([]Invoice, error)

+ GetAMPInvoiceID func(ctx context.Context, setID []byte) (int64, error)

+ GetInvoice func(ctx context.Context, arg GetInvoiceParams) ([]Invoice, error)

+ GetInvoiceFeatures func(ctx context.Context, invoiceID int64) ([]InvoiceFeature, error)

+ GetInvoiceHTLCCustomRecords func(ctx context.Context, invoiceID int64) ([]GetInvoiceHTLCCustomRecordsRow, error)

+ GetInvoiceHTLCs func(ctx context.Context, invoiceID int64) ([]InvoiceHtlc, error)

+ InsertAMPSubInvoiceHTLC func(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) error

+ InsertInvoice func(ctx context.Context, arg InsertInvoiceParams) (int64, error)

+ InsertInvoiceFeature func(ctx context.Context, arg InsertInvoiceFeatureParams) error

+ InsertInvoiceHTLC func(ctx context.Context, arg InsertInvoiceHTLCParams) (int64, error)

+ InsertInvoiceHTLCCustomRecord func(ctx context.Context, arg InsertInvoiceHTLCCustomRecordParams) error

+ NextInvoiceSettleIndex func(ctx context.Context) (int64, error)

+ OnAMPSubInvoiceCanceled func(ctx context.Context, arg OnAMPSubInvoiceCanceledParams) error

+ OnAMPSubInvoiceCreated func(ctx context.Context, arg OnAMPSubInvoiceCreatedParams) error

+ OnAMPSubInvoiceSettled func(ctx context.Context, arg OnAMPSubInvoiceSettledParams) error

+ OnInvoiceCanceled func(ctx context.Context, arg OnInvoiceCanceledParams) error

+ OnInvoiceCreated func(ctx context.Context, arg OnInvoiceCreatedParams) error

+ OnInvoiceSettled func(ctx context.Context, arg OnInvoiceSettledParams) error

+ UpdateAMPSubInvoiceHTLCPreimage func(ctx context.Context, arg UpdateAMPSubInvoiceHTLCPreimageParams) (sql.Result, error)

+ UpdateAMPSubInvoiceState func(ctx context.Context, arg UpdateAMPSubInvoiceStateParams) error

+ UpdateInvoiceAmountPaid func(ctx context.Context, arg UpdateInvoiceAmountPaidParams) (sql.Result, error)

+ UpdateInvoiceHTLC func(ctx context.Context, arg UpdateInvoiceHTLCParams) error

+ UpdateInvoiceHTLCs func(ctx context.Context, arg UpdateInvoiceHTLCsParams) error

+ UpdateInvoiceState func(ctx context.Context, arg UpdateInvoiceStateParams) (sql.Result, error)

+ UpsertAMPSubInvoice func(ctx context.Context, arg UpsertAMPSubInvoiceParams) (sql.Result, error)

+ type Queries struct

+ func New(db DBTX) *Queries

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UpdateAMPSubInvoiceHTLCPreimageParams struct

+ HtlcID int64

+ InvoiceID int64

+ Preimage []byte

+ SetID []byte

+ type UpdateAMPSubInvoiceStateParams struct

+ SetID []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type UpdateInvoiceAmountPaidParams struct

+ AmountPaidMsat int64

+ ID int64

+ type UpdateInvoiceHTLCParams struct

+ ChanID string

+ HtlcID int64

+ InvoiceID int64

+ ResolveTime sql.NullTime

+ State int16

+ type UpdateInvoiceHTLCsParams struct

+ InvoiceID int64

+ ResolveTime sql.NullTime

+ State int16

+ type UpdateInvoiceStateParams struct

+ ID int64

+ Preimage []byte

+ SettleIndex sql.NullInt64

+ SettledAt sql.NullTime

+ State int16

+ type UpsertAMPSubInvoiceParams struct

+ CreatedAt time.Time

+ InvoiceID int64

+ SetID []byte

+ State int16

Other modules containing this package

github.com/lightningnetwork/lnd

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