queries

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddressLog

type AddressLog struct {
	Address               string
	InboxID               []byte
	AssociationSequenceID sql.NullInt64
	RevocationSequenceID  sql.NullInt64
}

type BlockchainMessage added in v0.2.0

type BlockchainMessage struct {
	BlockNumber          uint64
	BlockHash            []byte
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	IsCanonical          bool
}

type BuildPayerReportParams added in v0.3.0

type BuildPayerReportParams struct {
	OriginatorID           int32
	StartMinutesSinceEpoch int32
	EndMinutesSinceEpoch   int32
}

type BuildPayerReportRow added in v0.3.0

type BuildPayerReportRow struct {
	PayerAddress          string
	TotalSpendPicodollars int64
}

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 FillNonceSequenceParams added in v0.3.0

type FillNonceSequenceParams struct {
	PendingNonce int64
	NumElements  int32
}

type GatewayEnvelope

type GatewayEnvelope struct {
	GatewayTime          time.Time
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	Topic                []byte
	OriginatorEnvelope   []byte
	PayerID              sql.NullInt32
}

type GetAddressLogsRow

type GetAddressLogsRow struct {
	Address               string
	InboxID               string
	AssociationSequenceID sql.NullInt64
}

type GetBlocksInRangeParams added in v0.2.0

type GetBlocksInRangeParams struct {
	StartBlock uint64
	EndBlock   uint64
}

type GetBlocksInRangeRow added in v0.2.0

type GetBlocksInRangeRow struct {
	BlockNumber uint64
	BlockHash   []byte
}

type GetGatewayEnvelopeByIDParams added in v0.3.0

type GetGatewayEnvelopeByIDParams struct {
	OriginatorSequenceID int64
	OriginatorNodeID     int32
}

type GetLatestBlockRow added in v0.2.0

type GetLatestBlockRow struct {
	BlockNumber int64
	BlockHash   []byte
}

type GetLatestCursorRow added in v0.2.0

type GetLatestCursorRow struct {
	OriginatorNodeID int32
	MaxSequenceID    int64
}

type GetPayerUnsettledUsageParams added in v0.3.0

type GetPayerUnsettledUsageParams struct {
	PayerID             int32
	MinutesSinceEpochGt int64
	MinutesSinceEpochLt int64
}

type GetPayerUnsettledUsageRow added in v0.3.0

type GetPayerUnsettledUsageRow struct {
	TotalSpendPicodollars int64
	LastSequenceID        int64
}

type GetRecentOriginatorCongestionParams added in v0.3.0

type GetRecentOriginatorCongestionParams struct {
	OriginatorID int32
	EndMinute    int32
	NumMinutes   int32
}

type GetRecentOriginatorCongestionRow added in v0.3.0

type GetRecentOriginatorCongestionRow struct {
	MinutesSinceEpoch int32
	NumMessages       int32
}

type GetSecondNewestMinuteParams added in v0.3.0

type GetSecondNewestMinuteParams struct {
	OriginatorID             int32
	MinimumMinutesSinceEpoch int32
}

type GetSecondNewestMinuteRow added in v0.3.0

type GetSecondNewestMinuteRow struct {
	MaxSequenceID     int64
	MinutesSinceEpoch int32
}

type IncrementOriginatorCongestionParams added in v0.3.0

type IncrementOriginatorCongestionParams struct {
	OriginatorID      int32
	MinutesSinceEpoch int32
}

type IncrementUnsettledUsageParams added in v0.3.0

type IncrementUnsettledUsageParams struct {
	PayerID           int32
	OriginatorID      int32
	MinutesSinceEpoch int32
	SpendPicodollars  int64
	SequenceID        int64
}

type InsertAddressLogParams

type InsertAddressLogParams struct {
	Address               string
	InboxID               string
	AssociationSequenceID sql.NullInt64
}

type InsertBlockchainMessageParams added in v0.2.0

type InsertBlockchainMessageParams struct {
	BlockNumber          uint64
	BlockHash            []byte
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	IsCanonical          bool
}

type InsertGatewayEnvelopeParams

type InsertGatewayEnvelopeParams struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	Topic                []byte
	OriginatorEnvelope   []byte
	PayerID              sql.NullInt32
	GatewayTime          interface{}
}

type InsertNodeInfoParams

type InsertNodeInfoParams struct {
	NodeID    int32
	PublicKey []byte
}

type InsertStagedOriginatorEnvelopeParams

type InsertStagedOriginatorEnvelopeParams struct {
	Topic         []byte
	PayerEnvelope []byte
}

type LatestBlock added in v0.1.1

type LatestBlock struct {
	ContractAddress string
	BlockNumber     int64
	BlockHash       []byte
}

type NodeInfo

type NodeInfo struct {
	NodeID      int32
	PublicKey   []byte
	SingletonID int16
}

type NonceTable added in v0.3.0

type NonceTable struct {
	Nonce     int64
	CreatedAt sql.NullTime
}

type OriginatorCongestion added in v0.3.0

type OriginatorCongestion struct {
	OriginatorID      int32
	NumMessages       int32
	MinutesSinceEpoch int32
}

type Payer added in v0.3.0

type Payer struct {
	ID      int32
	Address string
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) BuildPayerReport added in v0.3.0

func (q *Queries) BuildPayerReport(ctx context.Context, arg BuildPayerReportParams) ([]BuildPayerReportRow, error)

func (*Queries) DeleteAvailableNonce added in v0.3.0

func (q *Queries) DeleteAvailableNonce(ctx context.Context, nonce int64) (int64, error)

func (*Queries) DeleteObsoleteNonces added in v0.3.0

func (q *Queries) DeleteObsoleteNonces(ctx context.Context, nonce int64) (int64, error)

func (*Queries) DeleteStagedOriginatorEnvelope

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

func (*Queries) FillNonceSequence added in v0.3.0

func (q *Queries) FillNonceSequence(ctx context.Context, arg FillNonceSequenceParams) (int32, error)

func (*Queries) FindOrCreatePayer added in v0.3.0

func (q *Queries) FindOrCreatePayer(ctx context.Context, address string) (int32, error)

func (*Queries) GetAddressLogs

func (q *Queries) GetAddressLogs(ctx context.Context, addresses []string) ([]GetAddressLogsRow, error)

func (*Queries) GetBlocksInRange added in v0.2.0

func (q *Queries) GetBlocksInRange(ctx context.Context, arg GetBlocksInRangeParams) ([]GetBlocksInRangeRow, error)

Returns blocks in ascending order (oldest to newest) StartBlock should be the lower bound (older block) EndBlock should be the upper bound (newer block) Example: GetBlocksInRange(1000, 2000), returns 1000, 1001, 1002, ..., 2000

func (*Queries) GetGatewayEnvelopeByID added in v0.3.0

func (q *Queries) GetGatewayEnvelopeByID(ctx context.Context, arg GetGatewayEnvelopeByIDParams) (GatewayEnvelope, error)

Include the node ID to take advantage of the primary key index

func (*Queries) GetLatestBlock added in v0.1.1

func (q *Queries) GetLatestBlock(ctx context.Context, contractAddress string) (GetLatestBlockRow, error)

func (*Queries) GetLatestCursor added in v0.2.0

func (q *Queries) GetLatestCursor(ctx context.Context) ([]GetLatestCursorRow, error)

func (*Queries) GetLatestSequenceId

func (q *Queries) GetLatestSequenceId(ctx context.Context, originatorNodeID int32) (int64, error)

func (*Queries) GetNextAvailableNonce added in v0.3.0

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

func (*Queries) GetPayerUnsettledUsage added in v0.3.0

func (q *Queries) GetPayerUnsettledUsage(ctx context.Context, arg GetPayerUnsettledUsageParams) (GetPayerUnsettledUsageRow, error)

func (*Queries) GetRecentOriginatorCongestion added in v0.3.0

func (q *Queries) GetRecentOriginatorCongestion(ctx context.Context, arg GetRecentOriginatorCongestionParams) ([]GetRecentOriginatorCongestionRow, error)

func (*Queries) GetSecondNewestMinute added in v0.3.0

func (q *Queries) GetSecondNewestMinute(ctx context.Context, arg GetSecondNewestMinuteParams) (GetSecondNewestMinuteRow, error)

func (*Queries) IncrementOriginatorCongestion added in v0.3.0

func (q *Queries) IncrementOriginatorCongestion(ctx context.Context, arg IncrementOriginatorCongestionParams) error

func (*Queries) IncrementUnsettledUsage added in v0.3.0

func (q *Queries) IncrementUnsettledUsage(ctx context.Context, arg IncrementUnsettledUsageParams) error

func (*Queries) InsertAddressLog

func (q *Queries) InsertAddressLog(ctx context.Context, arg InsertAddressLogParams) (int64, error)

func (*Queries) InsertBlockchainMessage added in v0.2.0

func (q *Queries) InsertBlockchainMessage(ctx context.Context, arg InsertBlockchainMessageParams) error

func (*Queries) InsertGatewayEnvelope

func (q *Queries) InsertGatewayEnvelope(ctx context.Context, arg InsertGatewayEnvelopeParams) (int64, error)

func (*Queries) InsertNodeInfo

func (q *Queries) InsertNodeInfo(ctx context.Context, arg InsertNodeInfoParams) (int64, error)

func (*Queries) InsertStagedOriginatorEnvelope

func (q *Queries) InsertStagedOriginatorEnvelope(ctx context.Context, arg InsertStagedOriginatorEnvelopeParams) (StagedOriginatorEnvelope, error)

func (*Queries) RevokeAddressFromLog

func (q *Queries) RevokeAddressFromLog(ctx context.Context, arg RevokeAddressFromLogParams) (int64, error)

func (*Queries) SelectGatewayEnvelopes

func (q *Queries) SelectGatewayEnvelopes(ctx context.Context, arg SelectGatewayEnvelopesParams) ([]GatewayEnvelope, error)

func (*Queries) SelectNodeInfo

func (q *Queries) SelectNodeInfo(ctx context.Context) (NodeInfo, error)

func (*Queries) SelectStagedOriginatorEnvelopes

func (q *Queries) SelectStagedOriginatorEnvelopes(ctx context.Context, arg SelectStagedOriginatorEnvelopesParams) ([]StagedOriginatorEnvelope, error)

func (*Queries) SelectVectorClock

func (q *Queries) SelectVectorClock(ctx context.Context) ([]SelectVectorClockRow, error)

func (*Queries) SetLatestBlock added in v0.1.1

func (q *Queries) SetLatestBlock(ctx context.Context, arg SetLatestBlockParams) error

func (*Queries) SumOriginatorCongestion added in v0.3.0

func (q *Queries) SumOriginatorCongestion(ctx context.Context, arg SumOriginatorCongestionParams) (int64, error)

func (*Queries) UpdateBlocksCanonicalityInRange added in v0.2.0

func (q *Queries) UpdateBlocksCanonicalityInRange(ctx context.Context, arg UpdateBlocksCanonicalityInRangeParams) error

func (*Queries) WithTx

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

type RevokeAddressFromLogParams

type RevokeAddressFromLogParams struct {
	RevocationSequenceID sql.NullInt64
	Address              string
	InboxID              string
}

type SelectGatewayEnvelopesParams

type SelectGatewayEnvelopesParams struct {
	CursorNodeIds     []int32
	CursorSequenceIds []int64
	Topics            [][]byte
	OriginatorNodeIds []int32
	RowLimit          int32
}

type SelectStagedOriginatorEnvelopesParams

type SelectStagedOriginatorEnvelopesParams struct {
	LastSeenID int64
	NumRows    int32
}

type SelectVectorClockRow

type SelectVectorClockRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	OriginatorEnvelope   []byte
}

type SetLatestBlockParams added in v0.1.1

type SetLatestBlockParams struct {
	ContractAddress string
	BlockNumber     int64
	BlockHash       []byte
}

type StagedOriginatorEnvelope

type StagedOriginatorEnvelope struct {
	ID             int64
	OriginatorTime time.Time
	Topic          []byte
	PayerEnvelope  []byte
}

type SumOriginatorCongestionParams added in v0.3.0

type SumOriginatorCongestionParams struct {
	OriginatorID        int32
	MinutesSinceEpochGt int64
	MinutesSinceEpochLt int64
}

type UnsettledUsage added in v0.3.0

type UnsettledUsage struct {
	PayerID           int32
	OriginatorID      int32
	MinutesSinceEpoch int32
	SpendPicodollars  int64
	LastSequenceID    int64
}

type UpdateBlocksCanonicalityInRangeParams added in v0.2.0

type UpdateBlocksCanonicalityInRangeParams struct {
	StartBlockNumber uint64
	EndBlockNumber   uint64
}

Jump to

Keyboard shortcuts

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