bulk_load

type BatchProcessor interface {
	PrepareProcess(i int)
	RunProcess(i int, waitGroup *sync.WaitGroup, telemetryPoints chan *report.Point, reportTags [][2]string) error
	AfterRunProcess(i int)
	EmptyBatchChanel()
}

type BulkLoad interface {
	Init()
	Validate()
	CreateDb()
	PrepareWorkers()
	GetBatchProcessor() BatchProcessor
	GetScanner() Scanner
	SyncEnd()
	CleanUp()
	UpdateReport(params *report.LoadReportParams) (reportTags [][2]string, extraVals []report.ExtraVal)
}

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

type LoadRunner struct {
	DbName    string
	Workers   int
	ItemLimit int64
	BatchSize int
	TimeLimit time.Duration

	DoLoad         bool
	DoDBCreate     bool
	DoAbortOnExist bool

	StatPool sync.Pool
	StatChan chan *Stat
	// contains filtered or unexported fields
}

type NotifyHandler func(arg int) (int, error)

type NotifyReceiver struct {
}

type Scanner interface {
	RunScanner(r io.Reader, syncChanDone chan int)
	IsScanFinished() bool
	GetReadStatistics() (itemsRead, bytesRead, valuesRead int64)
}

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

type Stat struct {
	Label []byte
	Value float64
}

type StatGroup struct {
	Min  float64
	Max  float64
	Mean float64
	Sum  float64

	Count int64
}