Versions in this module Expand all Collapse all v1 v1.1.0 Jun 24, 2022 v1.0.0 Jun 19, 2022 Changes in this version + const MetricConsumeFailureCountKey + const MetricConsumeProcessMillisCounterKey + const MetricConsumeProcessedCountKey + const MetricConsumeSuccessCountKey + const MetricProduceFailureCountKey + const MetricProduceProcessedCountKey + const MetricProduceSuccessCountKey + type Control struct + BalanceManager utils.ExecIface + Chains map[string]cfg.Chain + Features map[string]struct{} + GenesisContainer *utils.GenesisContainer + IndexedList utils.IndexedList + IsAccumulateBalanceIndexer bool + IsAccumulateBalanceReader bool + IsAggregateCache bool + IsCChainIndex bool + IsDisableBootstrap bool + LocalTxPool chan *LocalTxPoolJob + Log logging.Logger + Persist db.Persist + Services cfg.Services + ServicesCfg cfg.Config + func (s *Control) Database() (*utils.Connections, error) + func (s *Control) DatabaseRO() (*utils.Connections, error) + func (s *Control) Enqueue(pool *db.TxPool) + func (s *Control) Init(networkID uint32) error + func (s *Control) InitConsumeMetrics() + func (s *Control) InitProduceMetrics() + func (s *Control) Logger() logging.Logger + type LocalTxPoolJob struct + Errs *avlancheGoUtils.AtomicInterface + TxPool *db.TxPool