Documentation
¶
Index ¶
- type AddV1ChannelProofParams
- type ChannelAndNodeIDs
- type ChannelAndNodes
- type CreateChannelParams
- type DBTX
- type DeleteExtraNodeTypeParams
- type DeleteNodeByPubKeyParams
- type DeleteNodeFeatureParams
- type DeletePruneLogEntriesInRangeParams
- type DeleteZombieChannelParams
- type GetChannelAndNodesBySCIDParams
- type GetChannelAndNodesBySCIDRow
- type GetChannelByOutpointWithPoliciesParams
- type GetChannelByOutpointWithPoliciesRow
- type GetChannelBySCIDParams
- type GetChannelBySCIDWithPoliciesParams
- type GetChannelBySCIDWithPoliciesRow
- type GetChannelPolicyByChannelAndNodeParams
- type GetChannelPolicyExtraTypesBatchRow
- type GetChannelsByIDsRow
- type GetChannelsByOutpointsRow
- type GetChannelsByPolicyLastUpdateRangeParams
- type GetChannelsByPolicyLastUpdateRangeRow
- type GetChannelsBySCIDRangeParams
- type GetChannelsBySCIDRangeRow
- type GetChannelsBySCIDWithPoliciesParams
- type GetChannelsBySCIDWithPoliciesRow
- 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
- type GetNodeAddressesRow
- type GetNodeByPubKeyParams
- type GetNodeFeaturesByPubKeyParams
- type GetNodeIDByPubKeyParams
- type GetNodesByLastUpdateRangeParams
- type GetPublicV1ChannelsBySCIDParams
- type GetSCIDByOutpointParams
- type GetSourceNodesByVersionRow
- type GetZombieChannelParams
- type GetZombieChannelsSCIDsParams
- type GraphChannel
- type GraphChannelExtraType
- type GraphChannelFeature
- type GraphChannelPolicy
- type GraphChannelPolicyExtraType
- type GraphClosedScid
- type GraphNode
- type GraphNodeAddress
- type GraphNodeExtraType
- type GraphNodeFeature
- type GraphPruneLog
- type GraphSourceNode
- type GraphZombieChannel
- type InsertChannelFeatureParams
- type InsertChannelMigParams
- type InsertEdgePolicyMigParams
- type InsertNodeFeatureParams
- type InsertNodeMigParams
- type IsZombieChannelParams
- type ListChannelsByNodeIDParams
- type ListChannelsByNodeIDRow
- type ListChannelsForNodeIDsParams
- type ListChannelsForNodeIDsRow
- type ListChannelsPaginatedParams
- type ListChannelsPaginatedRow
- type ListChannelsWithPoliciesForCachePaginatedParams
- type ListChannelsWithPoliciesForCachePaginatedRow
- type ListChannelsWithPoliciesPaginatedParams
- type ListChannelsWithPoliciesPaginatedRow
- type ListNodeIDsAndPubKeysParams
- type ListNodeIDsAndPubKeysRow
- type ListNodesPaginatedParams
- type Queries
- func (q *Queries) AddSourceNode(ctx context.Context, nodeID int64) error
- 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) CreateChannel(ctx context.Context, arg CreateChannelParams) (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) DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error
- func (q *Queries) DeleteNode(ctx context.Context, id int64) 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) 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) GetChannelBySCID(ctx context.Context, arg GetChannelBySCIDParams) (GraphChannel, 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) GetExtraNodeTypes(ctx context.Context, nodeID int64) ([]GraphNodeExtraType, 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) GetNodeByPubKey(ctx context.Context, arg GetNodeByPubKeyParams) (GraphNode, error)
- func (q *Queries) GetNodeExtraTypesBatch(ctx context.Context, ids []int64) ([]GraphNodeExtraType, error)
- func (q *Queries) GetNodeFeatures(ctx context.Context, nodeID int64) ([]GraphNodeFeature, error)
- func (q *Queries) GetNodeFeaturesBatch(ctx context.Context, ids []int64) ([]GraphNodeFeature, error)
- func (q *Queries) GetNodeFeaturesByPubKey(ctx context.Context, arg GetNodeFeaturesByPubKeyParams) ([]int32, 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) GetNodesByLastUpdateRange(ctx context.Context, arg GetNodesByLastUpdateRangeParams) ([]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) GetSourceNodesByVersion(ctx context.Context, version int16) ([]GetSourceNodesByVersionRow, 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) HighestSCID(ctx context.Context, version int16) ([]byte, error)
- func (q *Queries) InsertChannelFeature(ctx context.Context, arg InsertChannelFeatureParams) 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) InsertNodeFeature(ctx context.Context, arg InsertNodeFeatureParams) 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) UpsertNode(ctx context.Context, arg UpsertNodeParams) (int64, error)
- func (q *Queries) UpsertNodeAddress(ctx context.Context, arg UpsertNodeAddressParams) error
- func (q *Queries) UpsertNodeExtraType(ctx context.Context, arg UpsertNodeExtraTypeParams) error
- func (q *Queries) UpsertPruneLogEntry(ctx context.Context, arg UpsertPruneLogEntryParams) error
- func (q *Queries) UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type UpsertChanPolicyExtraTypeParams
- type UpsertChannelExtraTypeParams
- type UpsertEdgePolicyParams
- type UpsertNodeAddressParams
- type UpsertNodeExtraTypeParams
- type UpsertNodeParams
- type UpsertPruneLogEntryParams
- type UpsertZombieChannelParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddV1ChannelProofParams ¶
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 DeleteNodeFeatureParams ¶
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 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 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 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 ¶
func (r GetChannelsByOutpointsRow) Channel() GraphChannel
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 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 ¶
func (r GetChannelsByPolicyLastUpdateRangeRow) Channel() GraphChannel
Channel returns the GraphChannel associated with this interface.
NOTE: This method is part of the ChannelAndNodes interface.
func (GetChannelsByPolicyLastUpdateRangeRow) Node1 ¶
func (r GetChannelsByPolicyLastUpdateRangeRow) Node1() GraphNode
Node1 returns the first GraphNode associated with this channel.
NOTE: This method is part of the ChannelAndNodes interface.
func (GetChannelsByPolicyLastUpdateRangeRow) Node2 ¶
func (r GetChannelsByPolicyLastUpdateRangeRow) Node2() GraphNode
Node2 returns the second GraphNode associated with this channel.
NOTE: This method is part of the ChannelAndNodes interface.
type GetChannelsBySCIDRangeRow ¶
type GetChannelsBySCIDRangeRow struct {
GraphChannel GraphChannel
Node1PubKey []byte
Node2PubKey []byte
}
func (GetChannelsBySCIDRangeRow) Channel ¶
func (r GetChannelsBySCIDRangeRow) Channel() GraphChannel
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 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 ¶
func (r GetChannelsBySCIDWithPoliciesRow) Channel() GraphChannel
Channel returns the GraphChannel associated with this interface.
NOTE: This method is part of the ChannelAndNodeIDs interface.
func (GetChannelsBySCIDWithPoliciesRow) Node1 ¶
func (r GetChannelsBySCIDWithPoliciesRow) Node1() GraphNode
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 ¶
func (r GetChannelsBySCIDWithPoliciesRow) Node2() GraphNode
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 GetNodeAddressesRow ¶
type GetNodeByPubKeyParams ¶
type GetNodeIDByPubKeyParams ¶
type GetSCIDByOutpointParams ¶
type GetZombieChannelParams ¶
type GraphChannel ¶
type GraphChannelExtraType ¶
type GraphChannelFeature ¶
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 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 GraphNodeExtraType ¶
type GraphNodeFeature ¶
type GraphPruneLog ¶
type GraphSourceNode ¶
type GraphSourceNode struct {
NodeID int64
}
type GraphZombieChannel ¶
type InsertChannelMigParams ¶
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 InsertNodeMigParams ¶
type InsertNodeMigParams struct {
Version int16
PubKey []byte
Alias sql.NullString
LastUpdate sql.NullInt64
Color sql.NullString
Signature []byte
}
type IsZombieChannelParams ¶
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 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 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 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 Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AddSourceNode ¶
func (*Queries) AddV1ChannelProof ¶
func (*Queries) CountZombieChannels ¶
func (*Queries) CreateChannel ¶
func (*Queries) DeleteChannelPolicyExtraTypes ¶
func (*Queries) DeleteChannels ¶
func (*Queries) DeleteExtraNodeType ¶
func (q *Queries) DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error
func (*Queries) DeleteNodeAddresses ¶
func (*Queries) DeleteNodeByPubKey ¶
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 (*Queries) DeleteZombieChannel ¶
func (*Queries) GetChannelAndNodesBySCID ¶
func (q *Queries) GetChannelAndNodesBySCID(ctx context.Context, arg GetChannelAndNodesBySCIDParams) (GetChannelAndNodesBySCIDRow, error)
func (*Queries) GetChannelByOutpointWithPolicies ¶
func (q *Queries) GetChannelByOutpointWithPolicies(ctx context.Context, arg GetChannelByOutpointWithPoliciesParams) (GetChannelByOutpointWithPoliciesRow, error)
func (*Queries) GetChannelBySCID ¶
func (q *Queries) GetChannelBySCID(ctx context.Context, arg GetChannelBySCIDParams) (GraphChannel, error)
func (*Queries) GetChannelBySCIDWithPolicies ¶
func (q *Queries) GetChannelBySCIDWithPolicies(ctx context.Context, arg GetChannelBySCIDWithPoliciesParams) (GetChannelBySCIDWithPoliciesRow, error)
func (*Queries) GetChannelExtrasBatch ¶
func (*Queries) GetChannelFeaturesBatch ¶
func (*Queries) GetChannelPolicyByChannelAndNode ¶
func (q *Queries) GetChannelPolicyByChannelAndNode(ctx context.Context, arg GetChannelPolicyByChannelAndNodeParams) (GraphChannelPolicy, error)
func (*Queries) GetChannelPolicyExtraTypesBatch ¶
func (*Queries) GetChannelsByIDs ¶
func (*Queries) GetChannelsByOutpoints ¶
func (*Queries) GetChannelsByPolicyLastUpdateRange ¶
func (q *Queries) GetChannelsByPolicyLastUpdateRange(ctx context.Context, arg GetChannelsByPolicyLastUpdateRangeParams) ([]GetChannelsByPolicyLastUpdateRangeRow, error)
func (*Queries) GetChannelsBySCIDRange ¶
func (q *Queries) GetChannelsBySCIDRange(ctx context.Context, arg GetChannelsBySCIDRangeParams) ([]GetChannelsBySCIDRangeRow, error)
func (*Queries) GetChannelsBySCIDWithPolicies ¶
func (q *Queries) GetChannelsBySCIDWithPolicies(ctx context.Context, arg GetChannelsBySCIDWithPoliciesParams) ([]GetChannelsBySCIDWithPoliciesRow, error)
func (*Queries) GetChannelsBySCIDs ¶
func (q *Queries) GetChannelsBySCIDs(ctx context.Context, arg GetChannelsBySCIDsParams) ([]GraphChannel, error)
func (*Queries) GetClosedChannelsSCIDs ¶
func (*Queries) GetExtraNodeTypes ¶
func (*Queries) GetNodeAddresses ¶
func (*Queries) GetNodeAddressesBatch ¶
func (*Queries) GetNodeByPubKey ¶
func (*Queries) GetNodeExtraTypesBatch ¶
func (*Queries) GetNodeFeatures ¶
func (*Queries) GetNodeFeaturesBatch ¶
func (*Queries) GetNodeFeaturesByPubKey ¶
func (*Queries) GetNodeIDByPubKey ¶
func (*Queries) GetNodesByIDs ¶
func (*Queries) GetNodesByLastUpdateRange ¶
func (*Queries) GetPruneEntriesForHeights ¶
func (*Queries) GetPruneHashByHeight ¶
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 (*Queries) GetSourceNodesByVersion ¶
func (*Queries) GetV1DisabledSCIDs ¶
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 (*Queries) InsertChannelFeature ¶
func (q *Queries) InsertChannelFeature(ctx context.Context, arg InsertChannelFeatureParams) error
func (*Queries) InsertChannelMig ¶
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 (*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 ¶
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 (*Queries) IsPublicV1Node ¶
func (*Queries) IsZombieChannel ¶
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) ListChannelsWithPoliciesForCachePaginated ¶
func (q *Queries) ListChannelsWithPoliciesForCachePaginated(ctx context.Context, arg ListChannelsWithPoliciesForCachePaginatedParams) ([]ListChannelsWithPoliciesForCachePaginatedRow, error)
func (*Queries) ListChannelsWithPoliciesPaginated ¶
func (q *Queries) ListChannelsWithPoliciesPaginated(ctx context.Context, arg ListChannelsWithPoliciesPaginatedParams) ([]ListChannelsWithPoliciesPaginatedRow, error)
func (*Queries) ListNodeIDsAndPubKeys ¶
func (q *Queries) ListNodeIDsAndPubKeys(ctx context.Context, arg ListNodeIDsAndPubKeysParams) ([]ListNodeIDsAndPubKeysRow, error)
func (*Queries) ListNodesPaginated ¶
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 (*Queries) UpsertNode ¶
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
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 UpsertNodeParams ¶
type UpsertNodeParams struct {
Version int16
PubKey []byte
Alias sql.NullString
LastUpdate sql.NullInt64
Color sql.NullString
Signature []byte
}