worker

Documentation

Index

• type Worker
  • func NewWorker(cfg *config.Config, name string, ig ingester.DatabendIngester, ...) *Worker
  • func (w *Worker) IsSplitAccordingMaxGoRoutine(minSplitKey, maxSplitKey, batchSize int) bool
  • func (w *Worker) IsWorkerCorrect() (int, int, bool)
  • func (w *Worker) Run(ctx context.Context)
  • func (w *Worker) StepBatchByTimeSplitKey() error

Types

type Worker

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

func NewWorker

func NewWorker(cfg *config.Config, name string, ig ingester.DatabendIngester, src *source.Source) *Worker

func (*Worker) IsSplitAccordingMaxGoRoutine

func (w *Worker) IsSplitAccordingMaxGoRoutine(minSplitKey, maxSplitKey, batchSize int) bool

func (*Worker) IsWorkerCorrect

func (w *Worker) IsWorkerCorrect() (int, int, bool)

func (*Worker) Run

func (w *Worker) Run(ctx context.Context)

func (*Worker) StepBatchByTimeSplitKey

func (w *Worker) StepBatchByTimeSplitKey() error