Versions in this module Expand all Collapse all v2 v2.0.1 Jun 3, 2020 Changes in this version + var ErrNotFound = errors.New("ledger not found") + func StreamChanges(changeProcessor ChangeProcessor, reader ChangeReader) error + func StreamLedgerTransactions(txProcessor LedgerTransactionProcessor, reader LedgerReader) error + type Change struct + Post *xdr.LedgerEntry + Pre *xdr.LedgerEntry + Type xdr.LedgerEntryType + func (c *Change) AccountChangedExceptSigners() (bool, error) + func (c *Change) AccountSignersChanged() bool + func (c *Change) LedgerEntryChangeType() xdr.LedgerEntryChangeType + type ChangeProcessor interface + ProcessChange func(change Change) error + type ChangeReader interface + Close func() error + Read func() (Change, error) + type DBLedgerReader struct + func NewDBLedgerReader(ctx context.Context, sequence uint32, backend ledgerbackend.LedgerBackend) (*DBLedgerReader, error) + func (dblrc *DBLedgerReader) Close() error + func (dblrc *DBLedgerReader) GetHeader() xdr.LedgerHeaderHistoryEntry + func (dblrc *DBLedgerReader) GetSequence() uint32 + func (dblrc *DBLedgerReader) Read() (LedgerTransaction, error) + type GenesisLedgerStateReader struct + NetworkPassphrase string + func (r *GenesisLedgerStateReader) Close() error + func (r *GenesisLedgerStateReader) Read() (Change, error) + type LedgerChangeReader struct + func NewLedgerChangeReader(ctx context.Context, sequence uint32, backend ledgerbackend.LedgerBackend) (*LedgerChangeReader, error) + func (r *LedgerChangeReader) Close() error + func (r *LedgerChangeReader) GetHeader() xdr.LedgerHeaderHistoryEntry + func (r *LedgerChangeReader) Read() (Change, error) + type LedgerEntryChangeCache struct + func NewLedgerEntryChangeCache() *LedgerEntryChangeCache + func (c *LedgerEntryChangeCache) AddChange(change Change) error + func (c *LedgerEntryChangeCache) GetChanges() []Change + func (c *LedgerEntryChangeCache) Size() int + type LedgerReader interface + Close func() error + GetHeader func() xdr.LedgerHeaderHistoryEntry + GetSequence func() uint32 + Read func() (LedgerTransaction, error) + type LedgerTransaction struct + Envelope xdr.TransactionEnvelope + FeeChanges xdr.LedgerEntryChanges + Index uint32 + Meta xdr.TransactionMeta + Result xdr.TransactionResultPair + func (t *LedgerTransaction) GetChanges() ([]Change, error) + func (t *LedgerTransaction) GetFeeChanges() []Change + func (t *LedgerTransaction) GetOperationChanges(operationIndex uint32) ([]Change, error) + type LedgerTransactionProcessor interface + ProcessTransaction func(transaction LedgerTransaction) error + type MockChangeProcessor struct + func (m *MockChangeProcessor) ProcessChange(change Change) error + type MockChangeReader struct + func (m *MockChangeReader) Close() error + func (m *MockChangeReader) Read() (Change, error) + type MockLedgerReader struct + func (m *MockLedgerReader) Close() error + func (m *MockLedgerReader) GetHeader() xdr.LedgerHeaderHistoryEntry + func (m *MockLedgerReader) GetSequence() uint32 + func (m *MockLedgerReader) GetUpgradeChanges() []Change + func (m *MockLedgerReader) IgnoreUpgradeChanges() + func (m *MockLedgerReader) Read() (LedgerTransaction, error) + func (m *MockLedgerReader) ReadUpgradeChange() (Change, error) + type MockLedgerTransactionProcessor struct + func (m *MockLedgerTransactionProcessor) ProcessTransaction(transaction LedgerTransaction) error + type SingleLedgerStateReader struct + func MakeSingleLedgerStateReader(ctx context.Context, archive historyarchive.ArchiveInterface, sequence uint32, ...) (*SingleLedgerStateReader, error) + func (msr *SingleLedgerStateReader) Close() error + func (msr *SingleLedgerStateReader) Read() (Change, error) + type StatsChangeProcessor struct + func (p *StatsChangeProcessor) GetResults() StatsChangeProcessorResults + func (p *StatsChangeProcessor) ProcessChange(change Change) error + type StatsChangeProcessorResults struct + AccountsCreated int64 + AccountsRemoved int64 + AccountsUpdated int64 + DataCreated int64 + DataRemoved int64 + DataUpdated int64 + OffersCreated int64 + OffersRemoved int64 + OffersUpdated int64 + TrustLinesCreated int64 + TrustLinesRemoved int64 + TrustLinesUpdated int64 + func (stats *StatsChangeProcessorResults) Map() map[string]interface{} + type StatsLedgerTransactionProcessor struct + func (p *StatsLedgerTransactionProcessor) GetResults() StatsLedgerTransactionProcessorResults + func (p *StatsLedgerTransactionProcessor) ProcessTransaction(transaction LedgerTransaction) error + type StatsLedgerTransactionProcessorResults struct + Operations int64 + OperationsAccountMerge int64 + OperationsAllowTrust int64 + OperationsBumpSequence int64 + OperationsChangeTrust int64 + OperationsCreateAccount int64 + OperationsCreatePassiveSellOffer int64 + OperationsInFailed int64 + OperationsInSuccessful int64 + OperationsInflation int64 + OperationsManageBuyOffer int64 + OperationsManageData int64 + OperationsManageSellOffer int64 + OperationsPathPaymentStrictReceive int64 + OperationsPathPaymentStrictSend int64 + OperationsPayment int64 + OperationsSetOptions int64 + Transactions int64 + TransactionsFailed int64 + TransactionsSuccessful int64 + func (stats *StatsLedgerTransactionProcessorResults) Map() map[string]interface{}