rangetask

Dec 1, 2022

Changes in this version

+ func NewLocateRegionBackoffer(ctx context.Context) *retry.Backoffer

+ type DeleteRangeTask struct

+ func NewDeleteRangeTask(store storage, startKey []byte, endKey []byte, concurrency int) *DeleteRangeTask

+ func NewNotifyDeleteRangeTask(store storage, startKey []byte, endKey []byte, concurrency int) *DeleteRangeTask

+ func (t *DeleteRangeTask) CompletedRegions() int

+ func (t *DeleteRangeTask) Execute(ctx context.Context) error

+ type Runner struct

+ func NewRangeTaskRunner(name string, store storage, concurrency int, handler TaskHandler) *Runner

+ func (s *Runner) CompletedRegions() int

+ func (s *Runner) FailedRegions() int

+ func (s *Runner) RunOnRange(ctx context.Context, startKey, endKey []byte) error

+ func (s *Runner) SetRegionsPerTask(regionsPerTask int)

+ type TaskHandler = func(ctx context.Context, r kv.KeyRange) (TaskStat, error)

+ type TaskStat struct

+ CompletedRegions int

+ FailedRegions int