analyzer

Documentation

Index

• Variables
• type EpochTask
• type MonitorTasks
• type StateAnalyzer
  • func NewStateAnalyzer(pCtx context.Context, httpCli *clientapi.APIClient, initSlot uint64, ...) (*StateAnalyzer, error)
  • func (s *StateAnalyzer) Close()
  • func (s *StateAnalyzer) Run()
• type ValTask

Variables

var (
	MAX_VAL_BATCH_SIZE = 20000
	VAL_LEN            = 400000
	SLOT_SECONDS       = 12
	EPOCH_SLOTS        = 32
)

Types

type EpochTask

type EpochTask struct {
	ValIdxs     []uint64
	NextState   fork_state.ForkStateContentBase
	State       fork_state.ForkStateContentBase
	PrevState   fork_state.ForkStateContentBase
	OnlyPrevAtt bool
}

type MonitorTasks

type MonitorTasks struct {
	ValIdxs []uint64
	Slot    uint64
}

type StateAnalyzer

type StateAnalyzer struct {
	InitSlot           uint64
	FinalSlot          uint64
	ValidatorIndexes   []uint64
	SlotRanges         []uint64
	MonitorSlotProcess map[uint64]uint64
	EpochTaskChan      chan *EpochTask
	ValTaskChan        chan *ValTask
	// contains filtered or unexported fields
}

func NewStateAnalyzer

func NewStateAnalyzer(
	pCtx context.Context,
	httpCli *clientapi.APIClient,
	initSlot uint64,
	finalSlot uint64,
	valIdxs []uint64,
	idbUrl string,
	workerNum int,
	dbWorkerNum int) (*StateAnalyzer, error)

func (*StateAnalyzer) Close

func (s *StateAnalyzer) Close()

func (*StateAnalyzer) Run

func (s *StateAnalyzer) Run()

type ValTask

type ValTask struct {
	ValIdxs         []uint64
	StateMetricsObj fork_metrics.StateMetrics
	OnlyPrevAtt     bool
}