queries

package

Go to main page

Versions in this module

v0

v0.9.5

May 8, 2026

v0.9.4

Apr 27, 2026

Changes in this version

type Queries

+ func (q *Queries) SelectRoundSweepTxs(ctx context.Context, txid string) ([]SelectRoundSweepTxsRow, error)

+ type SelectRoundSweepTxsRow struct

+ Tx string

+ Txid string

v0.9.3

Apr 20, 2026

v0.9.2

Mar 26, 2026

v0.9.1

Mar 19, 2026

v0.9.0

Mar 5, 2026

Changes in this version

+ type Asset struct

+ ControlAssetID sql.NullString

+ ID string

+ IsImmutable bool

+ Metadata sql.NullString

+ MetadataHash sql.NullString

+ type AssetProjection struct

+ Amount string

+ AssetID string

+ Txid string

+ Vout int32

+ type InsertAssetParams struct

+ ControlAssetID sql.NullString

+ ID string

+ IsImmutable bool

+ Metadata sql.NullString

+ MetadataHash sql.NullString

+ type InsertVtxoAssetProjectionParams struct

+ Amount string

+ AssetID string

+ Txid string

+ Vout int32

type Intent

+ Txid sql.NullString

type IntentWithInputsVw

+ AssetAmount sql.NullString

+ AssetID sql.NullString

+ IntentTxid sql.NullString

+ UpdatedAt sql.NullInt64

type IntentWithReceiversVw

+ Txid sql.NullString

type Queries

+ func (q *Queries) InsertAsset(ctx context.Context, arg InsertAssetParams) error

+ func (q *Queries) InsertVtxoAssetProjection(ctx context.Context, arg InsertVtxoAssetProjectionParams) error

+ func (q *Queries) SelectAssetExists(ctx context.Context, id string) (int32, error)

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

+ func (q *Queries) SelectAssetsByIds(ctx context.Context, dollar_1 []string) ([]Asset, error)

+ func (q *Queries) SelectControlAssetByID(ctx context.Context, id string) (sql.NullString, error)

+ func (q *Queries) SelectIntentByTxid(ctx context.Context, txid sql.NullString) (SelectIntentByTxidRow, error)

type RoundIntentsVw

+ Txid sql.NullString

+ type SelectIntentByTxidRow struct

+ ID sql.NullString

+ Message sql.NullString

+ Proof sql.NullString

+ Txid sql.NullString

+ type SelectPendingSpentVtxosWithPubkeysParams struct

+ After int64

+ Before int64

+ Column1 []string

+ type SelectVtxosWithPubkeysParams struct

+ After int64

+ Before int64

+ Column1 []string

type UpsertIntentParams

+ Txid sql.NullString

type Vtxo

+ UpdatedAt int64

type VtxoVw

+ AssetAmount string

+ AssetID string

+ UpdatedAt int64

v0.9.0-rc.4

Mar 3, 2026

v0.9.0-rc.3

Feb 27, 2026

v0.9.0-rc.2

Feb 24, 2026

v0.9.0-rc.1

Feb 18, 2026

v0.9.0-rc.0

Feb 16, 2026

v0.8.11

Jan 2, 2026

Changes in this version

+ type AddIntentFeesParams struct

+ OffchainInputFeeProgram interface{}

+ OffchainOutputFeeProgram interface{}

+ OnchainInputFeeProgram interface{}

+ OnchainOutputFeeProgram interface{}

+ type IntentFee struct

+ CreatedAt int64

+ ID int64

+ OffchainInputFeeProgram string

+ OffchainOutputFeeProgram string

+ OnchainInputFeeProgram string

+ OnchainOutputFeeProgram string

type Queries

+ func (q *Queries) AddIntentFees(ctx context.Context, arg AddIntentFeesParams) error

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

+ func (q *Queries) SelectExpiringLiquidityAmount(ctx context.Context, arg SelectExpiringLiquidityAmountParams) (int64, error)

+ func (q *Queries) SelectLatestIntentFees(ctx context.Context) (IntentFee, error)

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

+ type SelectExpiringLiquidityAmountParams struct

+ After int64

+ Before interface{}

v0.8.10

Nov 29, 2025

v0.8.9

Nov 25, 2025

Changes in this version

type Queries

+ func (q *Queries) SelectPendingSpentVtxo(ctx context.Context, arg SelectPendingSpentVtxoParams) (VtxoVw, error)

+ func (q *Queries) SelectPendingSpentVtxosWithPubkeys(ctx context.Context, dollar_1 []string) ([]VtxoVw, error)

+ type SelectPendingSpentVtxoParams struct

+ Txid string

+ Vout int32

v0.8.8

Nov 21, 2025

v0.8.7

Nov 19, 2025

Changes in this version

type Queries

+ func (q *Queries) SelectSweepableVtxoOutpointsByCommitmentTxid(ctx context.Context, commitmentTxid string) ([]SelectSweepableVtxoOutpointsByCommitmentTxidRow, error)

+ func (q *Queries) SelectVtxoPubKeysByCommitmentTxid(ctx context.Context, arg SelectVtxoPubKeysByCommitmentTxidParams) ([]string, error)

+ func (q *Queries) SelectVtxosOutpointsByArkTxidRecursive(ctx context.Context, txid string) ([]SelectVtxosOutpointsByArkTxidRecursiveRow, error)

+ type SelectSweepableVtxoOutpointsByCommitmentTxidRow struct

+ VtxoTxid string

+ VtxoVout int32

+ type SelectVtxoPubKeysByCommitmentTxidParams struct

+ CommitmentTxid string

+ MinAmount int64

+ type SelectVtxosOutpointsByArkTxidRecursiveRow struct

+ Txid string

+ Vout int32

v0.8.6

Nov 11, 2025

v0.8.5

Nov 4, 2025

v0.8.4

Oct 30, 2025

Changes in this version

type Queries

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

v0.8.3

Oct 29, 2025

v0.8.2

Oct 28, 2025

v0.8.1

Oct 28, 2025

v0.8.1-rc.0

Oct 21, 2025

v0.8.0

Oct 20, 2025

Changes in this version

+ type Conviction struct

+ CreatedAt int64

+ CrimeReason string

+ CrimeRoundID string

+ CrimeType int32

+ ExpiresAt sql.NullInt64

+ ID string

+ Pardoned bool

+ Script sql.NullString

+ Type int32

type MarketHour

+ RoundMaxParticipants int64

+ RoundMinParticipants int64

type Queries

+ func (q *Queries) SelectActiveScriptConvictions(ctx context.Context, arg SelectActiveScriptConvictionsParams) ([]Conviction, error)

+ func (q *Queries) SelectConviction(ctx context.Context, id string) (Conviction, error)

+ func (q *Queries) SelectConvictionsByRoundID(ctx context.Context, roundID string) ([]Conviction, error)

+ func (q *Queries) SelectConvictionsInTimeRange(ctx context.Context, arg SelectConvictionsInTimeRangeParams) ([]Conviction, error)

+ func (q *Queries) SelectLatestScheduledSession(ctx context.Context) (ScheduledSession, error)

+ func (q *Queries) SelectRoundIdsInTimeRangeWithFilters(ctx context.Context, arg SelectRoundIdsInTimeRangeWithFiltersParams) ([]string, error)

+ func (q *Queries) SelectRoundIdsWithFilters(ctx context.Context, arg SelectRoundIdsWithFiltersParams) ([]string, error)

+ func (q *Queries) SelectSweepableUnrolledVtxos(ctx context.Context) ([]SelectSweepableUnrolledVtxosRow, error)

+ func (q *Queries) SelectVtxosByArkTxidRecursive(ctx context.Context, txid string) ([]SelectVtxosByArkTxidRecursiveRow, error)

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

+ func (q *Queries) UpdateVtxoSweptIfNotSwept(ctx context.Context, arg UpdateVtxoSweptIfNotSweptParams) (int64, error)

+ func (q *Queries) UpsertConviction(ctx context.Context, arg UpsertConvictionParams) error

+ func (q *Queries) UpsertScheduledSession(ctx context.Context, arg UpsertScheduledSessionParams) error

+ type ScheduledSession struct

+ Duration int64

+ EndTime int64

+ ID int32

+ Period int64

+ RoundMaxParticipants int64

+ RoundMinParticipants int64

+ StartTime int64

+ UpdatedAt int64

+ type SelectActiveScriptConvictionsParams struct

+ ExpiresAt sql.NullInt64

+ Script sql.NullString

+ type SelectConvictionsInTimeRangeParams struct

+ FromTime int64

+ ToTime int64

+ type SelectRoundIdsInTimeRangeWithFiltersParams struct

+ EndTs int64

+ StartTs int64

+ WithCompleted bool

+ WithFailed bool

+ type SelectRoundIdsWithFiltersParams struct

+ WithCompleted bool

+ WithFailed bool

+ type SelectSweepableUnrolledVtxosRow struct

+ VtxoVw VtxoVw

+ type SelectVtxosByArkTxidRecursiveRow struct

+ Depth int32

+ Preconfirmed bool

+ Txid string

+ Vout int32

+ type UpdateVtxoSweptIfNotSweptParams struct

+ Txid string

+ Vout int32

+ type UpsertConvictionParams struct

+ CreatedAt int64

+ CrimeReason string

+ CrimeRoundID string

+ CrimeType int32

+ ExpiresAt sql.NullInt64

+ ID string

+ Pardoned bool

+ Script sql.NullString

+ Type int32

+ type UpsertScheduledSessionParams struct

+ Duration int64

+ EndTime int64

+ ID int32

+ Period int64

+ RoundMaxParticipants int64

+ RoundMinParticipants int64

+ StartTime int64

+ UpdatedAt int64

v0.8.0-rc.1

Oct 10, 2025

v0.8.0-rc.0

Oct 9, 2025

v0.7.1

Sep 9, 2025

v0.7.1-rc.0

Sep 8, 2025

v0.7.0

Jul 9, 2025

Changes in this version

+ type CheckpointTx struct

+ CommitmentTxid string

+ IsRootCommitmentTxid bool

+ OffchainTxid string

+ Tx string

+ Txid string

+ type DBTX interface

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

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

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

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

+ type InsertVtxoCommitmentTxidParams struct

+ CommitmentTxid string

+ VtxoTxid string

+ VtxoVout int32

+ type Intent struct

+ ID sql.NullString

+ Message sql.NullString

+ Proof sql.NullString

+ RoundID sql.NullString

+ type IntentWithInputsVw struct

+ Amount sql.NullInt64

+ ArkTxid sql.NullString

+ CommitmentTxid sql.NullString

+ Commitments []byte

+ CreatedAt sql.NullInt64

+ ExpiresAt sql.NullInt64

+ ID sql.NullString

+ IntentID sql.NullString

+ Message sql.NullString

+ Preconfirmed sql.NullBool

+ Proof sql.NullString

+ Pubkey sql.NullString

+ RoundID sql.NullString

+ SettledBy sql.NullString

+ Spent sql.NullBool

+ SpentBy sql.NullString

+ Swept sql.NullBool

+ Txid sql.NullString

+ Unrolled sql.NullBool

+ Vout sql.NullInt32

+ type IntentWithReceiversVw struct

+ Amount sql.NullInt64

+ ID sql.NullString

+ IntentID sql.NullString

+ Message sql.NullString

+ OnchainAddress sql.NullString

+ Proof sql.NullString

+ Pubkey sql.NullString

+ RoundID sql.NullString

+ type MarketHour struct

+ EndTime int64

+ ID int32

+ Period int64

+ RoundInterval int64

+ StartTime int64

+ UpdatedAt int64

+ type OffchainTx struct

+ EndingTimestamp int64

+ ExpiryTimestamp int64

+ FailReason sql.NullString

+ StageCode int32

+ StartingTimestamp int64

+ Tx string

+ Txid string

+ type OffchainTxVw struct

+ CheckpointTx sql.NullString

+ CheckpointTxid sql.NullString

+ CommitmentTxid sql.NullString

+ EndingTimestamp int64

+ ExpiryTimestamp int64

+ FailReason sql.NullString

+ IsRootCommitmentTxid sql.NullBool

+ OffchainTxid sql.NullString

+ StageCode int32

+ StartingTimestamp int64

+ Tx string

+ Txid string

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) InsertVtxoCommitmentTxid(ctx context.Context, arg InsertVtxoCommitmentTxidParams) error

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

+ func (q *Queries) SelectAllVtxos(ctx context.Context) ([]SelectAllVtxosRow, error)

+ func (q *Queries) SelectLatestMarketHour(ctx context.Context) (MarketHour, error)

+ func (q *Queries) SelectNotUnrolledVtxos(ctx context.Context) ([]SelectNotUnrolledVtxosRow, error)

+ func (q *Queries) SelectNotUnrolledVtxosWithPubkey(ctx context.Context, pubkey string) ([]SelectNotUnrolledVtxosWithPubkeyRow, error)

+ func (q *Queries) SelectOffchainTx(ctx context.Context, txid string) ([]SelectOffchainTxRow, error)

+ func (q *Queries) SelectRoundConnectors(ctx context.Context, txid string) ([]Tx, error)

+ func (q *Queries) SelectRoundForfeitTxs(ctx context.Context, txid string) ([]Tx, error)

+ func (q *Queries) SelectRoundIdsInTimeRange(ctx context.Context, arg SelectRoundIdsInTimeRangeParams) ([]string, error)

+ func (q *Queries) SelectRoundStats(ctx context.Context, txid string) (SelectRoundStatsRow, error)

+ func (q *Queries) SelectRoundVtxoTree(ctx context.Context, txid string) ([]Tx, error)

+ func (q *Queries) SelectRoundVtxoTreeLeaves(ctx context.Context, commitmentTxid string) ([]SelectRoundVtxoTreeLeavesRow, error)

+ func (q *Queries) SelectRoundWithId(ctx context.Context, id string) ([]SelectRoundWithIdRow, error)

+ func (q *Queries) SelectRoundWithTxid(ctx context.Context, txid string) ([]SelectRoundWithTxidRow, error)

+ func (q *Queries) SelectRoundsWithTxids(ctx context.Context, dollar_1 []string) ([]string, error)

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

+ func (q *Queries) SelectSweepableVtxos(ctx context.Context) ([]SelectSweepableVtxosRow, error)

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

+ func (q *Queries) SelectTxs(ctx context.Context, dollar_1 []string) ([]SelectTxsRow, error)

+ func (q *Queries) SelectVtxo(ctx context.Context, arg SelectVtxoParams) (SelectVtxoRow, error)

+ func (q *Queries) SelectVtxosWithCommitmentTxid(ctx context.Context, commitmentTxid string) ([]SelectVtxosWithCommitmentTxidRow, error)

+ func (q *Queries) SelectVtxosWithPubkeys(ctx context.Context, dollar_1 []string) ([]SelectVtxosWithPubkeysRow, error)

+ func (q *Queries) UpdateVtxoExpiration(ctx context.Context, arg UpdateVtxoExpirationParams) error

+ func (q *Queries) UpdateVtxoIntentId(ctx context.Context, arg UpdateVtxoIntentIdParams) error

+ func (q *Queries) UpdateVtxoSettled(ctx context.Context, arg UpdateVtxoSettledParams) error

+ func (q *Queries) UpdateVtxoSpent(ctx context.Context, arg UpdateVtxoSpentParams) error

+ func (q *Queries) UpdateVtxoSwept(ctx context.Context, arg UpdateVtxoSweptParams) error

+ func (q *Queries) UpdateVtxoUnrolled(ctx context.Context, arg UpdateVtxoUnrolledParams) error

+ func (q *Queries) UpsertCheckpointTx(ctx context.Context, arg UpsertCheckpointTxParams) error

+ func (q *Queries) UpsertIntent(ctx context.Context, arg UpsertIntentParams) error

+ func (q *Queries) UpsertMarketHour(ctx context.Context, arg UpsertMarketHourParams) error

+ func (q *Queries) UpsertOffchainTx(ctx context.Context, arg UpsertOffchainTxParams) error

+ func (q *Queries) UpsertReceiver(ctx context.Context, arg UpsertReceiverParams) error

+ func (q *Queries) UpsertRound(ctx context.Context, arg UpsertRoundParams) error

+ func (q *Queries) UpsertTx(ctx context.Context, arg UpsertTxParams) error

+ func (q *Queries) UpsertVtxo(ctx context.Context, arg UpsertVtxoParams) error

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

+ type Receiver struct

+ Amount int64

+ IntentID string

+ OnchainAddress string

+ Pubkey string

+ type Round struct

+ ConnectorAddress string

+ Ended bool

+ EndingTimestamp int64

+ FailReason sql.NullString

+ Failed bool

+ ID string

+ StageCode int32

+ StartingTimestamp int64

+ Swept bool

+ Version int32

+ VtxoTreeExpiration int64

+ type RoundIntentsVw struct

+ ID sql.NullString

+ Message sql.NullString

+ Proof sql.NullString

+ RoundID sql.NullString

+ type RoundTxsVw struct

+ Children pqtype.NullRawMessage

+ Position sql.NullInt32

+ RoundID sql.NullString

+ Tx sql.NullString

+ Txid sql.NullString

+ Type sql.NullString

+ type RoundWithCommitmentTxVw struct

+ Children pqtype.NullRawMessage

+ ConnectorAddress string

+ Ended bool

+ EndingTimestamp int64

+ FailReason sql.NullString

+ Failed bool

+ ID string

+ Position int32

+ RoundID string

+ StageCode int32

+ StartingTimestamp int64

+ Swept bool

+ Tx string

+ Txid string

+ Type string

+ Version int32

+ VtxoTreeExpiration int64

+ type SelectAllVtxosRow struct

+ VtxoVw VtxoVw

+ type SelectNotUnrolledVtxosRow struct

+ VtxoVw VtxoVw

+ type SelectNotUnrolledVtxosWithPubkeyRow struct

+ VtxoVw VtxoVw

+ type SelectOffchainTxRow struct

+ OffchainTxVw OffchainTxVw

+ type SelectRoundIdsInTimeRangeParams struct

+ EndTs int64

+ StartTs int64

+ type SelectRoundStatsRow struct

+ EndingTimestamp int64

+ ExpiresAt interface{}

+ StartingTimestamp int64

+ Swept bool

+ TotalBatchAmount int64

+ TotalForfeitAmount int64

+ TotalInputVtxos int64

+ TotalOutputVtxos int64

+ type SelectRoundVtxoTreeLeavesRow struct

+ VtxoVw VtxoVw

+ type SelectRoundWithIdRow struct

+ IntentWithInputsVw IntentWithInputsVw

+ IntentWithReceiversVw IntentWithReceiversVw

+ Round Round

+ RoundIntentsVw RoundIntentsVw

+ RoundTxsVw RoundTxsVw

+ type SelectRoundWithTxidRow struct

+ IntentWithInputsVw IntentWithInputsVw

+ IntentWithReceiversVw IntentWithReceiversVw

+ Round Round

+ RoundIntentsVw RoundIntentsVw

+ RoundTxsVw RoundTxsVw

+ type SelectSweepableVtxosRow struct

+ VtxoVw VtxoVw

+ type SelectTxsRow struct

+ Data string

+ Txid string

+ type SelectVtxoParams struct

+ Txid string

+ Vout int32

+ type SelectVtxoRow struct

+ VtxoVw VtxoVw

+ type SelectVtxosWithCommitmentTxidRow struct

+ VtxoVw VtxoVw

+ type SelectVtxosWithPubkeysRow struct

+ VtxoVw VtxoVw

+ type Tx struct

+ Children pqtype.NullRawMessage

+ Position int32

+ RoundID string

+ Tx string

+ Txid string

+ Type string

+ type UpdateVtxoExpirationParams struct

+ ExpiresAt int64

+ Txid string

+ Vout int32

+ type UpdateVtxoIntentIdParams struct

+ IntentID sql.NullString

+ Txid string

+ Vout int32

+ type UpdateVtxoSettledParams struct

+ SettledBy sql.NullString

+ SpentBy sql.NullString

+ Txid string

+ Vout int32

+ type UpdateVtxoSpentParams struct

+ ArkTxid sql.NullString

+ SpentBy sql.NullString

+ Txid string

+ Vout int32

+ type UpdateVtxoSweptParams struct

+ Txid string

+ Vout int32

+ type UpdateVtxoUnrolledParams struct

+ Txid string

+ Vout int32

+ type UpsertCheckpointTxParams struct

+ CommitmentTxid string

+ IsRootCommitmentTxid bool

+ OffchainTxid string

+ Tx string

+ Txid string

+ type UpsertIntentParams struct

+ ID sql.NullString

+ Message sql.NullString

+ Proof sql.NullString

+ RoundID sql.NullString

+ type UpsertMarketHourParams struct

+ EndTime int64

+ ID int32

+ Period int64

+ RoundInterval int64

+ StartTime int64

+ UpdatedAt int64

+ type UpsertOffchainTxParams struct

+ EndingTimestamp int64

+ ExpiryTimestamp int64

+ FailReason sql.NullString

+ StageCode int32

+ StartingTimestamp int64

+ Tx string

+ Txid string

+ type UpsertReceiverParams struct

+ Amount int64

+ IntentID string

+ OnchainAddress string

+ Pubkey string

+ type UpsertRoundParams struct

+ ConnectorAddress string

+ Ended bool

+ EndingTimestamp int64

+ FailReason sql.NullString

+ Failed bool

+ ID string

+ StageCode int32

+ StartingTimestamp int64

+ Swept bool

+ Version int32

+ VtxoTreeExpiration int64

+ type UpsertTxParams struct

+ Children pqtype.NullRawMessage

+ Position int32

+ RoundID string

+ Tx string

+ Txid string

+ Type string

+ type UpsertVtxoParams struct

+ Amount int64

+ ArkTxid sql.NullString

+ CommitmentTxid string

+ CreatedAt int64

+ ExpiresAt int64

+ Preconfirmed bool

+ Pubkey string

+ SettledBy sql.NullString

+ Spent bool

+ SpentBy sql.NullString

+ Swept bool

+ Txid string

+ Unrolled bool

+ Vout int32

+ type Vtxo struct

+ Amount int64

+ ArkTxid sql.NullString

+ CommitmentTxid string

+ CreatedAt int64

+ ExpiresAt int64

+ IntentID sql.NullString

+ Preconfirmed bool

+ Pubkey string

+ SettledBy sql.NullString

+ Spent bool

+ SpentBy sql.NullString

+ Swept bool

+ Txid string

+ Unrolled bool

+ Vout int32

+ type VtxoCommitmentTxid struct

+ CommitmentTxid string

+ VtxoTxid string

+ VtxoVout int32

+ type VtxoVw struct

+ Amount int64

+ ArkTxid sql.NullString

+ CommitmentTxid string

+ Commitments []byte

+ CreatedAt int64

+ ExpiresAt int64

+ IntentID sql.NullString

+ Preconfirmed bool

+ Pubkey string

+ SettledBy sql.NullString

+ Spent bool

+ SpentBy sql.NullString

+ Swept bool

+ Txid string

+ Unrolled bool

+ Vout int32

v0.7.0-rc.2

Jul 8, 2025

v0.7.0-rc.0

Jul 4, 2025

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