Versions in this module Expand all Collapse all v0 v0.1.0 Jan 28, 2021 Changes in this version + const CurrentVersion + const MaxDBConnections + const MaxSupportedProtocolVersion + var ErrReingestRangeConflict = errors.New("reingest range overlaps with horizon ingestion") + type Config struct + CaptiveCoreBinaryPath string + CaptiveCoreConfigAppendPath string + CaptiveCoreHTTPPort uint + CheckpointFrequency uint32 + CoreSession *db.Session + DisableStateVerification bool + EnableCaptiveCore bool + HistoryArchiveURL string + HistorySession *db.Session + MaxReingestRetries int + NetworkPassphrase string + ReingestRetryBackoffSeconds int + RemoteCaptiveCoreURL string + StellarCoreCursor string + StellarCoreURL string + type Metrics struct + LedgerIngestionDuration prometheus.Summary + LedgerStatsCounter *prometheus.CounterVec + ProcessorsRunDuration *prometheus.CounterVec + StateInvalidGauge prometheus.GaugeFunc + StateVerifyDuration prometheus.Summary + type OrderBookStream struct + LatestLedgerGauge prometheus.Gauge + func NewOrderBookStream(historyQ history.IngestionQ, graph orderbook.OBGraph) *OrderBookStream + func (o *OrderBookStream) Run(ctx context.Context) + func (o *OrderBookStream) Update() error + type ParallelSystems struct + func NewParallelSystems(config Config, workerCount uint) (*ParallelSystems, error) + func (ps *ParallelSystems) ReingestRange(fromLedger, toLedger uint32, batchSizeSuggestion uint32) error + type ProcessorRunner struct + func (s *ProcessorRunner) DisableMemoryStatsLogging() + func (s *ProcessorRunner) EnableMemoryStatsLogging() + func (s *ProcessorRunner) RunAllProcessorsOnLedger(sequence uint32) (changeStats ingest.StatsChangeProcessorResults, ...) + func (s *ProcessorRunner) RunHistoryArchiveIngestion(checkpointLedger uint32) (ingest.StatsChangeProcessorResults, error) + func (s *ProcessorRunner) RunTransactionProcessorsOnLedger(ledger uint32) (transactionStats processors.StatsLedgerTransactionProcessorResults, ...) + func (s *ProcessorRunner) SetHistoryAdapter(historyAdapter historyArchiveAdapterInterface) + func (s *ProcessorRunner) SetLedgerBackend(ledgerBackend ledgerbackend.LedgerBackend) + type ProcessorRunnerInterface interface + DisableMemoryStatsLogging func() + EnableMemoryStatsLogging func() + RunAllProcessorsOnLedger func(sequence uint32) (changeStats ingest.StatsChangeProcessorResults, ...) + RunHistoryArchiveIngestion func(checkpointLedger uint32) (ingest.StatsChangeProcessorResults, error) + RunTransactionProcessorsOnLedger func(sequence uint32) (transactionStats processors.StatsLedgerTransactionProcessorResults, ...) + SetHistoryAdapter func(historyAdapter historyArchiveAdapterInterface) + SetLedgerBackend func(ledgerBackend ledgerbackend.LedgerBackend) + type System interface + BuildGenesisState func() error + Metrics func() Metrics + ReingestRange func(fromLedger, toLedger uint32, force bool) error + Run func() + Shutdown func() + StressTest func(numTransactions, changesPerTransaction int) error + VerifyRange func(fromLedger, toLedger uint32, verifyState bool) error + func NewSystem(config Config) (System, error)