Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker represents a worker with given labels and resource quotas
func (*Worker) GetDesiredState ¶
func (w *Worker) GetDesiredState() <-chan common.DesiredState
GetDesiredState returns a channel which provides desired task state. It's caller's responsibility to calculate state diffs and change real world state.
func (*Worker) Run ¶
func (w *Worker) Run()
Run runs worker routine loop to watch task assignment changes.
func (*Worker) SetTaskStatus ¶
func (w *Worker) SetTaskStatus(uuid string, status *pb.TaskStatus) error
SetTaskStatus sets user-defined status, which can be read by master. Note that status is bound to current worker, and will be invalidated on task reassignment.
Source Files
Click to show internal directories.
Click to hide internal directories.