Versions in this module Expand all Collapse all v0 v0.3.9 Jan 27, 2026 Changes in this version + var AlreadyIngestBytes = 0 + var AlreadyIngestRows = 0 + type DatabendWorkerStatsData struct + BytesPerSecond float64 + RowsPerSecond float64 + type DatabendWorkerStatsRecorder struct + func NewDatabendWorkerStatsRecorder() *DatabendWorkerStatsRecorder + func (stats *DatabendWorkerStatsRecorder) RecordMetric(bytes int, rows int) + func (stats *DatabendWorkerStatsRecorder) Stats(statsWindow time.Duration) DatabendWorkerStatsData + type Worker struct + Cfg *config.Config + Ig ingester.DatabendIngester + Name string + Src source.Sourcer + func NewWorker(cfg *config.Config, name string, ig ingester.DatabendIngester, ...) *Worker + func (w *Worker) IsSplitAccordingMaxGoRoutine(minSplitKey, maxSplitKey, batchSize uint64) bool + func (w *Worker) IsWorkerCorrect() (int, int, bool) + func (w *Worker) Run(ctx context.Context) + func (w *Worker) StepBatchByTimeSplitKey() error
Go to main page