Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrTaskTerminal ¶
type ErrTaskTerminal struct {
// contains filtered or unexported fields
}
func (ErrTaskTerminal) Error ¶
func (e ErrTaskTerminal) Error() string
type State ¶
type State struct {
// contains filtered or unexported fields
}
State is an in-memory structure for keeping track of tasks. The State is updated when provided a mesos.TaskStatus via the Update method. If a task is encounted that was not specified during the creation of State it will panic.
func (*State) Pop ¶
Pending returns the next task waiting to be scheduled. If a returned task is not scheduled the caller must return via Append or the Task will be lost.
func (*State) Update ¶
func (s *State) Update(status mesos.TaskStatus)
Update places the TaskStatus into the updates channel
Source Files
Click to show internal directories.
Click to hide internal directories.