servicesctrl

package
v0.0.0-...-201df52 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2023 License: BSD-3-Clause Imports: 6 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL