initstats

Documentation

Index

• Variables
• type RangeWorker
  • func NewRangeWorker(taskName string, dealFunc func(task Task) error, maxTid, initStatsStep uint64, ...) *RangeWorker
  • func (ls *RangeWorker) LoadStats()
  • func (ls *RangeWorker) SendTask(task Task)
  • func (ls *RangeWorker) Wait()
• type Task

Variables

var InitStatsPercentage atomicutil.Float64

InitStatsPercentage is the percentage of the table to load stats.

Types

type RangeWorker

type RangeWorker struct {
	// contains filtered or unexported fields
}

RangeWorker is used to load stats concurrently by the range of table id.

func NewRangeWorker

func NewRangeWorker(taskName string, dealFunc func(task Task) error, maxTid, initStatsStep uint64, totalPercentageStep float64) *RangeWorker

NewRangeWorker creates a new RangeWorker.

func (*RangeWorker) LoadStats

func (ls *RangeWorker) LoadStats()

LoadStats loads stats concurrently when to init stats

func (*RangeWorker) SendTask

func (ls *RangeWorker) SendTask(task Task)

SendTask sends a task to the load stats worker.

func (*RangeWorker) Wait

func (ls *RangeWorker) Wait()

Wait closes the load stats worker.

type Task

type Task struct {
	StartTid int64
	EndTid   int64
}

Task represents the range of the table for loading stats.