Documentation
¶
Index ¶
- type AddV1ChannelProofParams
- type AmpSubInvoice
- type AmpSubInvoiceHtlc
- type ChannelAndNodeIDs
- type ChannelAndNodes
- type CreateChannelParams
- type DBTX
- type DeleteExtraNodeTypeParams
- type DeleteInvoiceParams
- type DeleteNodeByPubKeyParams
- type DeleteNodeFeatureParams
- type DeletePruneLogEntriesInRangeParams
- type DeleteZombieChannelParams
- type FetchAMPSubInvoiceHTLCsParams
- type FetchAMPSubInvoiceHTLCsRow
- type FetchAMPSubInvoicesParams
- type FetchSettledAMPSubInvoicesParams
- type FetchSettledAMPSubInvoicesRow
- type FilterInvoicesParams
- 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 GetInvoiceHTLCCustomRecordsRow
- type GetInvoiceParams
- 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 InsertAMPSubInvoiceHTLCParams
- type InsertAMPSubInvoiceParams
- type InsertChannelFeatureParams
- type InsertChannelMigParams
- type InsertEdgePolicyMigParams
- type InsertInvoiceFeatureParams
- type InsertInvoiceHTLCCustomRecordParams
- type InsertInvoiceHTLCParams
- type InsertInvoiceParams
- type InsertKVInvoiceKeyAndAddIndexParams
- type InsertMigratedInvoiceParams
- type InsertNodeFeatureParams
- type InsertNodeMigParams
- type Invoice
- type InvoiceEvent
- type InvoiceEventType
- type InvoiceFeature
- type InvoiceHtlc
- type InvoiceHtlcCustomRecord
- type InvoicePaymentHash
- type InvoiceSequence
- 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 MigrationTracker
- type OnAMPSubInvoiceCanceledParams
- type OnAMPSubInvoiceCreatedParams
- type OnAMPSubInvoiceSettledParams
- type OnInvoiceCanceledParams
- type OnInvoiceCreatedParams
- type OnInvoiceSettledParams
- type Querier
- 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) ClearKVInvoiceHashIndex(ctx context.Context) 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) DeleteCanceledInvoices(ctx context.Context) (sql.Result, 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) DeleteInvoice(ctx context.Context, arg DeleteInvoiceParams) (sql.Result, 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) 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) 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) GetDatabaseVersion(ctx context.Context) (int32, error)
- func (q *Queries) GetExtraNodeTypes(ctx context.Context, nodeID int64) ([]GraphNodeExtraType, error)
- func (q *Queries) GetInvoice(ctx context.Context, arg GetInvoiceParams) ([]Invoice, error)
- func (q *Queries) GetInvoiceByHash(ctx context.Context, hash []byte) (Invoice, error)
- func (q *Queries) GetInvoiceBySetID(ctx context.Context, setID []byte) ([]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) GetKVInvoicePaymentHashByAddIndex(ctx context.Context, addIndex int64) ([]byte, error)
- func (q *Queries) GetMigration(ctx context.Context, version int32) (time.Time, 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) GetTx() DBTX
- 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) InsertAMPSubInvoice(ctx context.Context, arg InsertAMPSubInvoiceParams) error
- func (q *Queries) InsertAMPSubInvoiceHTLC(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) 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) 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) InsertKVInvoiceKeyAndAddIndex(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error
- func (q *Queries) InsertMigratedInvoice(ctx context.Context, arg InsertMigratedInvoiceParams) (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) 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) SetKVInvoicePaymentHash(ctx context.Context, arg SetKVInvoicePaymentHashParams) error
- func (q *Queries) SetMigration(ctx context.Context, arg SetMigrationParams) 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) 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) UpsertSourceNode(ctx context.Context, arg UpsertSourceNodeParams) (int64, error)
- func (q *Queries) UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type SetKVInvoicePaymentHashParams
- type SetMigrationParams
- type UpdateAMPSubInvoiceHTLCPreimageParams
- type UpdateAMPSubInvoiceStateParams
- type UpdateInvoiceAmountPaidParams
- type UpdateInvoiceHTLCParams
- type UpdateInvoiceHTLCsParams
- type UpdateInvoiceStateParams
- type UpsertAMPSubInvoiceParams
- type UpsertChanPolicyExtraTypeParams
- type UpsertChannelExtraTypeParams
- type UpsertEdgePolicyParams
- type UpsertNodeAddressParams
- type UpsertNodeExtraTypeParams
- type UpsertNodeParams
- type UpsertPruneLogEntryParams
- type UpsertSourceNodeParams
- type UpsertZombieChannelParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddV1ChannelProofParams ¶
type AmpSubInvoice ¶
type AmpSubInvoiceHtlc ¶
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 DeleteInvoiceParams ¶
type DeleteNodeFeatureParams ¶
type FetchSettledAMPSubInvoicesRow ¶
type FetchSettledAMPSubInvoicesRow struct {
SetID []byte
AmpSettleIndex sql.NullInt64
AmpSettledAt sql.NullTime
ID int64
Hash []byte
Preimage []byte
SettleIndex sql.NullInt64
SettledAt sql.NullTime
Memo sql.NullString
AmountMsat int64
CltvDelta sql.NullInt32
Expiry int32
PaymentAddr []byte
PaymentRequest sql.NullString
PaymentRequestHash []byte
State int16
AmountPaidMsat int64
IsAmp bool
IsHodl bool
IsKeysend bool
CreatedAt time.Time
}
type FilterInvoicesParams ¶
type 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 GetInvoiceParams ¶
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 InsertInvoiceHTLCParams ¶
type InsertInvoiceParams ¶
type InsertInvoiceParams struct {
Hash []byte
Preimage []byte
Memo sql.NullString
AmountMsat int64
CltvDelta sql.NullInt32
Expiry int32
PaymentAddr []byte
PaymentRequest sql.NullString
PaymentRequestHash []byte
State int16
AmountPaidMsat int64
IsAmp bool
IsHodl bool
IsKeysend bool
CreatedAt time.Time
}
type InsertMigratedInvoiceParams ¶
type InsertMigratedInvoiceParams struct {
Hash []byte
Preimage []byte
SettleIndex sql.NullInt64
SettledAt sql.NullTime
Memo sql.NullString
AmountMsat int64
CltvDelta sql.NullInt32
Expiry int32
PaymentAddr []byte
PaymentRequest sql.NullString
PaymentRequestHash []byte
State int16
AmountPaidMsat int64
IsAmp bool
IsHodl bool
IsKeysend bool
CreatedAt time.Time
}
type InsertNodeFeatureParams ¶
type InsertNodeMigParams ¶
type InsertNodeMigParams struct {
Version int16
PubKey []byte
Alias sql.NullString
LastUpdate sql.NullInt64
Color sql.NullString
Signature []byte
}
type Invoice ¶
type Invoice struct {
ID int64
Hash []byte
Preimage []byte
SettleIndex sql.NullInt64
SettledAt sql.NullTime
Memo sql.NullString
AmountMsat int64
CltvDelta sql.NullInt32
Expiry int32
PaymentAddr []byte
PaymentRequest sql.NullString
PaymentRequestHash []byte
State int16
AmountPaidMsat int64
IsAmp bool
IsHodl bool
IsKeysend bool
CreatedAt time.Time
}
type InvoiceEvent ¶
type InvoiceEventType ¶
type InvoiceFeature ¶
type InvoiceHtlc ¶
type InvoiceHtlcCustomRecord ¶
type InvoicePaymentHash ¶
type InvoiceSequence ¶
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 MigrationTracker ¶
type OnInvoiceCanceledParams ¶
type OnInvoiceCreatedParams ¶
type OnInvoiceSettledParams ¶
type Querier ¶
type Querier interface {
AddSourceNode(ctx context.Context, nodeID int64) error
AddV1ChannelProof(ctx context.Context, arg AddV1ChannelProofParams) (sql.Result, error)
ClearKVInvoiceHashIndex(ctx context.Context) error
CountZombieChannels(ctx context.Context, version int16) (int64, error)
CreateChannel(ctx context.Context, arg CreateChannelParams) (int64, error)
DeleteCanceledInvoices(ctx context.Context) (sql.Result, error)
DeleteChannelPolicyExtraTypes(ctx context.Context, channelPolicyID int64) error
DeleteChannels(ctx context.Context, ids []int64) error
DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error
DeleteInvoice(ctx context.Context, arg DeleteInvoiceParams) (sql.Result, error)
DeleteNode(ctx context.Context, id int64) error
DeleteNodeAddresses(ctx context.Context, nodeID int64) error
DeleteNodeByPubKey(ctx context.Context, arg DeleteNodeByPubKeyParams) (sql.Result, error)
DeleteNodeFeature(ctx context.Context, arg DeleteNodeFeatureParams) error
DeletePruneLogEntriesInRange(ctx context.Context, arg DeletePruneLogEntriesInRangeParams) error
DeleteUnconnectedNodes(ctx context.Context) ([][]byte, error)
DeleteZombieChannel(ctx context.Context, arg DeleteZombieChannelParams) (sql.Result, error)
FetchAMPSubInvoiceHTLCs(ctx context.Context, arg FetchAMPSubInvoiceHTLCsParams) ([]FetchAMPSubInvoiceHTLCsRow, error)
FetchAMPSubInvoices(ctx context.Context, arg FetchAMPSubInvoicesParams) ([]AmpSubInvoice, error)
FetchSettledAMPSubInvoices(ctx context.Context, arg FetchSettledAMPSubInvoicesParams) ([]FetchSettledAMPSubInvoicesRow, error)
FilterInvoices(ctx context.Context, arg FilterInvoicesParams) ([]Invoice, error)
GetAMPInvoiceID(ctx context.Context, setID []byte) (int64, error)
GetChannelAndNodesBySCID(ctx context.Context, arg GetChannelAndNodesBySCIDParams) (GetChannelAndNodesBySCIDRow, error)
GetChannelByOutpointWithPolicies(ctx context.Context, arg GetChannelByOutpointWithPoliciesParams) (GetChannelByOutpointWithPoliciesRow, error)
GetChannelBySCID(ctx context.Context, arg GetChannelBySCIDParams) (GraphChannel, error)
GetChannelBySCIDWithPolicies(ctx context.Context, arg GetChannelBySCIDWithPoliciesParams) (GetChannelBySCIDWithPoliciesRow, error)
GetChannelExtrasBatch(ctx context.Context, chanIds []int64) ([]GraphChannelExtraType, error)
GetChannelFeaturesBatch(ctx context.Context, chanIds []int64) ([]GraphChannelFeature, error)
GetChannelPolicyByChannelAndNode(ctx context.Context, arg GetChannelPolicyByChannelAndNodeParams) (GraphChannelPolicy, error)
GetChannelPolicyExtraTypesBatch(ctx context.Context, policyIds []int64) ([]GetChannelPolicyExtraTypesBatchRow, error)
GetChannelsByIDs(ctx context.Context, ids []int64) ([]GetChannelsByIDsRow, error)
GetChannelsByOutpoints(ctx context.Context, outpoints []string) ([]GetChannelsByOutpointsRow, error)
GetChannelsByPolicyLastUpdateRange(ctx context.Context, arg GetChannelsByPolicyLastUpdateRangeParams) ([]GetChannelsByPolicyLastUpdateRangeRow, error)
GetChannelsBySCIDRange(ctx context.Context, arg GetChannelsBySCIDRangeParams) ([]GetChannelsBySCIDRangeRow, error)
GetChannelsBySCIDWithPolicies(ctx context.Context, arg GetChannelsBySCIDWithPoliciesParams) ([]GetChannelsBySCIDWithPoliciesRow, error)
GetChannelsBySCIDs(ctx context.Context, arg GetChannelsBySCIDsParams) ([]GraphChannel, error)
GetClosedChannelsSCIDs(ctx context.Context, scids [][]byte) ([][]byte, error)
GetDatabaseVersion(ctx context.Context) (int32, error)
GetExtraNodeTypes(ctx context.Context, nodeID int64) ([]GraphNodeExtraType, error)
// This method may return more than one invoice if filter using multiple fields
// from different invoices. It is the caller's responsibility to ensure that
// we bubble up an error in those cases.
GetInvoice(ctx context.Context, arg GetInvoiceParams) ([]Invoice, error)
GetInvoiceByHash(ctx context.Context, hash []byte) (Invoice, error)
GetInvoiceBySetID(ctx context.Context, setID []byte) ([]Invoice, error)
GetInvoiceFeatures(ctx context.Context, invoiceID int64) ([]InvoiceFeature, error)
GetInvoiceHTLCCustomRecords(ctx context.Context, invoiceID int64) ([]GetInvoiceHTLCCustomRecordsRow, error)
GetInvoiceHTLCs(ctx context.Context, invoiceID int64) ([]InvoiceHtlc, error)
GetKVInvoicePaymentHashByAddIndex(ctx context.Context, addIndex int64) ([]byte, error)
GetMigration(ctx context.Context, version int32) (time.Time, error)
GetNodeAddresses(ctx context.Context, nodeID int64) ([]GetNodeAddressesRow, error)
GetNodeAddressesBatch(ctx context.Context, ids []int64) ([]GraphNodeAddress, error)
GetNodeByPubKey(ctx context.Context, arg GetNodeByPubKeyParams) (GraphNode, error)
GetNodeExtraTypesBatch(ctx context.Context, ids []int64) ([]GraphNodeExtraType, error)
GetNodeFeatures(ctx context.Context, nodeID int64) ([]GraphNodeFeature, error)
GetNodeFeaturesBatch(ctx context.Context, ids []int64) ([]GraphNodeFeature, error)
GetNodeFeaturesByPubKey(ctx context.Context, arg GetNodeFeaturesByPubKeyParams) ([]int32, error)
GetNodeIDByPubKey(ctx context.Context, arg GetNodeIDByPubKeyParams) (int64, error)
GetNodesByIDs(ctx context.Context, ids []int64) ([]GraphNode, error)
GetNodesByLastUpdateRange(ctx context.Context, arg GetNodesByLastUpdateRangeParams) ([]GraphNode, error)
GetPruneEntriesForHeights(ctx context.Context, heights []int64) ([]GraphPruneLog, error)
GetPruneHashByHeight(ctx context.Context, blockHeight int64) ([]byte, error)
GetPruneTip(ctx context.Context) (GraphPruneLog, error)
GetPublicV1ChannelsBySCID(ctx context.Context, arg GetPublicV1ChannelsBySCIDParams) ([]GraphChannel, error)
GetSCIDByOutpoint(ctx context.Context, arg GetSCIDByOutpointParams) ([]byte, error)
GetSourceNodesByVersion(ctx context.Context, version int16) ([]GetSourceNodesByVersionRow, error)
// NOTE: this is V1 specific since for V1, disabled is a
// simple, single boolean. The proposed V2 policy
// structure will have a more complex disabled bit vector
// and so the query for V2 may differ.
GetV1DisabledSCIDs(ctx context.Context) ([][]byte, error)
GetZombieChannel(ctx context.Context, arg GetZombieChannelParams) (GraphZombieChannel, error)
GetZombieChannelsSCIDs(ctx context.Context, arg GetZombieChannelsSCIDsParams) ([]GraphZombieChannel, error)
HighestSCID(ctx context.Context, version int16) ([]byte, error)
InsertAMPSubInvoice(ctx context.Context, arg InsertAMPSubInvoiceParams) error
InsertAMPSubInvoiceHTLC(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) error
InsertChannelFeature(ctx context.Context, arg InsertChannelFeatureParams) error
// NOTE: This query is only meant to be used by the graph SQL migration since
// for that migration, in order to be retry-safe, we don't want to error out if
// we re-insert the same channel again (which would error if the normal
// CreateChannel query is used because of the uniqueness constraint on the scid
// and version columns).
InsertChannelMig(ctx context.Context, arg InsertChannelMigParams) (int64, error)
InsertClosedChannel(ctx context.Context, scid []byte) error
// NOTE: This query is only meant to be used by the graph SQL migration since
// for that migration, in order to be retry-safe, we don't want to error out if
// we re-insert the same policy (which would error if the normal
// UpsertEdgePolicy query is used because of the constraint in that query that
// requires a policy update to have a newer last_update than the existing one).
InsertEdgePolicyMig(ctx context.Context, arg InsertEdgePolicyMigParams) (int64, error)
InsertInvoice(ctx context.Context, arg InsertInvoiceParams) (int64, error)
InsertInvoiceFeature(ctx context.Context, arg InsertInvoiceFeatureParams) error
InsertInvoiceHTLC(ctx context.Context, arg InsertInvoiceHTLCParams) (int64, error)
InsertInvoiceHTLCCustomRecord(ctx context.Context, arg InsertInvoiceHTLCCustomRecordParams) error
InsertKVInvoiceKeyAndAddIndex(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error
InsertMigratedInvoice(ctx context.Context, arg InsertMigratedInvoiceParams) (int64, error)
InsertNodeFeature(ctx context.Context, arg InsertNodeFeatureParams) error
// NOTE: This query is only meant to be used by the graph SQL migration since
// for that migration, in order to be retry-safe, we don't want to error out if
// we re-insert the same node (which would error if the normal UpsertNode query
// is used because of the constraint in that query that requires a node update
// to have a newer last_update than the existing node).
InsertNodeMig(ctx context.Context, arg InsertNodeMigParams) (int64, error)
IsClosedChannel(ctx context.Context, scid []byte) (bool, error)
IsPublicV1Node(ctx context.Context, pubKey []byte) (bool, error)
IsZombieChannel(ctx context.Context, arg IsZombieChannelParams) (bool, error)
ListChannelsByNodeID(ctx context.Context, arg ListChannelsByNodeIDParams) ([]ListChannelsByNodeIDRow, error)
ListChannelsForNodeIDs(ctx context.Context, arg ListChannelsForNodeIDsParams) ([]ListChannelsForNodeIDsRow, error)
ListChannelsPaginated(ctx context.Context, arg ListChannelsPaginatedParams) ([]ListChannelsPaginatedRow, error)
ListChannelsWithPoliciesForCachePaginated(ctx context.Context, arg ListChannelsWithPoliciesForCachePaginatedParams) ([]ListChannelsWithPoliciesForCachePaginatedRow, error)
ListChannelsWithPoliciesPaginated(ctx context.Context, arg ListChannelsWithPoliciesPaginatedParams) ([]ListChannelsWithPoliciesPaginatedRow, error)
ListNodeIDsAndPubKeys(ctx context.Context, arg ListNodeIDsAndPubKeysParams) ([]ListNodeIDsAndPubKeysRow, error)
ListNodesPaginated(ctx context.Context, arg ListNodesPaginatedParams) ([]GraphNode, error)
NextInvoiceSettleIndex(ctx context.Context) (int64, error)
OnAMPSubInvoiceCanceled(ctx context.Context, arg OnAMPSubInvoiceCanceledParams) error
OnAMPSubInvoiceCreated(ctx context.Context, arg OnAMPSubInvoiceCreatedParams) error
OnAMPSubInvoiceSettled(ctx context.Context, arg OnAMPSubInvoiceSettledParams) error
OnInvoiceCanceled(ctx context.Context, arg OnInvoiceCanceledParams) error
OnInvoiceCreated(ctx context.Context, arg OnInvoiceCreatedParams) error
OnInvoiceSettled(ctx context.Context, arg OnInvoiceSettledParams) error
SetKVInvoicePaymentHash(ctx context.Context, arg SetKVInvoicePaymentHashParams) error
SetMigration(ctx context.Context, arg SetMigrationParams) error
UpdateAMPSubInvoiceHTLCPreimage(ctx context.Context, arg UpdateAMPSubInvoiceHTLCPreimageParams) (sql.Result, error)
UpdateAMPSubInvoiceState(ctx context.Context, arg UpdateAMPSubInvoiceStateParams) error
UpdateInvoiceAmountPaid(ctx context.Context, arg UpdateInvoiceAmountPaidParams) (sql.Result, error)
UpdateInvoiceHTLC(ctx context.Context, arg UpdateInvoiceHTLCParams) error
UpdateInvoiceHTLCs(ctx context.Context, arg UpdateInvoiceHTLCsParams) error
UpdateInvoiceState(ctx context.Context, arg UpdateInvoiceStateParams) (sql.Result, error)
UpsertAMPSubInvoice(ctx context.Context, arg UpsertAMPSubInvoiceParams) (sql.Result, error)
UpsertChanPolicyExtraType(ctx context.Context, arg UpsertChanPolicyExtraTypeParams) error
UpsertChannelExtraType(ctx context.Context, arg UpsertChannelExtraTypeParams) error
UpsertEdgePolicy(ctx context.Context, arg UpsertEdgePolicyParams) (int64, error)
UpsertNode(ctx context.Context, arg UpsertNodeParams) (int64, error)
UpsertNodeAddress(ctx context.Context, arg UpsertNodeAddressParams) error
UpsertNodeExtraType(ctx context.Context, arg UpsertNodeExtraTypeParams) error
UpsertPruneLogEntry(ctx context.Context, arg UpsertPruneLogEntryParams) error
// We use a separate upsert for our own node since we want to be less strict
// about the last_update field. For our own node, we always want to
// update the record even if the last_update is the same as what we have.
UpsertSourceNode(ctx context.Context, arg UpsertSourceNodeParams) (int64, error)
UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AddSourceNode ¶
func (*Queries) AddV1ChannelProof ¶
func (*Queries) ClearKVInvoiceHashIndex ¶
func (*Queries) CountZombieChannels ¶
func (*Queries) CreateChannel ¶
func (*Queries) DeleteCanceledInvoices ¶
func (*Queries) DeleteChannelPolicyExtraTypes ¶
func (*Queries) DeleteChannels ¶
func (*Queries) DeleteExtraNodeType ¶
func (q *Queries) DeleteExtraNodeType(ctx context.Context, arg DeleteExtraNodeTypeParams) error
func (*Queries) DeleteInvoice ¶
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) FetchAMPSubInvoiceHTLCs ¶
func (q *Queries) FetchAMPSubInvoiceHTLCs(ctx context.Context, arg FetchAMPSubInvoiceHTLCsParams) ([]FetchAMPSubInvoiceHTLCsRow, error)
func (*Queries) FetchAMPSubInvoices ¶
func (q *Queries) FetchAMPSubInvoices(ctx context.Context, arg FetchAMPSubInvoicesParams) ([]AmpSubInvoice, error)
func (*Queries) FetchSettledAMPSubInvoices ¶
func (q *Queries) FetchSettledAMPSubInvoices(ctx context.Context, arg FetchSettledAMPSubInvoicesParams) ([]FetchSettledAMPSubInvoicesRow, error)
func (*Queries) FilterInvoices ¶
func (*Queries) GetAMPInvoiceID ¶
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) GetDatabaseVersion ¶
func (*Queries) GetExtraNodeTypes ¶
func (*Queries) GetInvoice ¶
This method may return more than one invoice if filter using multiple fields from different invoices. It is the caller's responsibility to ensure that we bubble up an error in those cases.
func (*Queries) GetInvoiceByHash ¶
func (*Queries) GetInvoiceBySetID ¶
func (*Queries) GetInvoiceFeatures ¶
func (*Queries) GetInvoiceHTLCCustomRecords ¶
func (*Queries) GetInvoiceHTLCs ¶
func (*Queries) GetKVInvoicePaymentHashByAddIndex ¶
func (*Queries) GetMigration ¶
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) GetTx ¶
GetTx returns the underlying DBTX (either *sql.DB or *sql.Tx) used by the Queries struct.
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) InsertAMPSubInvoice ¶
func (q *Queries) InsertAMPSubInvoice(ctx context.Context, arg InsertAMPSubInvoiceParams) error
func (*Queries) InsertAMPSubInvoiceHTLC ¶
func (q *Queries) InsertAMPSubInvoiceHTLC(ctx context.Context, arg InsertAMPSubInvoiceHTLCParams) error
func (*Queries) InsertChannelFeature ¶
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) InsertInvoice ¶
func (*Queries) InsertInvoiceFeature ¶
func (q *Queries) InsertInvoiceFeature(ctx context.Context, arg InsertInvoiceFeatureParams) error
func (*Queries) InsertInvoiceHTLC ¶
func (*Queries) InsertInvoiceHTLCCustomRecord ¶
func (q *Queries) InsertInvoiceHTLCCustomRecord(ctx context.Context, arg InsertInvoiceHTLCCustomRecordParams) error
func (*Queries) InsertKVInvoiceKeyAndAddIndex ¶
func (q *Queries) InsertKVInvoiceKeyAndAddIndex(ctx context.Context, arg InsertKVInvoiceKeyAndAddIndexParams) error
func (*Queries) InsertMigratedInvoice ¶
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) NextInvoiceSettleIndex ¶
func (*Queries) OnAMPSubInvoiceCanceled ¶
func (q *Queries) OnAMPSubInvoiceCanceled(ctx context.Context, arg OnAMPSubInvoiceCanceledParams) error
func (*Queries) OnAMPSubInvoiceCreated ¶
func (q *Queries) OnAMPSubInvoiceCreated(ctx context.Context, arg OnAMPSubInvoiceCreatedParams) error
func (*Queries) OnAMPSubInvoiceSettled ¶
func (q *Queries) OnAMPSubInvoiceSettled(ctx context.Context, arg OnAMPSubInvoiceSettledParams) error
func (*Queries) OnInvoiceCanceled ¶
func (q *Queries) OnInvoiceCanceled(ctx context.Context, arg OnInvoiceCanceledParams) error
func (*Queries) OnInvoiceCreated ¶
func (q *Queries) OnInvoiceCreated(ctx context.Context, arg OnInvoiceCreatedParams) error
func (*Queries) OnInvoiceSettled ¶
func (q *Queries) OnInvoiceSettled(ctx context.Context, arg OnInvoiceSettledParams) error
func (*Queries) SetKVInvoicePaymentHash ¶
func (q *Queries) SetKVInvoicePaymentHash(ctx context.Context, arg SetKVInvoicePaymentHashParams) error
func (*Queries) SetMigration ¶
func (q *Queries) SetMigration(ctx context.Context, arg SetMigrationParams) error
func (*Queries) UpdateAMPSubInvoiceHTLCPreimage ¶
func (*Queries) UpdateAMPSubInvoiceState ¶
func (q *Queries) UpdateAMPSubInvoiceState(ctx context.Context, arg UpdateAMPSubInvoiceStateParams) error
func (*Queries) UpdateInvoiceAmountPaid ¶
func (*Queries) UpdateInvoiceHTLC ¶
func (q *Queries) UpdateInvoiceHTLC(ctx context.Context, arg UpdateInvoiceHTLCParams) error
func (*Queries) UpdateInvoiceHTLCs ¶
func (q *Queries) UpdateInvoiceHTLCs(ctx context.Context, arg UpdateInvoiceHTLCsParams) error
func (*Queries) UpdateInvoiceState ¶
func (*Queries) UpsertAMPSubInvoice ¶
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) UpsertSourceNode ¶
We use a separate upsert for our own node since we want to be less strict about the last_update field. For our own node, we always want to update the record even if the last_update is the same as what we have.
func (*Queries) UpsertZombieChannel ¶
func (q *Queries) UpsertZombieChannel(ctx context.Context, arg UpsertZombieChannelParams) error
type SetMigrationParams ¶
type UpdateInvoiceHTLCParams ¶
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
}
type UpsertSourceNodeParams ¶
type UpsertSourceNodeParams struct {
Version int16
PubKey []byte
Alias sql.NullString
LastUpdate sql.NullInt64
Color sql.NullString
Signature []byte
}