task

package
v0.13.92 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2020 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Overview

Package task defines the Task type and its Manager, with the purpose of handling the lifetime of O² Task objects. Each Task generally matches a running Mesos Task. All Tasks are kept in a roster in Manager, and the latter also takes care of resource acquisition and deployment.

Index

Constants

View Source 
const (
	CONFIGURE = Event("CONFIGURE")
	RESET     = Event("RESET")
	START     = Event("START")
	STOP      = Event("STOP")
	EXIT      = Event("EXIT")
	GO_ERROR  = Event("GO_ERROR")
	RECOVER   = Event("RECOVER")
)
View Source 
const (
	TARGET_SEPARATOR_RUNE = ':'
	TARGET_SEPARATOR      = ":"
)
View Source 
const (
	UNDEFINED = iota
	INACTIVE
	PARTIAL
	ACTIVE
)

Variables

View Source 
var (
	STATUS_PRODUCT = map[Status]map[Status]Status{
		UNDEFINED: {
			UNDEFINED: UNDEFINED,
			INACTIVE:  UNDEFINED,
			PARTIAL:   UNDEFINED,
			ACTIVE:    UNDEFINED,
		},
		INACTIVE: {
			UNDEFINED: UNDEFINED,
			INACTIVE:  INACTIVE,
			PARTIAL:   PARTIAL,
			ACTIVE:    PARTIAL,
		},
		PARTIAL: {
			UNDEFINED: UNDEFINED,
			INACTIVE:  PARTIAL,
			PARTIAL:   PARTIAL,
			ACTIVE:    PARTIAL,
		},
		ACTIVE: {
			UNDEFINED: UNDEFINED,
			INACTIVE:  PARTIAL,
			PARTIAL:   PARTIAL,
			ACTIVE:    ACTIVE,
		},
	}
)

Functions

This section is empty.

Types

type AgentCache 

type AgentCache struct {
	// contains filtered or unexported fields
}

func (*AgentCache) Count 

func (ac *AgentCache) Count() (count int)

func (*AgentCache) Get 

func (ac *AgentCache) Get(id mesos.AgentID) (agent *AgentCacheInfo)

func (*AgentCache) Update 

func (ac *AgentCache) Update(agents ...AgentCacheInfo)

type AgentCacheInfo 

type AgentCacheInfo struct {
	AgentId    mesos.AgentID
	Attributes constraint.Attributes
	Hostname   string
}

type Class added in v0.12.90 

type Class struct {
	Identifier taskClassIdentifier `yaml:"name"`
	Defaults   gera.StringMap      `yaml:"defaults"`
	Control    struct {
		Mode controlmode.ControlMode `yaml:"mode"`
	} `yaml:"control"`
	Command     *common.CommandInfo     `yaml:"command"`
	Wants       ResourceWants           `yaml:"wants"`
	Bind        []channel.Inbound       `yaml:"bind"`
	Properties  gera.StringMap          `yaml:"properties"`
	Constraints []constraint.Constraint `yaml:"constraints"`
	Connect     []channel.Outbound      `yaml:"connect"`
}

↓ We need the roles tree to know *where* to run it and how to *configure* it, but 

the following information is enough to run the task even with no environment or
role Class.

func (*Class) Equals added in v0.12.90 

func (c *Class) Equals(other *Class) (response bool)

func (*Class) UnmarshalYAML added in v0.12.90 

func (c *Class) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

type DeploymentMap 

type DeploymentMap map[*Task]*Descriptor

type Descriptor 

type Descriptor struct {
	TaskRole        parentRole
	TaskClassName   string
	RoleConstraints constraint.Constraints
	RoleConnect     []channel.Outbound
	RoleBind        []channel.Inbound
}

type Descriptors 

type Descriptors []*Descriptor

type Event 

type Event string

func (Event) String 

func (e Event) String() string

type EventArgs 

type EventArgs map[string]string

type Filter 

type Filter func(*Task) bool
var Filter_NIL Filter = func(*Task) bool {
	return true
}

type GenericTaskError 

type GenericTaskError struct {
	// contains filtered or unexported fields
}

func (GenericTaskError) Error 

func (r GenericTaskError) Error() string

func (GenericTaskError) GetTaskId 

func (r GenericTaskError) GetTaskId() string

type GenericTasksError 

type GenericTasksError struct {
	// contains filtered or unexported fields
}

func (GenericTasksError) Error 

func (r GenericTasksError) Error() string

func (GenericTasksError) GetTaskIds 

func (r GenericTasksError) GetTaskIds() []string

type KillTaskFunc added in v0.9.0 

type KillTaskFunc func(*Task) error

type Manager 

type Manager struct {
	AgentCache AgentCache
	// contains filtered or unexported fields
}

func NewManager 

func NewManager(resourceOffersDone <-chan DeploymentMap,
	tasksToDeploy chan<- Descriptors,
	reviveOffersTrg chan struct{},
	cq *controlcommands.CommandQueue,
	killTaskFunc KillTaskFunc) (taskman *Manager)

func (*Manager) AcquireTasks 

func (m *Manager) AcquireTasks(envId uuid.Array, taskDescriptors Descriptors) (err error)

func (*Manager) BuildDescriptorConstraints 

func (m *Manager) BuildDescriptorConstraints(descriptors Descriptors) (cm map[*Descriptor]constraint.Constraints)

func (*Manager) Cleanup 

func (m *Manager) Cleanup() (killed Tasks, running Tasks, err error)

Kill all tasks outside an environment (all unlocked tasks)

func (*Manager) ConfigureTasks 

func (m *Manager) ConfigureTasks(envId uuid.Array, tasks Tasks) error

func (*Manager) GetTask 

func (m *Manager) GetTask(id string) *Task

func (*Manager) GetTaskClass 

func (m *Manager) GetTaskClass(name string) (b *Class)

func (*Manager) GetTasks 

func (m *Manager) GetTasks() Tasks

func (*Manager) GetWantsForDescriptor 

func (m *Manager) GetWantsForDescriptor(descriptor *Descriptor) (r *Wants)

func (*Manager) KillTasks 

func (m *Manager) KillTasks(taskIds []string) (killed Tasks, running Tasks, err error)

Kill a specific list of tasks. If the task list includes locked tasks, TaskNotFoundError is returned.

func (*Manager) NewTaskForMesosOffer 

func (m *Manager) NewTaskForMesosOffer(
	offer *mesos.Offer,
	descriptor *Descriptor,
	localBindMap channel.BindMap,
	executorId mesos.ExecutorID) (t *Task)

NewTaskForMesosOffer accepts a Mesos offer and a Descriptor and returns a newly constructed Task. This function should only be called by the Mesos scheduler controller when matching role requests with offers (matchRoles).

func (*Manager) RefreshClasses 

func (m *Manager) RefreshClasses(taskClassesRequired []string) (err error)

func (*Manager) ReleaseTasks 

func (m *Manager) ReleaseTasks(envId uuid.Array, tasks Tasks) error

func (*Manager) RemoveReposClasses added in v0.10.0 

func (m *Manager) RemoveReposClasses(repoPath string)

func (*Manager) TaskCount 

func (m *Manager) TaskCount() int

func (*Manager) TransitionTasks 

func (m *Manager) TransitionTasks(tasks Tasks, src string, event string, dest string, commonArgs controlcommands.PropertyMap) error

func (*Manager) UpdateTaskState 

func (m *Manager) UpdateTaskState(taskId string, state string)

func (*Manager) UpdateTaskStatus 

func (m *Manager) UpdateTaskStatus(status *mesos.TaskStatus)

type Range 

type Range struct {
	Begin uint64 `json:"begin" yaml:"begin"`
	End   uint64 `json:"end"   yaml:"end"`
}

type Ranges 

type Ranges []Range

func (Ranges) Equals 

func (this Ranges) Equals(other Ranges) (response bool)

type ResourceWants 

type ResourceWants struct {
	Cpu    *float64 `yaml:"cpu"`
	Memory *float64 `yaml:"memory"`
	Ports  Ranges   `yaml:"ports"`
}

func (*ResourceWants) UnmarshalYAML 

func (rw *ResourceWants) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

type Resources 

type Resources mesos.Resources

func (Resources) Satisfy 

func (r Resources) Satisfy(wants *Wants) bool

type State 

type State int
const (
	UNKNOWN State = iota
	STANDBY
	CONFIGURED
	RUNNING
	ERROR
	DONE
	MIXED
)

func StateFromString 

func StateFromString(s string) State

func (State) String 

func (s State) String() string

func (State) X 

func (s State) X(other State) State

type Status 

type Status uint8

func (Status) String 

func (s Status) String() string

func (Status) X 

func (s Status) X(other Status) Status

type Task 

type Task struct {
	GetTaskClass func() *Class
	// contains filtered or unexported fields
}

func (*Task) BuildPropertyMap 

func (t *Task) BuildPropertyMap(bindMap channel.BindMap) (propMap controlcommands.PropertyMap)

func (*Task) BuildTaskCommand 

func (t *Task) BuildTaskCommand(role parentRole) (err error)

Returns a consolidated CommandInfo for this Task, based on Roles tree and Class.

func (*Task) GetAgentId 

func (t *Task) GetAgentId() string

func (*Task) GetClassName 

func (t *Task) GetClassName() string

func (*Task) GetEnvironmentId 

func (t *Task) GetEnvironmentId() uuid.Array

func (*Task) GetExecutorId 

func (t *Task) GetExecutorId() string

func (*Task) GetHostname 

func (t *Task) GetHostname() string

func (*Task) GetLocalBindMap added in v0.13.0 

func (t *Task) GetLocalBindMap() channel.BindMap

func (*Task) GetMesosCommandTarget 

func (t *Task) GetMesosCommandTarget() controlcommands.MesosCommandTarget

func (*Task) GetName 

func (t *Task) GetName() string

func (*Task) GetOfferId 

func (t *Task) GetOfferId() string

func (*Task) GetParentRole 

func (t *Task) GetParentRole() interface{}

func (*Task) GetParentRolePath 

func (t *Task) GetParentRolePath() string

func (*Task) GetProperties added in v0.12.90 

func (t *Task) GetProperties() map[string]string

func (*Task) GetTaskCommandInfo added in v0.12.90 

func (t *Task) GetTaskCommandInfo() *common.TaskCommandInfo

func (*Task) GetTaskId 

func (t *Task) GetTaskId() string

func (*Task) GetWantsCPU 

func (t *Task) GetWantsCPU() float64

func (*Task) GetWantsMemory 

func (t *Task) GetWantsMemory() float64

func (*Task) GetWantsPorts 

func (t *Task) GetWantsPorts() Ranges

func (*Task) IsLocked 

func (t *Task) IsLocked() bool

func (*Task) IsSafeToStop added in v0.12.0 

func (t *Task) IsSafeToStop() bool

func (*Task) SetSafeToStop added in v0.12.0 

func (t *Task) SetSafeToStop(done bool)

type TaskAlreadyReleasedError 

type TaskAlreadyReleasedError taskErrorBase

func (TaskAlreadyReleasedError) Error 

func (r TaskAlreadyReleasedError) Error() string

type TaskError 

type TaskError interface {
	error
	GetTaskId() string
}

type TaskLockedError 

type TaskLockedError struct {
	// contains filtered or unexported fields
}

func (TaskLockedError) EnvironmentId 

func (r TaskLockedError) EnvironmentId() uuid.Array

func (TaskLockedError) Error 

func (r TaskLockedError) Error() string

func (TaskLockedError) GetTaskId 

func (r TaskLockedError) GetTaskId() string

type TaskNotFoundError 

type TaskNotFoundError taskErrorBase

func (TaskNotFoundError) Error 

func (r TaskNotFoundError) Error() string

type Tasks 

type Tasks []*Task

func (Tasks) BuildPropertyMaps 

func (m Tasks) BuildPropertyMaps(bindMap channel.BindMap) (propMapMap controlcommands.PropertyMapsMap, err error)

func (Tasks) Contains 

func (m Tasks) Contains(filter Filter) (has bool)

func (Tasks) Filtered 

func (m Tasks) Filtered(filter Filter) (tasks Tasks)

func (Tasks) FilteredForClass 

func (m Tasks) FilteredForClass(className string) (tasks Tasks)

func (Tasks) GetByTaskId 

func (m Tasks) GetByTaskId(id string) *Task

func (Tasks) GetMesosCommandTargets 

func (m Tasks) GetMesosCommandTargets() (receivers []controlcommands.MesosCommandTarget, err error)

func (Tasks) GetTaskIds added in v0.9.1 

func (m Tasks) GetTaskIds() []string

type TasksDeploymentError 

type TasksDeploymentError tasksErrorBase

func (TasksDeploymentError) Error 

func (r TasksDeploymentError) Error() string

type TasksError 

type TasksError interface {
	error
	GetTaskIds() []string
}

type Transition 

type Transition struct {
	Evt  Event
	Src  State
	Dst  State
	Args EventArgs
}

type Wants 

type Wants struct {
	Cpu             float64
	Memory          float64
	StaticPorts     Ranges
	InboundChannels []channel.Inbound
}

Source Files

View all Source files

Directories

Path Synopsis
Package constraint implements support for predicates on agent attributes.
 Package constraint implements support for predicates on agent attributes.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.