Documentation
¶
Index ¶
- type AddressLog
- type BlockchainMessage
- type BuildPayerReportParams
- type BuildPayerReportRow
- type ClearUnsettledUsageParams
- type DBTX
- type DeleteExpiredEnvelopesBatchRow
- type EnsureGatewayPartsParams
- type FetchAttestationsParams
- type FetchAttestationsRow
- type FetchPayerReportsParams
- type FetchPayerReportsRow
- type FillNonceSequenceParams
- type GatewayEnvelopeBlob
- type GatewayEnvelopesLatest
- type GatewayEnvelopesMetum
- type GatewayEnvelopesView
- type GetAddressLogsRow
- type GetGatewayEnvelopeByIDParams
- type GetLastEventParams
- type GetLastSequenceIDForOriginatorMinuteParams
- type GetLatestBlockRow
- type GetPayerInfoReportParams
- type GetPayerInfoReportRow
- type GetPayerUnsettledUsageParams
- type GetPayerUnsettledUsageRow
- type GetRecentOriginatorCongestionParams
- type GetRecentOriginatorCongestionRow
- type GetSecondNewestMinuteParams
- type GetSecondNewestMinuteRow
- type IncrementOriginatorCongestionParams
- type IncrementUnsettledUsageParams
- type InsertAddressLogParams
- type InsertGatewayEnvelopeParams
- type InsertGatewayEnvelopeRow
- type InsertNodeInfoParams
- type InsertOrIgnorePayerReportAttestationParams
- type InsertOrIgnorePayerReportParams
- type InsertPayerLedgerEventParams
- type InsertStagedOriginatorEnvelopeParams
- type LatestBlock
- type MakeBlobSeqBandParams
- type MakeMetaSeqBandParams
- type MigrationTracker
- type NodeInfo
- type NonceTable
- type OriginatorCongestion
- type Payer
- type PayerLedgerEvent
- type PayerReport
- type PayerReportAttestation
- type Queries
- func (q *Queries) AdvisoryLockWithKey(ctx context.Context, lockingKey int64) error
- func (q *Queries) BuildPayerReport(ctx context.Context, arg BuildPayerReportParams) ([]BuildPayerReportRow, error)
- func (q *Queries) ClearUnsettledUsage(ctx context.Context, arg ClearUnsettledUsageParams) error
- func (q *Queries) CountExpiredEnvelopes(ctx context.Context) (int64, error)
- func (q *Queries) DeleteAvailableNonce(ctx context.Context, nonce int64) (int64, error)
- func (q *Queries) DeleteExpiredEnvelopesBatch(ctx context.Context, batchSize int32) ([]DeleteExpiredEnvelopesBatchRow, error)
- func (q *Queries) DeleteObsoleteNonces(ctx context.Context, nonce int64) (int64, error)
- func (q *Queries) DeleteStagedOriginatorEnvelope(ctx context.Context, id int64) (int64, error)
- func (q *Queries) EnsureGatewayParts(ctx context.Context, arg EnsureGatewayPartsParams) error
- func (q *Queries) FetchAttestations(ctx context.Context, arg FetchAttestationsParams) ([]FetchAttestationsRow, error)
- func (q *Queries) FetchPayerReport(ctx context.Context, id []byte) (PayerReport, error)
- func (q *Queries) FetchPayerReportLocked(ctx context.Context, id []byte) (PayerReport, error)
- func (q *Queries) FetchPayerReports(ctx context.Context, arg FetchPayerReportsParams) ([]FetchPayerReportsRow, error)
- func (q *Queries) FillNonceSequence(ctx context.Context, arg FillNonceSequenceParams) (int32, error)
- func (q *Queries) FindOrCreatePayer(ctx context.Context, address string) (int32, error)
- func (q *Queries) GetAddressLogs(ctx context.Context, addresses []string) ([]GetAddressLogsRow, error)
- func (q *Queries) GetGatewayEnvelopeByID(ctx context.Context, arg GetGatewayEnvelopeByIDParams) (GatewayEnvelopesView, error)
- func (q *Queries) GetLastEvent(ctx context.Context, arg GetLastEventParams) (PayerLedgerEvent, error)
- func (q *Queries) GetLastSequenceIDForOriginatorMinute(ctx context.Context, arg GetLastSequenceIDForOriginatorMinuteParams) (int64, error)
- func (q *Queries) GetLatestBlock(ctx context.Context, contractAddress string) (GetLatestBlockRow, error)
- func (q *Queries) GetLatestSequenceId(ctx context.Context, originatorNodeID int32) (int64, error)
- func (q *Queries) GetMigrationProgress(ctx context.Context, sourceTable string) (int64, error)
- func (q *Queries) GetNextAvailableNonce(ctx context.Context) (int64, error)
- func (q *Queries) GetPayerBalance(ctx context.Context, payerID int32) (int64, error)
- func (q *Queries) GetPayerByAddress(ctx context.Context, address string) (int32, error)
- func (q *Queries) GetPayerInfoReport(ctx context.Context, arg GetPayerInfoReportParams) ([]GetPayerInfoReportRow, error)
- func (q *Queries) GetPayerUnsettledUsage(ctx context.Context, arg GetPayerUnsettledUsageParams) (GetPayerUnsettledUsageRow, error)
- func (q *Queries) GetRecentOriginatorCongestion(ctx context.Context, arg GetRecentOriginatorCongestionParams) ([]GetRecentOriginatorCongestionRow, error)
- func (q *Queries) GetSecondNewestMinute(ctx context.Context, arg GetSecondNewestMinuteParams) (GetSecondNewestMinuteRow, error)
- func (q *Queries) IncrementOriginatorCongestion(ctx context.Context, arg IncrementOriginatorCongestionParams) error
- func (q *Queries) IncrementUnsettledUsage(ctx context.Context, arg IncrementUnsettledUsageParams) error
- func (q *Queries) InsertAddressLog(ctx context.Context, arg InsertAddressLogParams) (int64, error)
- func (q *Queries) InsertGatewayEnvelope(ctx context.Context, arg InsertGatewayEnvelopeParams) (InsertGatewayEnvelopeRow, error)
- func (q *Queries) InsertNodeInfo(ctx context.Context, arg InsertNodeInfoParams) (int64, error)
- func (q *Queries) InsertOrIgnorePayerReport(ctx context.Context, arg InsertOrIgnorePayerReportParams) (int64, error)
- func (q *Queries) InsertOrIgnorePayerReportAttestation(ctx context.Context, arg InsertOrIgnorePayerReportAttestationParams) error
- func (q *Queries) InsertPayerLedgerEvent(ctx context.Context, arg InsertPayerLedgerEventParams) error
- func (q *Queries) InsertSavePoint(ctx context.Context) error
- func (q *Queries) InsertSavePointRelease(ctx context.Context) error
- func (q *Queries) InsertSavePointRollback(ctx context.Context) error
- func (q *Queries) InsertStagedOriginatorEnvelope(ctx context.Context, arg InsertStagedOriginatorEnvelopeParams) (StagedOriginatorEnvelope, error)
- func (q *Queries) MakeBlobOriginatorPart(ctx context.Context, originatorNodeID int32) error
- func (q *Queries) MakeBlobSeqBand(ctx context.Context, arg MakeBlobSeqBandParams) error
- func (q *Queries) MakeMetaOriginatorPart(ctx context.Context, originatorNodeID int32) error
- func (q *Queries) MakeMetaSeqBand(ctx context.Context, arg MakeMetaSeqBandParams) error
- func (q *Queries) RevokeAddressFromLog(ctx context.Context, arg RevokeAddressFromLogParams) (int64, error)
- func (q *Queries) SelectGatewayEnvelopesByOriginators(ctx context.Context, arg SelectGatewayEnvelopesByOriginatorsParams) ([]SelectGatewayEnvelopesByOriginatorsRow, error)
- func (q *Queries) SelectGatewayEnvelopesByTopics(ctx context.Context, arg SelectGatewayEnvelopesByTopicsParams) ([]SelectGatewayEnvelopesByTopicsRow, error)
- func (q *Queries) SelectGatewayEnvelopesUnfiltered(ctx context.Context, arg SelectGatewayEnvelopesUnfilteredParams) ([]GatewayEnvelopesView, error)
- func (q *Queries) SelectNewestFromTopics(ctx context.Context, topics [][]byte) ([]SelectNewestFromTopicsRow, error)
- func (q *Queries) SelectNodeInfo(ctx context.Context) (NodeInfo, error)
- func (q *Queries) SelectStagedOriginatorEnvelopes(ctx context.Context, arg SelectStagedOriginatorEnvelopesParams) ([]StagedOriginatorEnvelope, error)
- func (q *Queries) SelectVectorClock(ctx context.Context) ([]GatewayEnvelopesLatest, error)
- func (q *Queries) SetLatestBlock(ctx context.Context, arg SetLatestBlockParams) error
- func (q *Queries) SetReportAttestationStatus(ctx context.Context, arg SetReportAttestationStatusParams) error
- func (q *Queries) SetReportSubmissionStatus(ctx context.Context, arg SetReportSubmissionStatusParams) error
- func (q *Queries) SetReportSubmitted(ctx context.Context, arg SetReportSubmittedParams) error
- func (q *Queries) SumOriginatorCongestion(ctx context.Context, arg SumOriginatorCongestionParams) (int64, error)
- func (q *Queries) UpdateMigrationProgress(ctx context.Context, arg UpdateMigrationProgressParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RevokeAddressFromLogParams
- type SelectGatewayEnvelopesByOriginatorsParams
- type SelectGatewayEnvelopesByOriginatorsRow
- type SelectGatewayEnvelopesByTopicsParams
- type SelectGatewayEnvelopesByTopicsRow
- type SelectGatewayEnvelopesUnfilteredParams
- type SelectNewestFromTopicsRow
- type SelectStagedOriginatorEnvelopesParams
- type SetLatestBlockParams
- type SetReportAttestationStatusParams
- type SetReportSubmissionStatusParams
- type SetReportSubmittedParams
- type StagedOriginatorEnvelope
- type SumOriginatorCongestionParams
- type UnsettledUsage
- type UpdateMigrationProgressParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddressLog ¶
type BlockchainMessage ¶ added in v0.2.0
type BuildPayerReportParams ¶ added in v0.3.0
type BuildPayerReportRow ¶ added in v0.3.0
type ClearUnsettledUsageParams ¶ added in v0.5.1
type DeleteExpiredEnvelopesBatchRow ¶ added in v0.4.0
type EnsureGatewayPartsParams ¶ added in v1.0.0
type FetchAttestationsParams ¶ added in v0.5.0
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 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 GatewayEnvelopeBlob ¶ added in v1.0.0
type GatewayEnvelopesLatest ¶ added in v1.0.0
type GatewayEnvelopesMetum ¶ added in v1.0.0
type GatewayEnvelopesView ¶ added in v1.0.0
type GetAddressLogsRow ¶
type GetGatewayEnvelopeByIDParams ¶ added in v0.3.0
type GetLastEventParams ¶ added in v0.5.1
type GetLastSequenceIDForOriginatorMinuteParams ¶ added in v0.5.0
type GetLatestBlockRow ¶ added in v0.2.0
type GetPayerInfoReportParams ¶ added in v0.5.0
type GetPayerInfoReportParams struct {
GroupBy interface{}
PayerID int32
}
type GetPayerInfoReportRow ¶ added in v0.5.0
type GetPayerUnsettledUsageParams ¶ added in v0.3.0
type GetPayerUnsettledUsageRow ¶ added in v0.3.0
type GetRecentOriginatorCongestionParams ¶ added in v0.3.0
type GetRecentOriginatorCongestionRow ¶ added in v0.3.0
type GetSecondNewestMinuteParams ¶ added in v0.3.0
type GetSecondNewestMinuteRow ¶ added in v0.3.0
type IncrementOriginatorCongestionParams ¶ added in v0.3.0
type IncrementUnsettledUsageParams ¶ added in v0.3.0
type InsertAddressLogParams ¶
type InsertGatewayEnvelopeRow ¶ added in v1.0.0
type InsertNodeInfoParams ¶
type InsertOrIgnorePayerReportAttestationParams ¶ added in v0.5.0
type InsertOrIgnorePayerReportParams ¶ added in v0.5.0
type InsertPayerLedgerEventParams ¶ added in v0.5.1
type LatestBlock ¶ added in v0.1.1
type MakeBlobSeqBandParams ¶ added in v1.0.0
type MakeMetaSeqBandParams ¶ added in v1.0.0
type MigrationTracker ¶ added in v0.5.0
type NonceTable ¶ added in v0.3.0
type OriginatorCongestion ¶ added in v0.3.0
type PayerLedgerEvent ¶ added in v0.5.1
type PayerReport ¶ added in v0.5.0
type PayerReportAttestation ¶ added in v0.5.0
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AdvisoryLockWithKey ¶ added in v1.0.0
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 (*Queries) DeleteAvailableNonce ¶ added in v0.3.0
func (*Queries) DeleteExpiredEnvelopesBatch ¶ added in v0.4.0
func (*Queries) DeleteObsoleteNonces ¶ added in v0.3.0
func (*Queries) DeleteStagedOriginatorEnvelope ¶
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 (*Queries) FetchPayerReportLocked ¶ added in v1.0.0
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 (*Queries) FindOrCreatePayer ¶ added in v0.3.0
func (*Queries) GetAddressLogs ¶
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 (*Queries) GetLatestBlock ¶ added in v0.1.1
func (*Queries) GetLatestSequenceId ¶
func (*Queries) GetMigrationProgress ¶ added in v0.5.0
Migration Tracker Operations
func (*Queries) GetNextAvailableNonce ¶ added in v0.3.0
func (*Queries) GetPayerBalance ¶ added in v0.5.1
func (*Queries) GetPayerByAddress ¶ added in v0.5.0
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) 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 (*Queries) InsertGatewayEnvelope ¶
func (q *Queries) InsertGatewayEnvelope(ctx context.Context, arg InsertGatewayEnvelopeParams) (InsertGatewayEnvelopeRow, error)
func (*Queries) InsertNodeInfo ¶
func (*Queries) InsertOrIgnorePayerReport ¶ added in v0.5.0
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 (*Queries) InsertSavePointRelease ¶ added in v1.0.0
func (*Queries) InsertSavePointRollback ¶ added in v1.0.0
func (*Queries) InsertStagedOriginatorEnvelope ¶
func (q *Queries) InsertStagedOriginatorEnvelope(ctx context.Context, arg InsertStagedOriginatorEnvelopeParams) (StagedOriginatorEnvelope, error)
func (*Queries) MakeBlobOriginatorPart ¶ added in v1.0.0
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 (*Queries) MakeMetaSeqBand ¶ added in v1.0.0
func (q *Queries) MakeMetaSeqBand(ctx context.Context, arg MakeMetaSeqBandParams) error
func (*Queries) RevokeAddressFromLog ¶
func (*Queries) SelectGatewayEnvelopesByOriginators ¶ added in v1.0.0
func (q *Queries) SelectGatewayEnvelopesByOriginators(ctx context.Context, arg SelectGatewayEnvelopesByOriginatorsParams) ([]SelectGatewayEnvelopesByOriginatorsRow, error)
func (*Queries) SelectGatewayEnvelopesByTopics ¶ added in v1.0.0
func (q *Queries) SelectGatewayEnvelopesByTopics(ctx context.Context, arg SelectGatewayEnvelopesByTopicsParams) ([]SelectGatewayEnvelopesByTopicsRow, error)
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 (*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 (*Queries) UpdateMigrationProgress ¶ added in v0.5.0
func (q *Queries) UpdateMigrationProgress(ctx context.Context, arg UpdateMigrationProgressParams) error
type SelectGatewayEnvelopesByOriginatorsParams ¶ added in v1.0.0
type SelectGatewayEnvelopesByOriginatorsRow ¶ added in v1.0.0
type SelectGatewayEnvelopesByTopicsParams ¶ added in v1.0.0
type SelectGatewayEnvelopesByTopicsRow ¶ added in v1.0.0
type SelectGatewayEnvelopesUnfilteredParams ¶ added in v1.0.0
type SelectNewestFromTopicsRow ¶ added in v1.0.0
type SetLatestBlockParams ¶ added in v0.1.1
type SetReportAttestationStatusParams ¶ added in v0.5.0
type SetReportSubmissionStatusParams ¶ added in v0.5.1
type SetReportSubmittedParams ¶ added in v1.0.0
type SumOriginatorCongestionParams ¶ added in v0.3.0
type UnsettledUsage ¶ added in v0.3.0
type UpdateMigrationProgressParams ¶ added in v0.5.0
Click to show internal directories.
Click to hide internal directories.