servicesctrl

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

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"
)

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) Database

func (s *Control) Database() (*utils.Connections, error)

func (*Control) DatabaseRO

func (s *Control) DatabaseRO() (*utils.Connections, error)

func (*Control) Enqueue

func (s *Control) Enqueue(pool *db.TxPool)

func (*Control) Init

func (s *Control) Init(networkID uint32) error

func (*Control) InitConsumeMetrics

func (s *Control) InitConsumeMetrics()

func (*Control) InitProduceMetrics

func (s *Control) InitProduceMetrics()

func (*Control) Logger

func (s *Control) Logger() logging.Logger

type LocalTxPoolJob

type LocalTxPoolJob struct {
	TxPool *db.TxPool
	Errs   *avlancheGoUtils.AtomicInterface
}