Documentation
¶
Index ¶
Constants ¶
View Source
const CHANGE_NUM_CROSS = math.MaxInt32
Variables ¶
This section is empty.
Functions ¶
func StartScheduleJob ¶
func StartScheduleJob(ctx context.Context, service *service.BaseService)
the job check range infos and fix it
Types ¶
type BalanceJob ¶
type BalanceJob struct {
// contains filtered or unexported fields
}
check master distribution check range num in diff node is balanced , one job only move one range
type FailoverJob ¶
type FailoverJob struct {
// contains filtered or unexported fields
}
it check range num when not equal table.replica it will create or delete range to node
type MonitorJob ¶
type MonitorJob struct {
// contains filtered or unexported fields
}
type ProcessJob ¶
type ProcessJob interface {
// contains filtered or unexported methods
}
type RangeTypeJob ¶
type RangeTypeJob struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.