queries

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Jan 13, 2026 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 ClearUnsettledUsageParams added in v0.5.1

type ClearUnsettledUsageParams struct {
	OriginatorID                  int32
	PrevReportEndMinuteSinceEpoch int32
	EndMinuteSinceEpoch           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 DeleteExpiredEnvelopesBatchRow added in v0.4.0

type DeleteExpiredEnvelopesBatchRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	Expiry               int64
}

type DeleteExpiredMigratedEnvelopesBatchRow added in v1.1.0

type DeleteExpiredMigratedEnvelopesBatchRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	Expiry               int64
}

type DeleteMigrationDeadLetterBoxParams added in v1.1.0

type DeleteMigrationDeadLetterBoxParams struct {
	SourceTable string
	SequenceID  int64
}

type EnsureGatewayPartsParams added in v1.0.0

type EnsureGatewayPartsParams struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	BandWidth            int64
}

type FetchAttestationsParams added in v0.5.0

type FetchAttestationsParams struct {
	PayerReportID  []byte
	AttesterNodeID sql.NullInt32
}

type FetchAttestationsRow added in v0.5.0

type FetchAttestationsRow struct {
	PayerReportID        []byte
	NodeID               int64
	Signature            []byte
	CreatedAt            sql.NullTime
	ID                   []byte
	OriginatorNodeID     sql.NullInt32
	StartSequenceID      sql.NullInt64
	EndSequenceID        sql.NullInt64
	EndMinuteSinceEpoch  sql.NullInt32
	PayersMerkleRoot     []byte
	ActiveNodeIds        []int32
	SubmissionStatus     sql.NullInt16
	AttestationStatus    sql.NullInt16
	CreatedAt_2          sql.NullTime
	SubmittedReportIndex sql.NullInt32
}

type FetchPayerReportsParams added in v0.5.0

type FetchPayerReportsParams struct {
	MinAttestations     sql.NullInt32
	AttestationStatusIn []int16
	SubmissionStatusIn  []int16
	CreatedAfter        sql.NullTime
	EndSequenceID       sql.NullInt64
	StartSequenceID     sql.NullInt64
	OriginatorNodeID    sql.NullInt32
	PayerReportID       []byte
}

type FetchPayerReportsRow added in v0.5.0

type FetchPayerReportsRow struct {
	ID                   []byte
	OriginatorNodeID     int32
	StartSequenceID      int64
	EndSequenceID        int64
	EndMinuteSinceEpoch  int32
	PayersMerkleRoot     []byte
	ActiveNodeIds        []int32
	SubmissionStatus     int16
	AttestationStatus    int16
	CreatedAt            sql.NullTime
	SubmittedReportIndex sql.NullInt32
	NodeID               sql.NullInt64
	Signature            []byte
	AttestationsCount    int64
}

type FillNonceSequenceParams added in v0.3.0

type FillNonceSequenceParams struct {
	PendingNonce int64
	NumElements  int32
}

type GatewayEnvelopeBlob added in v1.0.0

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

type GatewayEnvelopesLatest added in v1.0.0

type GatewayEnvelopesLatest struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	GatewayTime          time.Time
}

type GatewayEnvelopesMetum added in v1.0.0

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

type GatewayEnvelopesView added in v1.0.0

type GatewayEnvelopesView struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	GatewayTime          time.Time
	Topic                []byte
	OriginatorEnvelope   []byte
}

type GetAddressLogsRow

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

type GetGatewayEnvelopeByIDParams added in v0.3.0

type GetGatewayEnvelopeByIDParams struct {
	OriginatorSequenceID int64
	OriginatorNodeID     int32
}

type GetLastEventParams added in v0.5.1

type GetLastEventParams struct {
	PayerID   int32
	EventType int16
}

type GetLastSequenceIDForOriginatorMinuteParams added in v0.5.0

type GetLastSequenceIDForOriginatorMinuteParams struct {
	OriginatorID      int32
	MinutesSinceEpoch int32
}

type GetLatestBlockRow added in v0.2.0

type GetLatestBlockRow struct {
	BlockNumber int64
	BlockHash   []byte
}

type GetPayerInfoReportParams added in v0.5.0

type GetPayerInfoReportParams struct {
	GroupBy interface{}
	PayerID int32
}

type GetPayerInfoReportRow added in v0.5.0

type GetPayerInfoReportRow struct {
	TimePeriod            int64
	TotalSpendPicodollars int64
	TotalMessageCount     int32
}

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
	MessageCount      int32
}

type InsertAddressLogParams

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

type InsertGatewayEnvelopeParams

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

type InsertGatewayEnvelopeRow added in v1.0.0

type InsertGatewayEnvelopeRow struct {
	InsertedMetaRows  int64
	InsertedBlobRows  int64
	TotalInsertedRows int32
}

type InsertMigrationDeadLetterBoxParams added in v1.1.0

type InsertMigrationDeadLetterBoxParams struct {
	SourceTable string
	SequenceID  int64
	Payload     []byte
	Reason      string
	Retryable   bool
}

type InsertNodeInfoParams

type InsertNodeInfoParams struct {
	NodeID    int32
	PublicKey []byte
}

type InsertOrIgnorePayerReportAttestationParams added in v0.5.0

type InsertOrIgnorePayerReportAttestationParams struct {
	PayerReportID []byte
	NodeID        int64
	Signature     []byte
}

type InsertOrIgnorePayerReportParams added in v0.5.0

type InsertOrIgnorePayerReportParams struct {
	ID                  []byte
	OriginatorNodeID    int32
	StartSequenceID     int64
	EndSequenceID       int64
	EndMinuteSinceEpoch int32
	PayersMerkleRoot    []byte
	ActiveNodeIds       []int32
}

type InsertPayerLedgerEventParams added in v0.5.1

type InsertPayerLedgerEventParams struct {
	EventID           []byte
	PayerID           int32
	AmountPicodollars int64
	EventType         int16
}

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 MakeBlobSeqBandParams added in v1.0.0

type MakeBlobSeqBandParams struct {
	OriginatorNodeID int32
	BandStart        int64
	BandEnd          int64
}

type MakeMetaSeqBandParams added in v1.0.0

type MakeMetaSeqBandParams struct {
	OriginatorNodeID int32
	BandStart        int64
	BandEnd          int64
}

type MigrationDeadLetterBox added in v1.1.0

type MigrationDeadLetterBox struct {
	SourceTable string
	SequenceID  int64
	Payload     []byte
	Reason      string
	Retryable   bool
	AddedAt     time.Time
	RetriedAt   time.Time
}

type MigrationTracker added in v0.5.0

type MigrationTracker struct {
	SourceTable    string
	LastMigratedID int64
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

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 PayerLedgerEvent added in v0.5.1

type PayerLedgerEvent struct {
	EventID           []byte
	PayerID           int32
	AmountPicodollars int64
	EventType         int16
	CreatedAt         time.Time
}

type PayerReport added in v0.5.0

type PayerReport struct {
	ID                   []byte
	OriginatorNodeID     int32
	StartSequenceID      int64
	EndSequenceID        int64
	EndMinuteSinceEpoch  int32
	PayersMerkleRoot     []byte
	ActiveNodeIds        []int32
	SubmissionStatus     int16
	AttestationStatus    int16
	CreatedAt            sql.NullTime
	SubmittedReportIndex sql.NullInt32
}

type PayerReportAttestation added in v0.5.0

type PayerReportAttestation struct {
	PayerReportID []byte
	NodeID        int64
	Signature     []byte
	CreatedAt     sql.NullTime
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) AdvisoryLockWithKey added in v1.0.0

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

func (*Queries) BuildPayerReport added in v0.3.0

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

func (*Queries) ClearUnsettledUsage added in v0.5.1

func (q *Queries) ClearUnsettledUsage(ctx context.Context, arg ClearUnsettledUsageParams) error

func (*Queries) CountExpiredEnvelopes added in v0.4.0

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

func (*Queries) CountExpiredMigratedEnvelopes added in v1.1.0

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

func (*Queries) DeleteAvailableNonce added in v0.3.0

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

func (*Queries) DeleteExpiredEnvelopesBatch added in v0.4.0

func (q *Queries) DeleteExpiredEnvelopesBatch(ctx context.Context, batchSize int32) ([]DeleteExpiredEnvelopesBatchRow, error)

func (*Queries) DeleteExpiredMigratedEnvelopesBatch added in v1.1.0

func (q *Queries) DeleteExpiredMigratedEnvelopesBatch(ctx context.Context, batchSize int32) ([]DeleteExpiredMigratedEnvelopesBatchRow, error)

func (*Queries) DeleteMigrationDeadLetterBox added in v1.1.0

func (q *Queries) DeleteMigrationDeadLetterBox(ctx context.Context, arg DeleteMigrationDeadLetterBoxParams) (bool, 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) EnsureGatewayParts added in v1.0.0

func (q *Queries) EnsureGatewayParts(ctx context.Context, arg EnsureGatewayPartsParams) error

func (*Queries) FetchAttestations added in v0.5.0

func (q *Queries) FetchAttestations(ctx context.Context, arg FetchAttestationsParams) ([]FetchAttestationsRow, error)

func (*Queries) FetchPayerReport added in v0.5.1

func (q *Queries) FetchPayerReport(ctx context.Context, id []byte) (PayerReport, error)

func (*Queries) FetchPayerReportLocked added in v1.0.0

func (q *Queries) FetchPayerReportLocked(ctx context.Context, id []byte) (PayerReport, error)

func (*Queries) FetchPayerReports added in v0.5.0

func (q *Queries) FetchPayerReports(ctx context.Context, arg FetchPayerReportsParams) ([]FetchPayerReportsRow, 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) GetGatewayEnvelopeByID added in v0.3.0

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

func (*Queries) GetLastEvent added in v0.5.1

func (q *Queries) GetLastEvent(ctx context.Context, arg GetLastEventParams) (PayerLedgerEvent, error)

func (*Queries) GetLastSequenceIDForOriginatorMinute added in v0.5.0

func (q *Queries) GetLastSequenceIDForOriginatorMinute(ctx context.Context, arg GetLastSequenceIDForOriginatorMinuteParams) (int64, error)

func (*Queries) GetLatestBlock added in v0.1.1

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

func (*Queries) GetLatestSequenceId

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

func (*Queries) GetMigrationProgress added in v0.5.0

func (q *Queries) GetMigrationProgress(ctx context.Context, sourceTable string) (int64, error)

Migration Tracker Operations

func (*Queries) GetNextAvailableNonce added in v0.3.0

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

func (*Queries) GetPayerBalance added in v0.5.1

func (q *Queries) GetPayerBalance(ctx context.Context, payerID int32) (int64, error)

func (*Queries) GetPayerByAddress added in v0.5.0

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

func (*Queries) GetPayerInfoReport added in v0.5.0

func (q *Queries) GetPayerInfoReport(ctx context.Context, arg GetPayerInfoReportParams) ([]GetPayerInfoReportRow, 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) GetRetryableMigrationDeadLetterBoxes added in v1.1.0

func (q *Queries) GetRetryableMigrationDeadLetterBoxes(ctx context.Context, rowLimit int32) ([]MigrationDeadLetterBox, 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) InsertGatewayEnvelope

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

func (*Queries) InsertMigrationDeadLetterBox added in v1.1.0

func (q *Queries) InsertMigrationDeadLetterBox(ctx context.Context, arg InsertMigrationDeadLetterBoxParams) (MigrationDeadLetterBox, error)

func (*Queries) InsertNodeInfo

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

func (*Queries) InsertOrIgnorePayerReport added in v0.5.0

func (q *Queries) InsertOrIgnorePayerReport(ctx context.Context, arg InsertOrIgnorePayerReportParams) (int64, error)

func (*Queries) InsertOrIgnorePayerReportAttestation added in v0.5.0

func (q *Queries) InsertOrIgnorePayerReportAttestation(ctx context.Context, arg InsertOrIgnorePayerReportAttestationParams) error

func (*Queries) InsertPayerLedgerEvent added in v0.5.1

func (q *Queries) InsertPayerLedgerEvent(ctx context.Context, arg InsertPayerLedgerEventParams) error

func (*Queries) InsertSavePoint added in v1.0.0

func (q *Queries) InsertSavePoint(ctx context.Context) error

func (*Queries) InsertSavePointRelease added in v1.0.0

func (q *Queries) InsertSavePointRelease(ctx context.Context) error

func (*Queries) InsertSavePointRollback added in v1.0.0

func (q *Queries) InsertSavePointRollback(ctx context.Context) error

func (*Queries) InsertStagedOriginatorEnvelope

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

func (*Queries) MakeBlobOriginatorPart added in v1.0.0

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

func (*Queries) MakeBlobSeqBand added in v1.0.0

func (q *Queries) MakeBlobSeqBand(ctx context.Context, arg MakeBlobSeqBandParams) error

func (*Queries) MakeMetaOriginatorPart added in v1.0.0

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

func (*Queries) MakeMetaSeqBand added in v1.0.0

func (q *Queries) MakeMetaSeqBand(ctx context.Context, arg MakeMetaSeqBandParams) error

func (*Queries) RevokeAddressFromLog

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

func (*Queries) SelectGatewayEnvelopesByOriginators added in v1.0.0

func (*Queries) SelectGatewayEnvelopesByTopics added in v1.0.0

func (*Queries) SelectGatewayEnvelopesUnfiltered added in v1.0.0

func (q *Queries) SelectGatewayEnvelopesUnfiltered(ctx context.Context, arg SelectGatewayEnvelopesUnfilteredParams) ([]GatewayEnvelopesView, error)

func (*Queries) SelectNewestFromTopics added in v0.4.0

func (q *Queries) SelectNewestFromTopics(ctx context.Context, topics [][]byte) ([]SelectNewestFromTopicsRow, error)

TODO(mkysel) -- sorting by gateway time can lead to wrong results, this query needs to be redone

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) ([]GatewayEnvelopesLatest, error)

func (*Queries) SetLatestBlock added in v0.1.1

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

func (*Queries) SetReportAttestationStatus added in v0.5.0

func (q *Queries) SetReportAttestationStatus(ctx context.Context, arg SetReportAttestationStatusParams) error

func (*Queries) SetReportSubmissionStatus added in v0.5.1

func (q *Queries) SetReportSubmissionStatus(ctx context.Context, arg SetReportSubmissionStatusParams) error

func (*Queries) SetReportSubmitted added in v1.0.0

func (q *Queries) SetReportSubmitted(ctx context.Context, arg SetReportSubmittedParams) error

func (*Queries) SumOriginatorCongestion added in v0.3.0

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

func (*Queries) TryAdvisoryLockWithKey added in v1.1.0

func (q *Queries) TryAdvisoryLockWithKey(ctx context.Context, lockingKey int64) (bool, error)

func (*Queries) UpdateMigrationProgress added in v0.5.0

func (q *Queries) UpdateMigrationProgress(ctx context.Context, arg UpdateMigrationProgressParams) 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 SelectGatewayEnvelopesByOriginatorsParams added in v1.0.0

type SelectGatewayEnvelopesByOriginatorsParams struct {
	CursorNodeIds     []int32
	CursorSequenceIds []int64
	OriginatorNodeIds []int32
	RowLimit          int32
}

type SelectGatewayEnvelopesByOriginatorsRow added in v1.0.0

type SelectGatewayEnvelopesByOriginatorsRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	GatewayTime          time.Time
	Topic                []byte
	OriginatorEnvelope   []byte
}

type SelectGatewayEnvelopesByTopicsParams added in v1.0.0

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

type SelectGatewayEnvelopesByTopicsRow added in v1.0.0

type SelectGatewayEnvelopesByTopicsRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	GatewayTime          time.Time
	Topic                []byte
	OriginatorEnvelope   []byte
}

type SelectGatewayEnvelopesUnfilteredParams added in v1.0.0

type SelectGatewayEnvelopesUnfilteredParams struct {
	RowLimit          int32
	CursorNodeIds     []int32
	CursorSequenceIds []int64
}

type SelectNewestFromTopicsRow added in v1.0.0

type SelectNewestFromTopicsRow struct {
	OriginatorNodeID     int32
	OriginatorSequenceID int64
	GatewayTime          time.Time
	Topic                []byte
	OriginatorEnvelope   []byte
}

type SelectStagedOriginatorEnvelopesParams

type SelectStagedOriginatorEnvelopesParams struct {
	LastSeenID int64
	NumRows    int32
}

type SetLatestBlockParams added in v0.1.1

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

type SetReportAttestationStatusParams added in v0.5.0

type SetReportAttestationStatusParams struct {
	NewStatus  int16
	ReportID   []byte
	PrevStatus []int16
}

type SetReportSubmissionStatusParams added in v0.5.1

type SetReportSubmissionStatusParams struct {
	NewStatus  int16
	ReportID   []byte
	PrevStatus []int16
}

type SetReportSubmittedParams added in v1.0.0

type SetReportSubmittedParams struct {
	NewStatus            int16
	SubmittedReportIndex int32
	ReportID             []byte
	PrevStatus           []int16
}

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
	MessageCount      int32
}

type UpdateMigrationProgressParams added in v0.5.0

type UpdateMigrationProgressParams struct {
	LastMigratedID int64
	SourceTable    string
}

Jump to

Keyboard shortcuts

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