processors

package
v2.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 3, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountDataProcessor

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

func NewAccountDataProcessor

func NewAccountDataProcessor(dataQ history.QData) *AccountDataProcessor

func (*AccountDataProcessor) Commit

func (p *AccountDataProcessor) Commit() error

func (*AccountDataProcessor) ProcessChange

func (p *AccountDataProcessor) ProcessChange(change io.Change) error

type AccountsProcessor

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

func NewAccountsProcessor

func NewAccountsProcessor(accountsQ history.QAccounts) *AccountsProcessor

func (*AccountsProcessor) Commit

func (p *AccountsProcessor) Commit() error

func (*AccountsProcessor) ProcessChange

func (p *AccountsProcessor) ProcessChange(change io.Change) error

type AssetStatSet

type AssetStatSet map[assetStatKey]*assetStatValue

AssetStatSet represents a collection of asset stats

func (AssetStatSet) Add

func (s AssetStatSet) Add(trustLine xdr.TrustLineEntry) error

Add updates the set with a trustline entry from a history archive snapshot if the trustline is authorized.

func (AssetStatSet) AddDelta

func (s AssetStatSet) AddDelta(asset xdr.Asset, deltaBalance int64, deltaAccounts int32) error

AddDelta adds a delta balance and delta accounts to a given asset.

func (AssetStatSet) All

func (s AssetStatSet) All() []history.ExpAssetStat

All returns a list of all `history.ExpAssetStat` contained within the set

func (AssetStatSet) Remove

func (s AssetStatSet) Remove(assetType xdr.AssetType, assetCode string, assetIssuer string) (history.ExpAssetStat, bool)

Remove deletes an asset stat from the set

type AssetStatsProcessor

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

func NewAssetStatsProcessor

func NewAssetStatsProcessor(
	assetStatsQ history.QAssetStats,
	useLedgerEntryCache bool,
) *AssetStatsProcessor

NewAssetStatsProcessor constructs a new AssetStatsProcessor instance. If useLedgerEntryCache is false we don't use ledger cache and we just add trust lines to assetStatSet, then we insert all the stats in one insert query. This is done to make history buckets processing faster (batch inserting).

func (*AssetStatsProcessor) Commit

func (p *AssetStatsProcessor) Commit() error

func (*AssetStatsProcessor) ProcessChange

func (p *AssetStatsProcessor) ProcessChange(change io.Change) error

type EffectProcessor

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

EffectProcessor process effects

func NewEffectProcessor

func NewEffectProcessor(effectsQ history.QEffects, sequence uint32) *EffectProcessor

func (*EffectProcessor) Commit

func (p *EffectProcessor) Commit() (err error)

func (*EffectProcessor) ProcessTransaction

func (p *EffectProcessor) ProcessTransaction(transaction io.LedgerTransaction) (err error)

type LedgersProcessor

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

func NewLedgerProcessor

func NewLedgerProcessor(
	ledgerQ history.QLedgers,
	ledger xdr.LedgerHeaderHistoryEntry,
	ingestVersion int,
) *LedgersProcessor

func (*LedgersProcessor) Commit

func (p *LedgersProcessor) Commit() error

func (*LedgersProcessor) ProcessTransaction

func (p *LedgersProcessor) ProcessTransaction(transaction io.LedgerTransaction) (err error)

type OffersProcessor

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

func NewOffersProcessor

func NewOffersProcessor(offersQ history.QOffers, sequence uint32) *OffersProcessor

func (*OffersProcessor) Commit

func (p *OffersProcessor) Commit() error

func (*OffersProcessor) ProcessChange

func (p *OffersProcessor) ProcessChange(change io.Change) error

type OperationProcessor

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

OperationProcessor operations processor

func NewOperationProcessor

func NewOperationProcessor(operationsQ history.QOperations, sequence uint32) *OperationProcessor

func (*OperationProcessor) Commit

func (p *OperationProcessor) Commit() error

func (*OperationProcessor) ProcessTransaction

func (p *OperationProcessor) ProcessTransaction(transaction io.LedgerTransaction) (err error)

ProcessTransaction process the given transaction

type ParticipantsProcessor

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

ParticipantsProcessor is a processor which ingests various participants from different sources (transactions, operations, etc)

func NewParticipantsProcessor

func NewParticipantsProcessor(participantsQ history.QParticipants, sequence uint32) *ParticipantsProcessor

func (*ParticipantsProcessor) Commit

func (p *ParticipantsProcessor) Commit() (err error)

func (*ParticipantsProcessor) ProcessTransaction

func (p *ParticipantsProcessor) ProcessTransaction(transaction io.LedgerTransaction) (err error)

type SignersProcessor

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

func NewSignersProcessor

func NewSignersProcessor(
	signersQ history.QSigners, useLedgerEntryCache bool,
) *SignersProcessor

func (*SignersProcessor) Commit

func (p *SignersProcessor) Commit() error

func (*SignersProcessor) ProcessChange

func (p *SignersProcessor) ProcessChange(change io.Change) error

type TradeProcessor

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

TradeProcessor operations processor

func NewTradeProcessor

func NewTradeProcessor(tradesQ history.QTrades, ledger xdr.LedgerHeaderHistoryEntry) *TradeProcessor

func (*TradeProcessor) Commit

func (p *TradeProcessor) Commit() error

func (*TradeProcessor) ProcessTransaction

func (p *TradeProcessor) ProcessTransaction(transaction io.LedgerTransaction) (err error)

ProcessTransaction process the given transaction

type TransactionProcessor

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

func NewTransactionProcessor

func NewTransactionProcessor(transactionsQ history.QTransactions, sequence uint32) *TransactionProcessor

func (*TransactionProcessor) Commit

func (p *TransactionProcessor) Commit() error

func (*TransactionProcessor) ProcessTransaction

func (p *TransactionProcessor) ProcessTransaction(transaction io.LedgerTransaction) error

type TrustLinesProcessor

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

func NewTrustLinesProcessor

func NewTrustLinesProcessor(trustLinesQ history.QTrustLines) *TrustLinesProcessor

func (*TrustLinesProcessor) Commit

func (p *TrustLinesProcessor) Commit() error

func (*TrustLinesProcessor) ProcessChange

func (p *TrustLinesProcessor) ProcessChange(change io.Change) error

Jump to

Keyboard shortcuts

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