scheduler

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

type Scheduler interface {
	// ResetWorkloads resets the workloads info of the capture
	ResetWorkloads(captureID model.CaptureID, workloads model.TaskWorkload)
	// AlignCapture makes sure that the workloads of the capture is matched with the specified captureIDs
	AlignCapture(captureIDs map[model.CaptureID]struct{})
	// Skewness returns the skewness
	Skewness() float64
	// CalRebalanceOperates calculates the rebalance operates
	// returns  * the skewness after rebalance
	//          * the move jobs need by rebalance
	CalRebalanceOperates(targetSkewness float64) (
		skewness float64, moveKeySpanJobs map[model.KeySpanID]*model.MoveKeySpanJob)
	// DistributeKeySpans distributes the new keyspans to the captures
	// returns the operations of the new keyspans
	DistributeKeySpans(keyspanIDs map[model.KeySpanID]model.Ts) map[model.CaptureID]map[model.KeySpanID]*model.KeySpanOperation
}