sqlc

package
v0.29.0-beta.rc2 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateDepositParams 

type CreateDepositParams struct {
	DepositID             []byte
	TxHash                []byte
	OutIndex              int32
	Amount                int64
	ConfirmationHeight    int64
	TimeoutSweepPkScript  []byte
	ExpirySweepTxid       []byte
	FinalizedWithdrawalTx sql.NullString
}

type CreateReservationParams 

type CreateReservationParams struct {
	ReservationID    []byte
	ClientPubkey     []byte
	ServerPubkey     []byte
	Expiry           int32
	Value            int64
	ClientKeyFamily  int32
	ClientKeyIndex   int32
	InitiationHeight int32
}

type CreateStaticAddressParams 

type CreateStaticAddressParams struct {
	ClientPubkey     []byte
	ServerPubkey     []byte
	Expiry           int32
	ClientKeyFamily  int32
	ClientKeyIndex   int32
	Pkscript         []byte
	ProtocolVersion  int32
	InitiationHeight int32
}

type DBTX 

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

type Deposit 

type Deposit struct {
	ID                    int32
	DepositID             []byte
	TxHash                []byte
	OutIndex              int32
	Amount                int64
	ConfirmationHeight    int64
	TimeoutSweepPkScript  []byte
	ExpirySweepTxid       []byte
	FinalizedWithdrawalTx sql.NullString
}

type DepositUpdate 

type DepositUpdate struct {
	ID              int32
	DepositID       []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type GetInstantOutSwapRow 

type GetInstantOutSwapRow struct {
	ID                        int32
	SwapHash                  []byte
	Preimage                  []byte
	InitiationTime            time.Time
	AmountRequested           int64
	CltvExpiry                int32
	MaxMinerFee               int64
	MaxSwapFee                int64
	InitiationHeight          int32
	ProtocolVersion           int32
	Label                     string
	SwapHash_2                []byte
	Preimage_2                []byte
	SweepAddress              string
	OutgoingChanSet           string
	HtlcFeeRate               int64
	ReservationIds            []byte
	SwapInvoice               string
	FinalizedHtlcTx           []byte
	SweepTxHash               []byte
	FinalizedSweeplessSweepTx []byte
	SweepConfirmationHeight   sql.NullInt32
	SwapHash_3                []byte
	SenderScriptPubkey        []byte
	ReceiverScriptPubkey      []byte
	SenderInternalPubkey      []byte
	ReceiverInternalPubkey    []byte
	ClientKeyFamily           int32
	ClientKeyIndex            int32
}

type GetInstantOutSwapsRow 

type GetInstantOutSwapsRow struct {
	ID                        int32
	SwapHash                  []byte
	Preimage                  []byte
	InitiationTime            time.Time
	AmountRequested           int64
	CltvExpiry                int32
	MaxMinerFee               int64
	MaxSwapFee                int64
	InitiationHeight          int32
	ProtocolVersion           int32
	Label                     string
	SwapHash_2                []byte
	Preimage_2                []byte
	SweepAddress              string
	OutgoingChanSet           string
	HtlcFeeRate               int64
	ReservationIds            []byte
	SwapInvoice               string
	FinalizedHtlcTx           []byte
	SweepTxHash               []byte
	FinalizedSweeplessSweepTx []byte
	SweepConfirmationHeight   sql.NullInt32
	SwapHash_3                []byte
	SenderScriptPubkey        []byte
	ReceiverScriptPubkey      []byte
	SenderInternalPubkey      []byte
	ReceiverInternalPubkey    []byte
	ClientKeyFamily           int32
	ClientKeyIndex            int32
}

type GetLoopInSwapRow 

type GetLoopInSwapRow struct {
	ID                     int32
	SwapHash               []byte
	Preimage               []byte
	InitiationTime         time.Time
	AmountRequested        int64
	CltvExpiry             int32
	MaxMinerFee            int64
	MaxSwapFee             int64
	InitiationHeight       int32
	ProtocolVersion        int32
	Label                  string
	SwapHash_2             []byte
	HtlcConfTarget         int32
	LastHop                []byte
	ExternalHtlc           bool
	SwapHash_3             []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type GetLoopInSwapsRow 

type GetLoopInSwapsRow struct {
	ID                     int32
	SwapHash               []byte
	Preimage               []byte
	InitiationTime         time.Time
	AmountRequested        int64
	CltvExpiry             int32
	MaxMinerFee            int64
	MaxSwapFee             int64
	InitiationHeight       int32
	ProtocolVersion        int32
	Label                  string
	SwapHash_2             []byte
	HtlcConfTarget         int32
	LastHop                []byte
	ExternalHtlc           bool
	SwapHash_3             []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type GetLoopOutSwapRow 

type GetLoopOutSwapRow struct {
	ID                     int32
	SwapHash               []byte
	Preimage               []byte
	InitiationTime         time.Time
	AmountRequested        int64
	CltvExpiry             int32
	MaxMinerFee            int64
	MaxSwapFee             int64
	InitiationHeight       int32
	ProtocolVersion        int32
	Label                  string
	SwapHash_2             []byte
	DestAddress            string
	SwapInvoice            string
	MaxSwapRoutingFee      int64
	SweepConfTarget        int32
	HtlcConfirmations      int32
	OutgoingChanSet        string
	PrepayInvoice          string
	MaxPrepayRoutingFee    int64
	PublicationDeadline    time.Time
	SingleSweep            bool
	PaymentTimeout         int32
	SwapHash_3             []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type GetLoopOutSwapsRow 

type GetLoopOutSwapsRow struct {
	ID                     int32
	SwapHash               []byte
	Preimage               []byte
	InitiationTime         time.Time
	AmountRequested        int64
	CltvExpiry             int32
	MaxMinerFee            int64
	MaxSwapFee             int64
	InitiationHeight       int32
	ProtocolVersion        int32
	Label                  string
	SwapHash_2             []byte
	DestAddress            string
	SwapInvoice            string
	MaxSwapRoutingFee      int64
	SweepConfTarget        int32
	HtlcConfirmations      int32
	OutgoingChanSet        string
	PrepayInvoice          string
	MaxPrepayRoutingFee    int64
	PublicationDeadline    time.Time
	SingleSweep            bool
	PaymentTimeout         int32
	SwapHash_3             []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type GetStaticAddressLoopInSwapRow 

type GetStaticAddressLoopInSwapRow struct {
	ID                      int32
	SwapHash                []byte
	Preimage                []byte
	InitiationTime          time.Time
	AmountRequested         int64
	CltvExpiry              int32
	MaxMinerFee             int64
	MaxSwapFee              int64
	InitiationHeight        int32
	ProtocolVersion         int32
	Label                   string
	ID_2                    int32
	SwapHash_2              []byte
	SwapInvoice             string
	LastHop                 []byte
	PaymentTimeoutSeconds   int32
	QuotedSwapFeeSatoshis   int64
	DepositOutpoints        string
	HtlcTxFeeRateSatKw      int64
	HtlcTimeoutSweepTxID    sql.NullString
	HtlcTimeoutSweepAddress string
	SwapHash_3              []byte
	SenderScriptPubkey      []byte
	ReceiverScriptPubkey    []byte
	SenderInternalPubkey    []byte
	ReceiverInternalPubkey  []byte
	ClientKeyFamily         int32
	ClientKeyIndex          int32
}

type GetStaticAddressLoopInSwapsByStatesRow 

type GetStaticAddressLoopInSwapsByStatesRow struct {
	ID                      int32
	SwapHash                []byte
	Preimage                []byte
	InitiationTime          time.Time
	AmountRequested         int64
	CltvExpiry              int32
	MaxMinerFee             int64
	MaxSwapFee              int64
	InitiationHeight        int32
	ProtocolVersion         int32
	Label                   string
	ID_2                    int32
	SwapHash_2              []byte
	SwapInvoice             string
	LastHop                 []byte
	PaymentTimeoutSeconds   int32
	QuotedSwapFeeSatoshis   int64
	DepositOutpoints        string
	HtlcTxFeeRateSatKw      int64
	HtlcTimeoutSweepTxID    sql.NullString
	HtlcTimeoutSweepAddress string
	SwapHash_3              []byte
	SenderScriptPubkey      []byte
	ReceiverScriptPubkey    []byte
	SenderInternalPubkey    []byte
	ReceiverInternalPubkey  []byte
	ClientKeyFamily         int32
	ClientKeyIndex          int32
}

type HtlcKey 

type HtlcKey struct {
	SwapHash               []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type InsertBatchParams 

type InsertBatchParams struct {
	Confirmed          bool
	BatchTxID          sql.NullString
	BatchPkScript      []byte
	LastRbfHeight      sql.NullInt32
	LastRbfSatPerKw    sql.NullInt32
	MaxTimeoutDistance int32
}

type InsertDepositUpdateParams 

type InsertDepositUpdateParams struct {
	DepositID       []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type InsertHtlcKeysParams 

type InsertHtlcKeysParams struct {
	SwapHash               []byte
	SenderScriptPubkey     []byte
	ReceiverScriptPubkey   []byte
	SenderInternalPubkey   []byte
	ReceiverInternalPubkey []byte
	ClientKeyFamily        int32
	ClientKeyIndex         int32
}

type InsertInstantOutParams 

type InsertInstantOutParams struct {
	SwapHash        []byte
	Preimage        []byte
	SweepAddress    string
	OutgoingChanSet string
	HtlcFeeRate     int64
	ReservationIds  []byte
	SwapInvoice     string
}

type InsertInstantOutUpdateParams 

type InsertInstantOutUpdateParams struct {
	SwapHash        []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type InsertLoopInParams 

type InsertLoopInParams struct {
	SwapHash       []byte
	HtlcConfTarget int32
	LastHop        []byte
	ExternalHtlc   bool
}

type InsertLoopOutParams 

type InsertLoopOutParams struct {
	SwapHash            []byte
	DestAddress         string
	SwapInvoice         string
	MaxSwapRoutingFee   int64
	SweepConfTarget     int32
	HtlcConfirmations   int32
	OutgoingChanSet     string
	PrepayInvoice       string
	MaxPrepayRoutingFee int64
	PublicationDeadline time.Time
	SingleSweep         bool
	PaymentTimeout      int32
}

type InsertMigrationParams 

type InsertMigrationParams struct {
	MigrationID string
	MigrationTs sql.NullTime
}

type InsertReservationUpdateParams 

type InsertReservationUpdateParams struct {
	ReservationID   []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type InsertStaticAddressLoopInParams 

type InsertStaticAddressLoopInParams struct {
	SwapHash                []byte
	SwapInvoice             string
	LastHop                 []byte
	PaymentTimeoutSeconds   int32
	QuotedSwapFeeSatoshis   int64
	DepositOutpoints        string
	HtlcTxFeeRateSatKw      int64
	HtlcTimeoutSweepTxID    sql.NullString
	HtlcTimeoutSweepAddress string
}

type InsertStaticAddressMetaUpdateParams 

type InsertStaticAddressMetaUpdateParams struct {
	SwapHash        []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type InsertSwapParams 

type InsertSwapParams struct {
	SwapHash         []byte
	Preimage         []byte
	InitiationTime   time.Time
	AmountRequested  int64
	CltvExpiry       int32
	MaxMinerFee      int64
	MaxSwapFee       int64
	InitiationHeight int32
	ProtocolVersion  int32
	Label            string
}

type InsertSwapUpdateParams 

type InsertSwapUpdateParams struct {
	SwapHash        []byte
	UpdateTimestamp time.Time
	UpdateState     int32
	HtlcTxhash      string
	ServerCost      int64
	OnchainCost     int64
	OffchainCost    int64
}

type InstantoutSwap 

type InstantoutSwap struct {
	SwapHash                  []byte
	Preimage                  []byte
	SweepAddress              string
	OutgoingChanSet           string
	HtlcFeeRate               int64
	ReservationIds            []byte
	SwapInvoice               string
	FinalizedHtlcTx           []byte
	SweepTxHash               []byte
	FinalizedSweeplessSweepTx []byte
	SweepConfirmationHeight   sql.NullInt32
}

type InstantoutUpdate 

type InstantoutUpdate struct {
	ID              int32
	SwapHash        []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type LiquidityParam 

type LiquidityParam struct {
	ID     int32
	Params []byte
}

type LoopinSwap 

type LoopinSwap struct {
	SwapHash       []byte
	HtlcConfTarget int32
	LastHop        []byte
	ExternalHtlc   bool
}

type LoopoutSwap 

type LoopoutSwap struct {
	SwapHash            []byte
	DestAddress         string
	SwapInvoice         string
	MaxSwapRoutingFee   int64
	SweepConfTarget     int32
	HtlcConfirmations   int32
	OutgoingChanSet     string
	PrepayInvoice       string
	MaxPrepayRoutingFee int64
	PublicationDeadline time.Time
	SingleSweep         bool
	PaymentTimeout      int32
}

type MigrationTracker 

type MigrationTracker struct {
	MigrationID string
	MigrationTs sql.NullTime
}

type OverrideSwapCostsParams 

type OverrideSwapCostsParams struct {
	ID           int32
	ServerCost   int64
	OnchainCost  int64
	OffchainCost int64
}

type Querier 

type Querier interface {
	AllDeposits(ctx context.Context) ([]Deposit, error)
	AllStaticAddresses(ctx context.Context) ([]StaticAddress, error)
	ConfirmBatch(ctx context.Context, id int32) error
	CreateDeposit(ctx context.Context, arg CreateDepositParams) error
	CreateReservation(ctx context.Context, arg CreateReservationParams) error
	CreateStaticAddress(ctx context.Context, arg CreateStaticAddressParams) error
	DropBatch(ctx context.Context, id int32) error
	FetchLiquidityParams(ctx context.Context) ([]byte, error)
	GetBatchSweeps(ctx context.Context, batchID int32) ([]Sweep, error)
	GetBatchSweptAmount(ctx context.Context, batchID int32) (int64, error)
	GetDeposit(ctx context.Context, depositID []byte) (Deposit, error)
	GetInstantOutSwap(ctx context.Context, swapHash []byte) (GetInstantOutSwapRow, error)
	GetInstantOutSwapUpdates(ctx context.Context, swapHash []byte) ([]InstantoutUpdate, error)
	GetInstantOutSwaps(ctx context.Context) ([]GetInstantOutSwapsRow, error)
	GetLastUpdateID(ctx context.Context, swapHash []byte) (int32, error)
	GetLatestDepositUpdate(ctx context.Context, depositID []byte) (DepositUpdate, error)
	GetLoopInSwap(ctx context.Context, swapHash []byte) (GetLoopInSwapRow, error)
	GetLoopInSwapUpdates(ctx context.Context, swapHash []byte) ([]StaticAddressSwapUpdate, error)
	GetLoopInSwaps(ctx context.Context) ([]GetLoopInSwapsRow, error)
	GetLoopOutSwap(ctx context.Context, swapHash []byte) (GetLoopOutSwapRow, error)
	GetLoopOutSwaps(ctx context.Context) ([]GetLoopOutSwapsRow, error)
	GetMigration(ctx context.Context, migrationID string) (MigrationTracker, error)
	GetParentBatch(ctx context.Context, swapHash []byte) (SweepBatch, error)
	GetReservation(ctx context.Context, reservationID []byte) (Reservation, error)
	GetReservationUpdates(ctx context.Context, reservationID []byte) ([]ReservationUpdate, error)
	GetReservations(ctx context.Context) ([]Reservation, error)
	GetStaticAddress(ctx context.Context, pkscript []byte) (StaticAddress, error)
	GetStaticAddressLoopInSwap(ctx context.Context, swapHash []byte) (GetStaticAddressLoopInSwapRow, error)
	GetStaticAddressLoopInSwapsByStates(ctx context.Context, dollar_1 sql.NullString) ([]GetStaticAddressLoopInSwapsByStatesRow, error)
	GetSwapUpdates(ctx context.Context, swapHash []byte) ([]SwapUpdate, error)
	GetSweepStatus(ctx context.Context, swapHash []byte) (bool, error)
	GetUnconfirmedBatches(ctx context.Context) ([]SweepBatch, error)
	InsertBatch(ctx context.Context, arg InsertBatchParams) (int32, error)
	InsertDepositUpdate(ctx context.Context, arg InsertDepositUpdateParams) error
	InsertHtlcKeys(ctx context.Context, arg InsertHtlcKeysParams) error
	InsertInstantOut(ctx context.Context, arg InsertInstantOutParams) error
	InsertInstantOutUpdate(ctx context.Context, arg InsertInstantOutUpdateParams) error
	InsertLoopIn(ctx context.Context, arg InsertLoopInParams) error
	InsertLoopOut(ctx context.Context, arg InsertLoopOutParams) error
	InsertMigration(ctx context.Context, arg InsertMigrationParams) error
	InsertReservationUpdate(ctx context.Context, arg InsertReservationUpdateParams) error
	InsertStaticAddressLoopIn(ctx context.Context, arg InsertStaticAddressLoopInParams) error
	InsertStaticAddressMetaUpdate(ctx context.Context, arg InsertStaticAddressMetaUpdateParams) error
	InsertSwap(ctx context.Context, arg InsertSwapParams) error
	InsertSwapUpdate(ctx context.Context, arg InsertSwapUpdateParams) error
	IsStored(ctx context.Context, swapHash []byte) (bool, error)
	OverrideSwapCosts(ctx context.Context, arg OverrideSwapCostsParams) error
	UpdateBatch(ctx context.Context, arg UpdateBatchParams) error
	UpdateDeposit(ctx context.Context, arg UpdateDepositParams) error
	UpdateInstantOut(ctx context.Context, arg UpdateInstantOutParams) error
	UpdateReservation(ctx context.Context, arg UpdateReservationParams) error
	UpdateStaticAddressLoopIn(ctx context.Context, arg UpdateStaticAddressLoopInParams) error
	UpsertLiquidityParams(ctx context.Context, params []byte) error
	UpsertSweep(ctx context.Context, arg UpsertSweepParams) error
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AllDeposits 

func (q *Queries) AllDeposits(ctx context.Context) ([]Deposit, error)

func (*Queries) AllStaticAddresses 

func (q *Queries) AllStaticAddresses(ctx context.Context) ([]StaticAddress, error)

func (*Queries) ConfirmBatch 

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

func (*Queries) CreateDeposit 

func (q *Queries) CreateDeposit(ctx context.Context, arg CreateDepositParams) error

func (*Queries) CreateReservation 

func (q *Queries) CreateReservation(ctx context.Context, arg CreateReservationParams) error

func (*Queries) CreateStaticAddress 

func (q *Queries) CreateStaticAddress(ctx context.Context, arg CreateStaticAddressParams) error

func (*Queries) DropBatch 

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

func (*Queries) FetchLiquidityParams 

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

func (*Queries) GetBatchSweeps 

func (q *Queries) GetBatchSweeps(ctx context.Context, batchID int32) ([]Sweep, error)

func (*Queries) GetBatchSweptAmount 

func (q *Queries) GetBatchSweptAmount(ctx context.Context, batchID int32) (int64, error)

func (*Queries) GetDeposit 

func (q *Queries) GetDeposit(ctx context.Context, depositID []byte) (Deposit, error)

func (*Queries) GetInstantOutSwap 

func (q *Queries) GetInstantOutSwap(ctx context.Context, swapHash []byte) (GetInstantOutSwapRow, error)

func (*Queries) GetInstantOutSwapUpdates 

func (q *Queries) GetInstantOutSwapUpdates(ctx context.Context, swapHash []byte) ([]InstantoutUpdate, error)

func (*Queries) GetInstantOutSwaps 

func (q *Queries) GetInstantOutSwaps(ctx context.Context) ([]GetInstantOutSwapsRow, error)

func (*Queries) GetLastUpdateID 

func (q *Queries) GetLastUpdateID(ctx context.Context, swapHash []byte) (int32, error)

func (*Queries) GetLatestDepositUpdate 

func (q *Queries) GetLatestDepositUpdate(ctx context.Context, depositID []byte) (DepositUpdate, error)

func (*Queries) GetLoopInSwap 

func (q *Queries) GetLoopInSwap(ctx context.Context, swapHash []byte) (GetLoopInSwapRow, error)

func (*Queries) GetLoopInSwapUpdates 

func (q *Queries) GetLoopInSwapUpdates(ctx context.Context, swapHash []byte) ([]StaticAddressSwapUpdate, error)

func (*Queries) GetLoopInSwaps 

func (q *Queries) GetLoopInSwaps(ctx context.Context) ([]GetLoopInSwapsRow, error)

func (*Queries) GetLoopOutSwap 

func (q *Queries) GetLoopOutSwap(ctx context.Context, swapHash []byte) (GetLoopOutSwapRow, error)

func (*Queries) GetLoopOutSwaps 

func (q *Queries) GetLoopOutSwaps(ctx context.Context) ([]GetLoopOutSwapsRow, error)

func (*Queries) GetMigration 

func (q *Queries) GetMigration(ctx context.Context, migrationID string) (MigrationTracker, error)

func (*Queries) GetParentBatch 

func (q *Queries) GetParentBatch(ctx context.Context, swapHash []byte) (SweepBatch, error)

func (*Queries) GetReservation 

func (q *Queries) GetReservation(ctx context.Context, reservationID []byte) (Reservation, error)

func (*Queries) GetReservationUpdates 

func (q *Queries) GetReservationUpdates(ctx context.Context, reservationID []byte) ([]ReservationUpdate, error)

func (*Queries) GetReservations 

func (q *Queries) GetReservations(ctx context.Context) ([]Reservation, error)

func (*Queries) GetStaticAddress 

func (q *Queries) GetStaticAddress(ctx context.Context, pkscript []byte) (StaticAddress, error)

func (*Queries) GetStaticAddressLoopInSwap 

func (q *Queries) GetStaticAddressLoopInSwap(ctx context.Context, swapHash []byte) (GetStaticAddressLoopInSwapRow, error)

func (*Queries) GetStaticAddressLoopInSwapsByStates 

func (q *Queries) GetStaticAddressLoopInSwapsByStates(ctx context.Context, dollar_1 sql.NullString) ([]GetStaticAddressLoopInSwapsByStatesRow, error)

func (*Queries) GetSwapUpdates 

func (q *Queries) GetSwapUpdates(ctx context.Context, swapHash []byte) ([]SwapUpdate, error)

func (*Queries) GetSweepStatus 

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

func (*Queries) GetUnconfirmedBatches 

func (q *Queries) GetUnconfirmedBatches(ctx context.Context) ([]SweepBatch, error)

func (*Queries) InsertBatch 

func (q *Queries) InsertBatch(ctx context.Context, arg InsertBatchParams) (int32, error)

func (*Queries) InsertDepositUpdate 

func (q *Queries) InsertDepositUpdate(ctx context.Context, arg InsertDepositUpdateParams) error

func (*Queries) InsertHtlcKeys 

func (q *Queries) InsertHtlcKeys(ctx context.Context, arg InsertHtlcKeysParams) error

func (*Queries) InsertInstantOut 

func (q *Queries) InsertInstantOut(ctx context.Context, arg InsertInstantOutParams) error

func (*Queries) InsertInstantOutUpdate 

func (q *Queries) InsertInstantOutUpdate(ctx context.Context, arg InsertInstantOutUpdateParams) error

func (*Queries) InsertLoopIn 

func (q *Queries) InsertLoopIn(ctx context.Context, arg InsertLoopInParams) error

func (*Queries) InsertLoopOut 

func (q *Queries) InsertLoopOut(ctx context.Context, arg InsertLoopOutParams) error

func (*Queries) InsertMigration 

func (q *Queries) InsertMigration(ctx context.Context, arg InsertMigrationParams) error

func (*Queries) InsertReservationUpdate 

func (q *Queries) InsertReservationUpdate(ctx context.Context, arg InsertReservationUpdateParams) error

func (*Queries) InsertStaticAddressLoopIn 

func (q *Queries) InsertStaticAddressLoopIn(ctx context.Context, arg InsertStaticAddressLoopInParams) error

func (*Queries) InsertStaticAddressMetaUpdate 

func (q *Queries) InsertStaticAddressMetaUpdate(ctx context.Context, arg InsertStaticAddressMetaUpdateParams) error

func (*Queries) InsertSwap 

func (q *Queries) InsertSwap(ctx context.Context, arg InsertSwapParams) error

func (*Queries) InsertSwapUpdate 

func (q *Queries) InsertSwapUpdate(ctx context.Context, arg InsertSwapUpdateParams) error

func (*Queries) IsStored 

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

func (*Queries) OverrideSwapCosts 

func (q *Queries) OverrideSwapCosts(ctx context.Context, arg OverrideSwapCostsParams) error

func (*Queries) UpdateBatch 

func (q *Queries) UpdateBatch(ctx context.Context, arg UpdateBatchParams) error

func (*Queries) UpdateDeposit 

func (q *Queries) UpdateDeposit(ctx context.Context, arg UpdateDepositParams) error

func (*Queries) UpdateInstantOut 

func (q *Queries) UpdateInstantOut(ctx context.Context, arg UpdateInstantOutParams) error

func (*Queries) UpdateReservation 

func (q *Queries) UpdateReservation(ctx context.Context, arg UpdateReservationParams) error

func (*Queries) UpdateStaticAddressLoopIn 

func (q *Queries) UpdateStaticAddressLoopIn(ctx context.Context, arg UpdateStaticAddressLoopInParams) error

func (*Queries) UpsertLiquidityParams 

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

func (*Queries) UpsertSweep 

func (q *Queries) UpsertSweep(ctx context.Context, arg UpsertSweepParams) error

func (*Queries) WithTx 

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

type Reservation 

type Reservation struct {
	ID                 int32
	ReservationID      []byte
	ClientPubkey       []byte
	ServerPubkey       []byte
	Expiry             int32
	Value              int64
	ClientKeyFamily    int32
	ClientKeyIndex     int32
	InitiationHeight   int32
	TxHash             []byte
	OutIndex           sql.NullInt32
	ConfirmationHeight sql.NullInt32
}

type ReservationUpdate 

type ReservationUpdate struct {
	ID              int32
	ReservationID   []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type StaticAddress 

type StaticAddress struct {
	ID               int32
	ClientPubkey     []byte
	ServerPubkey     []byte
	Expiry           int32
	ClientKeyFamily  int32
	ClientKeyIndex   int32
	Pkscript         []byte
	ProtocolVersion  int32
	InitiationHeight int32
}

type StaticAddressSwap 

type StaticAddressSwap struct {
	ID                      int32
	SwapHash                []byte
	SwapInvoice             string
	LastHop                 []byte
	PaymentTimeoutSeconds   int32
	QuotedSwapFeeSatoshis   int64
	DepositOutpoints        string
	HtlcTxFeeRateSatKw      int64
	HtlcTimeoutSweepTxID    sql.NullString
	HtlcTimeoutSweepAddress string
}

type StaticAddressSwapUpdate 

type StaticAddressSwapUpdate struct {
	ID              int32
	SwapHash        []byte
	UpdateState     string
	UpdateTimestamp time.Time
}

type Swap 

type Swap struct {
	ID               int32
	SwapHash         []byte
	Preimage         []byte
	InitiationTime   time.Time
	AmountRequested  int64
	CltvExpiry       int32
	MaxMinerFee      int64
	MaxSwapFee       int64
	InitiationHeight int32
	ProtocolVersion  int32
	Label            string
}

type SwapUpdate 

type SwapUpdate struct {
	ID              int32
	SwapHash        []byte
	UpdateTimestamp time.Time
	UpdateState     int32
	HtlcTxhash      string
	ServerCost      int64
	OnchainCost     int64
	OffchainCost    int64
}

type Sweep 

type Sweep struct {
	ID            int32
	SwapHash      []byte
	BatchID       int32
	OutpointTxid  []byte
	OutpointIndex int32
	Amt           int64
	Completed     bool
}

type SweepBatch 

type SweepBatch struct {
	ID                 int32
	Confirmed          bool
	BatchTxID          sql.NullString
	BatchPkScript      []byte
	LastRbfHeight      sql.NullInt32
	LastRbfSatPerKw    sql.NullInt32
	MaxTimeoutDistance int32
}

type UpdateBatchParams 

type UpdateBatchParams struct {
	ID              int32
	Confirmed       bool
	BatchTxID       sql.NullString
	BatchPkScript   []byte
	LastRbfHeight   sql.NullInt32
	LastRbfSatPerKw sql.NullInt32
}

type UpdateDepositParams 

type UpdateDepositParams struct {
	DepositID             []byte
	TxHash                []byte
	OutIndex              int32
	ConfirmationHeight    int64
	ExpirySweepTxid       []byte
	FinalizedWithdrawalTx sql.NullString
}

type UpdateInstantOutParams 

type UpdateInstantOutParams struct {
	SwapHash                  []byte
	FinalizedHtlcTx           []byte
	SweepTxHash               []byte
	FinalizedSweeplessSweepTx []byte
	SweepConfirmationHeight   sql.NullInt32
}

type UpdateReservationParams 

type UpdateReservationParams struct {
	ReservationID      []byte
	TxHash             []byte
	OutIndex           sql.NullInt32
	ConfirmationHeight sql.NullInt32
}

type UpdateStaticAddressLoopInParams 

type UpdateStaticAddressLoopInParams struct {
	SwapHash             []byte
	HtlcTxFeeRateSatKw   int64
	HtlcTimeoutSweepTxID sql.NullString
}

type UpsertSweepParams 

type UpsertSweepParams struct {
	SwapHash      []byte
	BatchID       int32
	OutpointTxid  []byte
	OutpointIndex int32
	Amt           int64
	Completed     bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.