Documentation
¶
Index ¶
- Constants
- type Control
- 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
Constants ¶
View Source
const ( MetricProduceProcessedCountKey = "produce_records_processed" MetricProduceSuccessCountKey = "produce_records_success" MetricProduceFailureCountKey = "produce_records_failure" MetricConsumeProcessedCountKey = "consume_records_processed" MetricConsumeProcessMillisCounterKey = "consume_records_process_millis" MetricConsumeSuccessCountKey = "consume_records_success" MetricConsumeFailureCountKey = "consume_records_failure" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Control ¶
type Control struct {
Services cfg.Services
ServicesCfg cfg.Config
Chains map[string]cfg.Chain `json:"chains"`
Log logging.Logger
Persist db.Persist
Features map[string]struct{}
BalanceManager utils.ExecIface
GenesisContainer *utils.GenesisContainer
IsAccumulateBalanceIndexer bool
IsAccumulateBalanceReader bool
IsDisableBootstrap bool
IsAggregateCache bool
IsCChainIndex bool
IndexedList utils.IndexedList
LocalTxPool chan *LocalTxPoolJob
}
func (*Control) DatabaseRO ¶
func (s *Control) DatabaseRO() (*utils.Connections, error)
func (*Control) InitConsumeMetrics ¶
func (s *Control) InitConsumeMetrics()
func (*Control) InitProduceMetrics ¶
func (s *Control) InitProduceMetrics()
type LocalTxPoolJob ¶
type LocalTxPoolJob struct {
TxPool *db.TxPool
Errs *avlancheGoUtils.AtomicInterface
}
Source Files
Click to show internal directories.
Click to hide internal directories.