Documentation
¶
Index ¶
- type AddressLog
- type BlockchainMessage
- type BuildPayerReportParams
- type BuildPayerReportRow
- type DBTX
- type FillNonceSequenceParams
- type GatewayEnvelope
- type GetAddressLogsRow
- type GetBlocksInRangeParams
- type GetBlocksInRangeRow
- type GetGatewayEnvelopeByIDParams
- type GetLatestBlockRow
- type GetLatestCursorRow
- type GetPayerUnsettledUsageParams
- type GetPayerUnsettledUsageRow
- type GetRecentOriginatorCongestionParams
- type GetRecentOriginatorCongestionRow
- type GetSecondNewestMinuteParams
- type GetSecondNewestMinuteRow
- type IncrementOriginatorCongestionParams
- type IncrementUnsettledUsageParams
- type InsertAddressLogParams
- type InsertBlockchainMessageParams
- type InsertGatewayEnvelopeParams
- type InsertNodeInfoParams
- type InsertStagedOriginatorEnvelopeParams
- type LatestBlock
- type NodeInfo
- type NonceTable
- type OriginatorCongestion
- type Payer
- type Queries
- func (q *Queries) BuildPayerReport(ctx context.Context, arg BuildPayerReportParams) ([]BuildPayerReportRow, error)
- func (q *Queries) DeleteAvailableNonce(ctx context.Context, nonce int64) (int64, 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) 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) GetBlocksInRange(ctx context.Context, arg GetBlocksInRangeParams) ([]GetBlocksInRangeRow, error)
- func (q *Queries) GetGatewayEnvelopeByID(ctx context.Context, arg GetGatewayEnvelopeByIDParams) (GatewayEnvelope, error)
- func (q *Queries) GetLatestBlock(ctx context.Context, contractAddress string) (GetLatestBlockRow, error)
- func (q *Queries) GetLatestCursor(ctx context.Context) ([]GetLatestCursorRow, error)
- func (q *Queries) GetLatestSequenceId(ctx context.Context, originatorNodeID int32) (int64, error)
- func (q *Queries) GetNextAvailableNonce(ctx context.Context) (int64, 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) InsertBlockchainMessage(ctx context.Context, arg InsertBlockchainMessageParams) error
- func (q *Queries) InsertGatewayEnvelope(ctx context.Context, arg InsertGatewayEnvelopeParams) (int64, error)
- func (q *Queries) InsertNodeInfo(ctx context.Context, arg InsertNodeInfoParams) (int64, error)
- func (q *Queries) InsertStagedOriginatorEnvelope(ctx context.Context, arg InsertStagedOriginatorEnvelopeParams) (StagedOriginatorEnvelope, error)
- func (q *Queries) RevokeAddressFromLog(ctx context.Context, arg RevokeAddressFromLogParams) (int64, error)
- func (q *Queries) SelectGatewayEnvelopes(ctx context.Context, arg SelectGatewayEnvelopesParams) ([]GatewayEnvelope, 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) ([]SelectVectorClockRow, error)
- func (q *Queries) SetLatestBlock(ctx context.Context, arg SetLatestBlockParams) error
- func (q *Queries) SumOriginatorCongestion(ctx context.Context, arg SumOriginatorCongestionParams) (int64, error)
- func (q *Queries) UpdateBlocksCanonicalityInRange(ctx context.Context, arg UpdateBlocksCanonicalityInRangeParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RevokeAddressFromLogParams
- type SelectGatewayEnvelopesParams
- type SelectStagedOriginatorEnvelopesParams
- type SelectVectorClockRow
- type SetLatestBlockParams
- type StagedOriginatorEnvelope
- type SumOriginatorCongestionParams
- type UnsettledUsage
- type UpdateBlocksCanonicalityInRangeParams
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 FillNonceSequenceParams ¶ added in v0.3.0
type GatewayEnvelope ¶
type GetAddressLogsRow ¶
type GetBlocksInRangeParams ¶ added in v0.2.0
type GetBlocksInRangeRow ¶ added in v0.2.0
type GetGatewayEnvelopeByIDParams ¶ added in v0.3.0
type GetLatestBlockRow ¶ added in v0.2.0
type GetLatestCursorRow ¶ added in v0.2.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 InsertBlockchainMessageParams ¶ added in v0.2.0
type InsertNodeInfoParams ¶
type LatestBlock ¶ added in v0.1.1
type NonceTable ¶ added in v0.3.0
type OriginatorCongestion ¶ added in v0.3.0
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
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 (*Queries) DeleteObsoleteNonces ¶ added in v0.3.0
func (*Queries) DeleteStagedOriginatorEnvelope ¶
func (*Queries) FillNonceSequence ¶ added in v0.3.0
func (*Queries) FindOrCreatePayer ¶ added in v0.3.0
func (*Queries) GetAddressLogs ¶
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 (*Queries) GetLatestCursor ¶ added in v0.2.0
func (q *Queries) GetLatestCursor(ctx context.Context) ([]GetLatestCursorRow, error)
func (*Queries) GetLatestSequenceId ¶
func (*Queries) GetNextAvailableNonce ¶ added in v0.3.0
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) InsertBlockchainMessage ¶ added in v0.2.0
func (q *Queries) InsertBlockchainMessage(ctx context.Context, arg InsertBlockchainMessageParams) error
func (*Queries) InsertGatewayEnvelope ¶
func (*Queries) InsertNodeInfo ¶
func (*Queries) InsertStagedOriginatorEnvelope ¶
func (q *Queries) InsertStagedOriginatorEnvelope(ctx context.Context, arg InsertStagedOriginatorEnvelopeParams) (StagedOriginatorEnvelope, error)
func (*Queries) RevokeAddressFromLog ¶
func (*Queries) SelectGatewayEnvelopes ¶
func (q *Queries) SelectGatewayEnvelopes(ctx context.Context, arg SelectGatewayEnvelopesParams) ([]GatewayEnvelope, error)
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) ([]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 (*Queries) UpdateBlocksCanonicalityInRange ¶ added in v0.2.0
func (q *Queries) UpdateBlocksCanonicalityInRange(ctx context.Context, arg UpdateBlocksCanonicalityInRangeParams) error
type SelectVectorClockRow ¶
type SetLatestBlockParams ¶ added in v0.1.1
type SumOriginatorCongestionParams ¶ added in v0.3.0
type UnsettledUsage ¶ added in v0.3.0
type UpdateBlocksCanonicalityInRangeParams ¶ added in v0.2.0
Click to show internal directories.
Click to hide internal directories.