runner

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

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 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 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 struct {
	Region   *metapb.Region
	SplitKey []byte
	Peer     *metapb.Peer
	Callback *message.Callback
}

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

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

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

type SplitCheckTask struct {
	Region *metapb.Region
}