runner

Documentation

Index

• func NewRaftLogGCTaskHandler() *raftLogGCTaskHandler
• func NewRegionTaskHandler(engines *engine_util.Engines, mgr *snap.SnapManager) *regionTaskHandler
• func NewSplitCheckHandler(engine *badger.DB, router message.RaftRouter, conf *config.Config) *splitCheckHandler
• type RaftLogGCTask
• type RegionTaskApply
• type RegionTaskDestroy
• type RegionTaskGen
• type SchedulerAskSplitTask
• type SchedulerRegionHeartbeatTask
• type SchedulerStoreHeartbeatTask
• type SchedulerTaskHandler
  • func NewSchedulerTaskHandler(storeID uint64, SchedulerClient scheduler_client.Client, ...) *SchedulerTaskHandler
  • func (r *SchedulerTaskHandler) Handle(t worker.Task)
  • func (r *SchedulerTaskHandler) Start()
• type SplitCheckTask

Functions

func NewRaftLogGCTaskHandler

func NewRaftLogGCTaskHandler() *raftLogGCTaskHandler

func NewRegionTaskHandler

func NewRegionTaskHandler(engines *engine_util.Engines, mgr *snap.SnapManager) *regionTaskHandler

func NewSplitCheckHandler

func NewSplitCheckHandler(engine *badger.DB, router message.RaftRouter, conf *config.Config) *splitCheckHandler

Types

type RaftLogGCTask

type RaftLogGCTask struct {
	RaftEngine *badger.DB
	RegionID   uint64
	StartIdx   uint64
	EndIdx     uint64
}

type RegionTaskApply

type RegionTaskApply struct {
	RegionId uint64                    // specify the region which the task is for.
	Notifier chan<- bool               // when it finishes snapshot applying, it notifies notifier.
	SnapMeta *eraftpb.SnapshotMetadata // the region meta information of the snapshot
	StartKey []byte                    // `StartKey` and `EndKey` are origin region's range, it's used to clean up certain range of region before applying snapshot.
	EndKey   []byte
}

type RegionTaskDestroy

type RegionTaskDestroy struct {
	RegionId uint64 // specify the region which the task is for.
	StartKey []byte // `StartKey` and `EndKey` are used to destroy certain range of region.
	EndKey   []byte
}

type RegionTaskGen

type RegionTaskGen struct {
	RegionId uint64                   // specify the region which the task is for.
	Notifier chan<- *eraftpb.Snapshot // when it finishes snapshot generating, it notifies notifier.
}

type SchedulerAskSplitTask

type SchedulerAskSplitTask struct {
	Region   *metapb.Region
	SplitKey []byte
	Peer     *metapb.Peer
	Callback *message.Callback
}

type SchedulerRegionHeartbeatTask

type SchedulerRegionHeartbeatTask struct {
	Region          *metapb.Region
	Peer            *metapb.Peer
	PendingPeers    []*metapb.Peer
	ApproximateSize *uint64
}

type SchedulerStoreHeartbeatTask

type SchedulerStoreHeartbeatTask struct {
	Stats  *schedulerpb.StoreStats
	Engine *badger.DB
	Path   string
}

type SchedulerTaskHandler

type SchedulerTaskHandler struct {
	SchedulerClient scheduler_client.Client
	// contains filtered or unexported fields
}

func NewSchedulerTaskHandler

func NewSchedulerTaskHandler(storeID uint64, SchedulerClient scheduler_client.Client, router message.RaftRouter) *SchedulerTaskHandler

func (*SchedulerTaskHandler) Handle

func (r *SchedulerTaskHandler) Handle(t worker.Task)

func (*SchedulerTaskHandler) Start

func (r *SchedulerTaskHandler) Start()

type SplitCheckTask

type SplitCheckTask struct {
	Region *metapb.Region
}