Documentation
¶
Index ¶
- type AccountDataProcessor
- type AccountsProcessor
- type AssetStatSet
- func (s AssetStatSet) Add(trustLine xdr.TrustLineEntry) error
- func (s AssetStatSet) AddDelta(asset xdr.Asset, deltaBalance int64, deltaAccounts int32) error
- func (s AssetStatSet) All() []history.ExpAssetStat
- func (s AssetStatSet) Remove(assetType xdr.AssetType, assetCode string, assetIssuer string) (history.ExpAssetStat, bool)
- type AssetStatsProcessor
- type EffectProcessor
- type LedgersProcessor
- type OffersProcessor
- type OperationProcessor
- type ParticipantsProcessor
- type SignersProcessor
- type TradeProcessor
- type TransactionProcessor
- type TrustLinesProcessor
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) 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
Source Files
¶
- account_data_processor.go
- accounts_processor.go
- asset_stats_processor.go
- asset_stats_set.go
- effects_processor.go
- ledgers_processor.go
- main.go
- offers_processor.go
- operations_processor.go
- participants_processor.go
- signers_processor.go
- trades_processor.go
- transactions_processor.go
- trust_lines_processor.go
Click to show internal directories.
Click to hide internal directories.