task

package

v1.2.5 Latest Latest Go to latest Published: Aug 18, 2016 License: Apache-2.0, CC-BY-SA-4.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dang3r/swarm

Links

Open Source Insights

Documentation ¶

Index ¶

type Task
- func NewTask(config *cluster.ContainerConfig, name string, timeout time.Duration) (*Task, error)
type Tasks
- func NewTasks(cluster launcher) *Tasks

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Task ¶

type Task struct {
	mesosproto.TaskInfo

	Error chan error
	// contains filtered or unexported fields
}

Task struct inherits from TaskInfo and represents a mesos task

func NewTask ¶

func NewTask(config *cluster.ContainerConfig, name string, timeout time.Duration) (*Task, error)

NewTask function creates a task

func (*Task) Build ¶

func (t *Task) Build(slaveID string, offers map[string]*mesosproto.Offer)

Build method builds the task

func (*Task) GetConfig ¶

func (t *Task) GetConfig() *cluster.ContainerConfig

GetConfig returns the container configuration of the task

func (*Task) GetContainer ¶

func (t *Task) GetContainer() chan *cluster.Container

GetContainer returns the container channel from the task where the Swarm API sends the created container

func (*Task) GetStatus ¶

func (t *Task) GetStatus() *mesosproto.TaskStatus

GetStatus method reads the task status on the updates channel

func (*Task) ID ¶

func (t *Task) ID() string

ID method returns the taskId

func (*Task) Monitor ¶

func (t *Task) Monitor() (bool, []byte, error)

Monitor method monitors task statuses

func (*Task) SendStatus ¶

func (t *Task) SendStatus(status *mesosproto.TaskStatus)

SendStatus method writes the task status in the updates channel

func (*Task) SetContainer ¶

func (t *Task) SetContainer(container *cluster.Container)

SetContainer writes on the container channel from the task

func (*Task) Stop ¶

func (t *Task) Stop()

Stop method sets the boolean determining if the task is done

func (*Task) Stopped ¶

func (t *Task) Stopped() bool

Stopped method returns a boolean determining if the task is done

type Tasks ¶

type Tasks struct {
	sync.Mutex

	Tasks map[string]*Task
	// contains filtered or unexported fields
}

Tasks is a simple map of tasks

func NewTasks ¶

func NewTasks(cluster launcher) *Tasks

NewTasks returns a new tasks

func (*Tasks) Add ¶

func (t *Tasks) Add(task *Task)

Add tries to Do the Task, if it's not possible, add the Task to the tasks for future tries

func (*Tasks) Process ¶

func (t *Tasks) Process()

Process tries to Do all the Tasks in the tasks and remove the Tasks successfully done

func (*Tasks) Remove ¶

func (t *Tasks) Remove(tasks ...*Task)

Remove a Task from the tasks

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL