Documentation ¶
Index ¶
- func DiffTaskState(old common.DesiredState, new common.DesiredState) ([]string, []string, []string)
- func DiffWorkerState(old common.WorkerTableView, new common.WorkerTableView) ([]string, []string, []string)
- func GetPort(endpoint string) int
- func RandomBackoff()
- func UpdateWorkerStatus(added bool, clone bool, wStatus *pb.WorkerStatus, task *pb.Task) *pb.WorkerStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DiffTaskState ¶
func DiffTaskState(old common.DesiredState, new common.DesiredState) ([]string, []string, []string)
DiffTaskState picks out what added/deleted/changed between old DesiredState and new DesiredState.
func DiffWorkerState ¶
func DiffWorkerState(old common.WorkerTableView, new common.WorkerTableView) ([]string, []string, []string)
DiffWorkerState picks out what added/deleted/changed between old WorkerTableView and new WorkerTableView.
func UpdateWorkerStatus ¶
func UpdateWorkerStatus(added bool, clone bool, wStatus *pb.WorkerStatus, task *pb.Task) *pb.WorkerStatus
UpdateWorkerStatus updates worker's status when task added or removed.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.