sqlc

package
v0.1.18-beta Latest Latest
Warning

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

Go to latest
Published: Jan 16, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddV1ChannelProofParams

type AddV1ChannelProofParams struct {
	Scid                []byte
	Node1Signature      []byte
	Node2Signature      []byte
	Flokicoin1Signature []byte
	Flokicoin2Signature []byte
}

type ChannelAndNodeIDs

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

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

type CreateChannelParams struct {
	Version             int16
	Scid                []byte
	NodeID1             int64
	NodeID2             int64
	Outpoint            string
	Capacity            sql.NullInt64
	FlokicoinKey1       []byte
	FlokicoinKey2       []byte
	Node1Signature      []byte
	Node2Signature      []byte
	Flokicoin1Signature []byte
	Flokicoin2Signature []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

type DeleteExtraNodeTypeParams struct {
	NodeID int64
	Type   int64
}

type DeleteNodeByPubKeyParams

type DeleteNodeByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type DeleteNodeFeatureParams

type DeleteNodeFeatureParams struct {
	NodeID     int64
	FeatureBit int32
}

type DeletePruneLogEntriesInRangeParams

type DeletePruneLogEntriesInRangeParams struct {
	StartHeight int64
	EndHeight   int64
}

type DeleteZombieChannelParams

type DeleteZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type GetChannelAndNodesBySCIDParams

type GetChannelAndNodesBySCIDParams struct {
	Scid    []byte
	Version int16
}

type GetChannelAndNodesBySCIDRow

type GetChannelAndNodesBySCIDRow struct {
	ID                  int64
	Version             int16
	Scid                []byte
	NodeID1             int64
	NodeID2             int64
	Outpoint            string
	Capacity            sql.NullInt64
	FlokicoinKey1       []byte
	FlokicoinKey2       []byte
	Node1Signature      []byte
	Node2Signature      []byte
	Flokicoin1Signature []byte
	Flokicoin2Signature []byte
	Node1PubKey         []byte
	Node2PubKey         []byte
}

type GetChannelByOutpointWithPoliciesParams

type GetChannelByOutpointWithPoliciesParams struct {
	Outpoint string
	Version  int16
}

type GetChannelByOutpointWithPoliciesRow

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

type GetChannelBySCIDParams struct {
	Scid    []byte
	Version int16
}

type GetChannelBySCIDWithPoliciesParams

type GetChannelBySCIDWithPoliciesParams struct {
	Scid    []byte
	Version int16
}

type GetChannelBySCIDWithPoliciesRow

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

type GetChannelPolicyByChannelAndNodeParams struct {
	ChannelID int64
	NodeID    int64
	Version   int16
}

type GetChannelPolicyExtraTypesBatchRow

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

type GetChannelsByIDsRow

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

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

func (GetChannelsByOutpointsRow) Channel

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsByOutpointsRow) Node1Pub

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

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

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

type GetChannelsByPolicyLastUpdateRangeRow

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

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsByPolicyLastUpdateRangeRow) Node1

Node1 returns the first GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsByPolicyLastUpdateRangeRow) Node2

Node2 returns the second GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

type GetChannelsBySCIDRangeParams

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

type GetChannelsBySCIDRangeRow

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

func (GetChannelsBySCIDRangeRow) Channel

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDRangeRow) Node1Pub

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

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

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

type GetChannelsBySCIDWithPoliciesRow

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

Channel returns the GraphChannel associated with this interface.

NOTE: This method is part of the ChannelAndNodeIDs interface.

func (GetChannelsBySCIDWithPoliciesRow) Node1

Node1 returns the first GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsBySCIDWithPoliciesRow) Node1Pub

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

Node2 returns the second GraphNode associated with this channel.

NOTE: This method is part of the ChannelAndNodes interface.

func (GetChannelsBySCIDWithPoliciesRow) Node2Pub

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

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

type GetNodeAddressesRow

type GetNodeAddressesRow struct {
	Type    int16
	Address string
}

type GetNodeByPubKeyParams

type GetNodeByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodeFeaturesByPubKeyParams

type GetNodeFeaturesByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodeIDByPubKeyParams

type GetNodeIDByPubKeyParams struct {
	PubKey  []byte
	Version int16
}

type GetNodesByLastUpdateRangeParams

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

type GetPublicV1ChannelsBySCIDParams

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

type GetSCIDByOutpointParams

type GetSCIDByOutpointParams struct {
	Outpoint string
	Version  int16
}

type GetSourceNodesByVersionRow

type GetSourceNodesByVersionRow struct {
	NodeID int64
	PubKey []byte
}

type GetZombieChannelParams

type GetZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type GetZombieChannelsSCIDsParams

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

type GraphChannel

type GraphChannel struct {
	ID                  int64
	Version             int16
	Scid                []byte
	NodeID1             int64
	NodeID2             int64
	Outpoint            string
	Capacity            sql.NullInt64
	FlokicoinKey1       []byte
	FlokicoinKey2       []byte
	Node1Signature      []byte
	Node2Signature      []byte
	Flokicoin1Signature []byte
	Flokicoin2Signature []byte
}

type GraphChannelExtraType

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

type GraphChannelFeature

type GraphChannelFeature struct {
	ChannelID  int64
	FeatureBit int32
}

type GraphChannelPolicy

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

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

type GraphClosedScid

type GraphClosedScid struct {
	Scid []byte
}

type GraphNode

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

type GraphNodeAddress

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

type GraphNodeExtraType

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

type GraphNodeFeature

type GraphNodeFeature struct {
	NodeID     int64
	FeatureBit int32
}

type GraphPruneLog

type GraphPruneLog struct {
	BlockHeight int64
	BlockHash   []byte
}

type GraphSourceNode

type GraphSourceNode struct {
	NodeID int64
}

type GraphZombieChannel

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

type InsertChannelFeatureParams

type InsertChannelFeatureParams struct {
	ChannelID  int64
	FeatureBit int32
}

type InsertChannelMigParams

type InsertChannelMigParams struct {
	Version             int16
	Scid                []byte
	NodeID1             int64
	NodeID2             int64
	Outpoint            string
	Capacity            sql.NullInt64
	FlokicoinKey1       []byte
	FlokicoinKey2       []byte
	Node1Signature      []byte
	Node2Signature      []byte
	Flokicoin1Signature []byte
	Flokicoin2Signature []byte
}

type InsertEdgePolicyMigParams

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 InsertNodeFeatureParams

type InsertNodeFeatureParams struct {
	NodeID     int64
	FeatureBit int32
}

type InsertNodeMigParams

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

type IsZombieChannelParams

type IsZombieChannelParams struct {
	Scid    []byte
	Version int16
}

type ListChannelsByNodeIDParams

type ListChannelsByNodeIDParams struct {
	Version int16
	NodeID1 int64
}

type ListChannelsByNodeIDRow

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

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

type ListChannelsForNodeIDsRow

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

type ListChannelsPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsPaginatedRow

type ListChannelsPaginatedRow struct {
	ID            int64
	FlokicoinKey1 []byte
	FlokicoinKey2 []byte
	Outpoint      string
}

type ListChannelsWithPoliciesForCachePaginatedParams

type ListChannelsWithPoliciesForCachePaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsWithPoliciesForCachePaginatedRow

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

type ListChannelsWithPoliciesPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListChannelsWithPoliciesPaginatedRow

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

type ListNodeIDsAndPubKeysParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type ListNodeIDsAndPubKeysRow

type ListNodeIDsAndPubKeysRow struct {
	ID     int64
	PubKey []byte
}

type ListNodesPaginatedParams

type ListNodesPaginatedParams struct {
	Version int16
	ID      int64
	Limit   int32
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) AddSourceNode

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

func (*Queries) AddV1ChannelProof

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

func (*Queries) CountZombieChannels

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

func (*Queries) CreateChannel

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

func (*Queries) DeleteChannelPolicyExtraTypes

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

func (*Queries) DeleteChannels

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

func (*Queries) DeleteExtraNodeType

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

func (*Queries) DeleteNode

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

func (*Queries) DeleteNodeAddresses

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

func (*Queries) DeleteNodeByPubKey

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

func (*Queries) DeleteNodeFeature

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

func (*Queries) DeletePruneLogEntriesInRange

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

func (*Queries) DeleteUnconnectedNodes

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

func (*Queries) DeleteZombieChannel

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

func (*Queries) GetChannelAndNodesBySCID

func (*Queries) GetChannelBySCID

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

func (*Queries) GetChannelExtrasBatch

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

func (*Queries) GetChannelFeaturesBatch

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

func (*Queries) GetChannelPolicyByChannelAndNode

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

func (*Queries) GetChannelPolicyExtraTypesBatch

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

func (*Queries) GetChannelsByIDs

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

func (*Queries) GetChannelsByOutpoints

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

func (*Queries) GetChannelsBySCIDRange

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

func (*Queries) GetChannelsBySCIDs

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

func (*Queries) GetClosedChannelsSCIDs

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

func (*Queries) GetExtraNodeTypes

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

func (*Queries) GetNodeAddresses

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

func (*Queries) GetNodeAddressesBatch

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

func (*Queries) GetNodeByPubKey

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

func (*Queries) GetNodeExtraTypesBatch

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

func (*Queries) GetNodeFeatures

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

func (*Queries) GetNodeFeaturesBatch

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

func (*Queries) GetNodeFeaturesByPubKey

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

func (*Queries) GetNodeIDByPubKey

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

func (*Queries) GetNodesByIDs

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

func (*Queries) GetNodesByLastUpdateRange

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

func (*Queries) GetPruneEntriesForHeights

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

func (*Queries) GetPruneHashByHeight

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

func (*Queries) GetPruneTip

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

func (*Queries) GetPublicV1ChannelsBySCID

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

func (*Queries) GetSCIDByOutpoint

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

func (*Queries) GetSourceNodesByVersion

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

func (*Queries) GetV1DisabledSCIDs

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

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

func (*Queries) GetZombieChannelsSCIDs

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

func (*Queries) HighestSCID

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

func (*Queries) InsertChannelFeature

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

func (*Queries) InsertChannelMig

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

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

func (*Queries) InsertEdgePolicyMig

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) InsertNodeFeature

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

func (*Queries) InsertNodeMig

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

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

func (*Queries) IsPublicV1Node

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

func (*Queries) IsZombieChannel

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

func (*Queries) ListChannelsByNodeID

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

func (*Queries) ListChannelsForNodeIDs

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

func (*Queries) ListChannelsPaginated

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

func (*Queries) ListNodeIDsAndPubKeys

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

func (*Queries) ListNodesPaginated

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

func (*Queries) UpsertChanPolicyExtraType

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

func (*Queries) UpsertChannelExtraType

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

func (*Queries) UpsertEdgePolicy

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

func (*Queries) UpsertNode

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

func (*Queries) UpsertNodeAddress

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

func (*Queries) UpsertNodeExtraType

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

func (*Queries) UpsertPruneLogEntry

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

func (*Queries) UpsertZombieChannel

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

func (*Queries) WithTx

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

type UpsertChanPolicyExtraTypeParams

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

type UpsertChannelExtraTypeParams

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

type UpsertEdgePolicyParams

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

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

type UpsertNodeExtraTypeParams

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

type UpsertNodeParams

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

type UpsertPruneLogEntryParams

type UpsertPruneLogEntryParams struct {
	BlockHeight int64
	BlockHash   []byte
}

type UpsertZombieChannelParams

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