splitter

Documentation

Index

• type RegionSplitter
  • func NewRegionSplitter(cluster sche.ClusterInformer, handler SplitRegionsHandler, ...) *RegionSplitter
  • func (r *RegionSplitter) SplitRegions(ctx context.Context, splitKeys [][]byte, retryLimit int) (int, []uint64)
• type SplitRegionsHandler
  • func NewSplitRegionsHandler(cluster sche.ClusterInformer, oc *operator.Controller) SplitRegionsHandler

Types

type RegionSplitter

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

RegionSplitter handles split regions

func NewRegionSplitter

func NewRegionSplitter(cluster sche.ClusterInformer, handler SplitRegionsHandler, addSuspectRegions func(bool, ...uint64)) *RegionSplitter

NewRegionSplitter return a region splitter

func (*RegionSplitter) SplitRegions

func (r *RegionSplitter) SplitRegions(ctx context.Context, splitKeys [][]byte, retryLimit int) (int, []uint64)

SplitRegions support splitRegions by given split keys.

type SplitRegionsHandler

type SplitRegionsHandler interface {
	SplitRegionByKeys(region *core.RegionInfo, splitKeys [][]byte) error
	ScanRegionsByKeyRange(groupKeys *regionGroupKeys, results *splitKeyResults)
}

SplitRegionsHandler used to handle region splitting

func NewSplitRegionsHandler

func NewSplitRegionsHandler(cluster sche.ClusterInformer, oc *operator.Controller) SplitRegionsHandler

NewSplitRegionsHandler return SplitRegionsHandler