Versions in this module Expand all Collapse all v0 v0.1.0 Jan 28, 2021 Changes in this version + func StreamChanges(changeProcessor ChangeProcessor, reader ingest.ChangeReader) error + func StreamLedgerTransactions(txProcessor LedgerTransactionProcessor, reader *ingest.LedgerTransactionReader) error + type AccountDataProcessor struct + func NewAccountDataProcessor(dataQ history.QData) *AccountDataProcessor + func (p *AccountDataProcessor) Commit() error + func (p *AccountDataProcessor) ProcessChange(change ingest.Change) error + type AccountsProcessor struct + func NewAccountsProcessor(accountsQ history.QAccounts) *AccountsProcessor + func (p *AccountsProcessor) Commit() error + func (p *AccountsProcessor) ProcessChange(change ingest.Change) error + type AssetStatSet map[assetStatKey]*assetStatValue + 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 struct + func NewAssetStatsProcessor(assetStatsQ history.QAssetStats, useLedgerEntryCache bool) *AssetStatsProcessor + func (p *AssetStatsProcessor) Commit() error + func (p *AssetStatsProcessor) ProcessChange(change ingest.Change) error + type ChangeProcessor interface + ProcessChange func(change ingest.Change) error + type ClaimableBalancesProcessor struct + func NewClaimableBalancesProcessor(Q history.QClaimableBalances) *ClaimableBalancesProcessor + func (p *ClaimableBalancesProcessor) Commit() error + func (p *ClaimableBalancesProcessor) ProcessChange(change ingest.Change) error + type EffectProcessor struct + func NewEffectProcessor(effectsQ history.QEffects, sequence uint32) *EffectProcessor + func (p *EffectProcessor) Commit() (err error) + func (p *EffectProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) (err error) + type LedgerTransactionProcessor interface + ProcessTransaction func(transaction ingest.LedgerTransaction) error + type LedgersProcessor struct + func NewLedgerProcessor(ledgerQ history.QLedgers, ledger xdr.LedgerHeaderHistoryEntry, ...) *LedgersProcessor + func (p *LedgersProcessor) Commit() error + func (p *LedgersProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) (err error) + type MockChangeProcessor struct + func (m *MockChangeProcessor) ProcessChange(change ingest.Change) error + type OffersProcessor struct + func NewOffersProcessor(offersQ history.QOffers, sequence uint32) *OffersProcessor + func (p *OffersProcessor) Commit() error + func (p *OffersProcessor) ProcessChange(change ingest.Change) error + type OperationProcessor struct + func NewOperationProcessor(operationsQ history.QOperations, sequence uint32) *OperationProcessor + func (p *OperationProcessor) Commit() error + func (p *OperationProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) error + type ParticipantsProcessor struct + func NewParticipantsProcessor(participantsQ history.QParticipants, sequence uint32) *ParticipantsProcessor + func (p *ParticipantsProcessor) Commit() (err error) + func (p *ParticipantsProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) (err error) + type SignersProcessor struct + func NewSignersProcessor(signersQ history.QSigners, useLedgerEntryCache bool) *SignersProcessor + func (p *SignersProcessor) Commit() error + func (p *SignersProcessor) ProcessChange(change ingest.Change) error + type StatsLedgerTransactionProcessor struct + func (p *StatsLedgerTransactionProcessor) GetResults() StatsLedgerTransactionProcessorResults + func (p *StatsLedgerTransactionProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) error + type StatsLedgerTransactionProcessorResults struct + Operations int64 + OperationsAccountMerge int64 + OperationsAllowTrust int64 + OperationsBeginSponsoringFutureReserves int64 + OperationsBumpSequence int64 + OperationsChangeTrust int64 + OperationsClaimClaimableBalance int64 + OperationsCreateAccount int64 + OperationsCreateClaimableBalance int64 + OperationsCreatePassiveSellOffer int64 + OperationsEndSponsoringFutureReserves int64 + OperationsInFailed int64 + OperationsInSuccessful int64 + OperationsInflation int64 + OperationsManageBuyOffer int64 + OperationsManageData int64 + OperationsManageSellOffer int64 + OperationsPathPaymentStrictReceive int64 + OperationsPathPaymentStrictSend int64 + OperationsPayment int64 + OperationsRevokeSponsorship int64 + OperationsSetOptions int64 + Transactions int64 + TransactionsFailed int64 + TransactionsSuccessful int64 + func (stats *StatsLedgerTransactionProcessorResults) Map() map[string]interface{} + type TradeProcessor struct + func NewTradeProcessor(tradesQ history.QTrades, ledger xdr.LedgerHeaderHistoryEntry) *TradeProcessor + func (p *TradeProcessor) Commit() error + func (p *TradeProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) (err error) + type TransactionProcessor struct + func NewTransactionProcessor(transactionsQ history.QTransactions, sequence uint32) *TransactionProcessor + func (p *TransactionProcessor) Commit() error + func (p *TransactionProcessor) ProcessTransaction(transaction ingest.LedgerTransaction) error + type TrustLinesProcessor struct + func NewTrustLinesProcessor(trustLinesQ history.QTrustLines) *TrustLinesProcessor + func (p *TrustLinesProcessor) Commit() error + func (p *TrustLinesProcessor) ProcessChange(change ingest.Change) error