scheduler

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

type Manager interface {
	ListScheduler() []Scheduler

	Start(ctx context.Context) error

	Stop(ctx context.Context) error

	UpdateEnableSchedule(ctx context.Context, enableSchedule bool)

	// Scheduler will be called when received new heartbeat, every scheduler registered in schedulerManager will be called to generate procedures.
	// Scheduler cloud be schedule with fix time interval or heartbeat.
	Scheduler(ctx context.Context, clusterSnapshot metadata.Snapshot) []ScheduleResult
}

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

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

type ScheduleResult struct {
	Procedure procedure.Procedure
	// Scheduler will give the reason than why the procedure is generated.
	Reason string
}

type Scheduler interface {
	// Schedule will generate procedure based on current cluster snapshot, which will be submitted to ProcedureManager, and whether it is actually executed depends on the current state of ProcedureManager.
	Schedule(ctx context.Context, clusterSnapshot metadata.Snapshot) (ScheduleResult, error)
}

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