Versions in this module Expand all Collapse all v0 v0.0.1 Nov 25, 2022 Changes in this version + func EncodeOfferId(id uint64, typ OfferIDType) int64 + func ParticipantsForTransaction(sequence uint32, transaction ingest.LedgerTransaction) ([]xdr.AccountId, error) + func PoolIDToString(id xdr.PoolId) string + func StreamChanges(ctx context.Context, changeProcessor ChangeProcessor, ...) error + func StreamLedgerTransactions(ctx context.Context, txFilterer LedgerTransactionFilterer, ...) error + type AccountDataProcessor struct + func NewAccountDataProcessor(dataQ history.QData) *AccountDataProcessor + func (p *AccountDataProcessor) Commit(ctx context.Context) error + func (p *AccountDataProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type AccountsProcessor struct + func NewAccountsProcessor(accountsQ history.QAccounts) *AccountsProcessor + func (p *AccountsProcessor) Commit(ctx context.Context) error + func (p *AccountsProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type AssetStatSet map[assetStatKey]*assetStatValue + func (s AssetStatSet) AddClaimableBalance(change ingest.Change) error + func (s AssetStatSet) AddLiquidityPool(change ingest.Change) error + func (s AssetStatSet) AddTrustline(change ingest.Change) 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(ctx context.Context) error + func (p *AssetStatsProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type ChangeProcessor interface + ProcessChange func(ctx context.Context, change ingest.Change) error + type ClaimableBalancesChangeProcessor struct + func NewClaimableBalancesChangeProcessor(Q history.QClaimableBalances) *ClaimableBalancesChangeProcessor + func (p *ClaimableBalancesChangeProcessor) Commit(ctx context.Context) error + func (p *ClaimableBalancesChangeProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type ClaimableBalancesTransactionProcessor struct + func NewClaimableBalancesTransactionProcessor(Q history.QHistoryClaimableBalances, sequence uint32) *ClaimableBalancesTransactionProcessor + func (p *ClaimableBalancesTransactionProcessor) Commit(ctx context.Context) error + func (p *ClaimableBalancesTransactionProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) error + type EffectProcessor struct + func NewEffectProcessor(effectsQ history.QEffects, sequence uint32) *EffectProcessor + func (p *EffectProcessor) Commit(ctx context.Context) (err error) + func (p *EffectProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) (err error) + type LedgerTransactionFilterer interface + FilterTransaction func(ctx context.Context, transaction ingest.LedgerTransaction) (bool, error) + type LedgerTransactionProcessor interface + ProcessTransaction func(ctx context.Context, transaction ingest.LedgerTransaction) error + type LedgersProcessor struct + func NewLedgerProcessor(ledgerQ history.QLedgers, ledger xdr.LedgerHeaderHistoryEntry, ...) *LedgersProcessor + func (p *LedgersProcessor) Commit(ctx context.Context) error + func (p *LedgersProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) (err error) + type LiquidityPoolsChangeProcessor struct + func NewLiquidityPoolsChangeProcessor(Q history.QLiquidityPools, sequence uint32) *LiquidityPoolsChangeProcessor + func (p *LiquidityPoolsChangeProcessor) Commit(ctx context.Context) error + func (p *LiquidityPoolsChangeProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type LiquidityPoolsTransactionProcessor struct + func NewLiquidityPoolsTransactionProcessor(Q history.QHistoryLiquidityPools, sequence uint32) *LiquidityPoolsTransactionProcessor + func (p *LiquidityPoolsTransactionProcessor) Commit(ctx context.Context) error + func (p *LiquidityPoolsTransactionProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) error + type MockChangeProcessor struct + func (m *MockChangeProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type OfferIDType uint64 + const CoreOfferIDType + const TOIDType + func DecodeOfferID(encodedId int64) (uint64, OfferIDType) + type OffersProcessor struct + func NewOffersProcessor(offersQ history.QOffers, sequence uint32) *OffersProcessor + func (p *OffersProcessor) Commit(ctx context.Context) error + func (p *OffersProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type OperationProcessor struct + func NewOperationProcessor(operationsQ history.QOperations, sequence uint32) *OperationProcessor + func (p *OperationProcessor) Commit(ctx context.Context) error + func (p *OperationProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) error + type ParticipantsProcessor struct + func NewParticipantsProcessor(participantsQ history.QParticipants, sequence uint32) *ParticipantsProcessor + func (p *ParticipantsProcessor) Commit(ctx context.Context) (err error) + func (p *ParticipantsProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) (err error) + type SignersProcessor struct + func NewSignersProcessor(signersQ history.QSigners, useLedgerEntryCache bool) *SignersProcessor + func (p *SignersProcessor) Commit(ctx context.Context) error + func (p *SignersProcessor) ProcessChange(ctx context.Context, change ingest.Change) error + type StatsLedgerTransactionProcessor struct + func (p *StatsLedgerTransactionProcessor) GetResults() StatsLedgerTransactionProcessorResults + func (p *StatsLedgerTransactionProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) error + type StatsLedgerTransactionProcessorResults struct + Operations int64 + OperationsAccountMerge int64 + OperationsAllowTrust int64 + OperationsBeginSponsoringFutureReserves int64 + OperationsBumpSequence int64 + OperationsChangeTrust int64 + OperationsClaimClaimableBalance int64 + OperationsClawback int64 + OperationsClawbackClaimableBalance int64 + OperationsCreateAccount int64 + OperationsCreateClaimableBalance int64 + OperationsCreatePassiveSellOffer int64 + OperationsEndSponsoringFutureReserves int64 + OperationsInFailed int64 + OperationsInSuccessful int64 + OperationsInflation int64 + OperationsLiquidityPoolDeposit int64 + OperationsLiquidityPoolWithdraw int64 + OperationsManageBuyOffer int64 + OperationsManageData int64 + OperationsManageSellOffer int64 + OperationsPathPaymentStrictReceive int64 + OperationsPathPaymentStrictSend int64 + OperationsPayment int64 + OperationsRevokeSponsorship int64 + OperationsSetOptions int64 + OperationsSetTrustLineFlags int64 + Transactions int64 + TransactionsFailed int64 + TransactionsFiltered 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(ctx context.Context) error + func (p *TradeProcessor) GetStats() TradeStats + func (p *TradeProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) (err error) + type TradeStats struct + func (stats *TradeStats) Map() map[string]interface{} + type TransactionProcessor struct + func NewTransactionFilteredTmpProcessor(transactionsQ history.QTransactions, sequence uint32) *TransactionProcessor + func NewTransactionProcessor(transactionsQ history.QTransactions, sequence uint32) *TransactionProcessor + func (p *TransactionProcessor) Commit(ctx context.Context) error + func (p *TransactionProcessor) ProcessTransaction(ctx context.Context, transaction ingest.LedgerTransaction) error + type TrustLinesProcessor struct + func NewTrustLinesProcessor(trustLinesQ history.QTrustLines) *TrustLinesProcessor + func (p *TrustLinesProcessor) Commit(ctx context.Context) error + func (p *TrustLinesProcessor) ProcessChange(ctx context.Context, change ingest.Change) error