eremetic

package module

Go to main page

Versions in this module

v0

v0.30.0

Dec 7, 2020

v0.29.0

Jun 25, 2019

Changes in this version

+ const ActiveState

+ const DefaultTaskFilterState

+ const QueuedState

+ const TerminatedState

+ func IsActive(state TaskState) bool

+ func IsEnqueued(state TaskState) bool

type DefaultTaskDB

+ func (db *DefaultTaskDB) ListTasks(filter *TaskFilter) ([]*Task, error)

type Request

+ Labels map[string]string

+ Name string

+ Privileged bool

+ VolumesFrom []string

type Task

+ Labels map[string]string

+ Privileged bool

+ VolumesFrom []string

+ func (task *Task) IsActive() bool

+ func (task *Task) IsEnqueued() bool

type TaskDB

+ ListTasks func(filter *TaskFilter) ([]*Task, error)

+ type TaskFilter struct

+ Name string

+ State string

+ func (filter TaskFilter) Match(task *Task) bool

v0.28.0

Jun 23, 2017

Changes in this version

+ func IsArchive(url string) bool

+ type AgentConstraint struct

+ AttributeName string

+ AttributeValue string

type Request

+ AgentConstraints []AgentConstraint

type Task

+ AgentConstraints []AgentConstraint

+ AgentID string

v0.27.0

Apr 19, 2017

Changes in this version

type DefaultTaskDB

+ func (db *DefaultTaskDB) DeleteTask(id string) error

type Request

+ DNS string

+ Network string

type Scheduler

+ Kill func(taskID string) error

type Task

+ DNS string

+ Network string

+ func (task *Task) CurrentStatus() TaskState

+ func (task *Task) IsTerminating() bool

+ func (task *Task) IsWaiting() bool

type TaskDB

+ DeleteTask func(id string) error

type TaskState

+ const TaskTerminating

v0.26.0

Oct 4, 2016

Changes in this version

type Request

+ Args []string

type Task

+ Args []string

+ FrameworkID string

+ SlaveID string

type TaskState

+ const TaskError

+ const TaskFailed

+ const TaskFinished

+ const TaskKilled

+ const TaskLost

+ const TaskQueued

+ const TaskRunning

+ const TaskStaging

+ const TaskStarting

v0.25.0

Sep 28, 2016

Changes in this version

+ const Masking

+ var ErrQueueFull = errors.New("task queue is full")

+ func ApplyMask(task *Task)

+ func Encode(task *Task) ([]byte, error)

+ func IsTerminal(state TaskState) bool

+ func NotifyCallback(task *Task)

+ type CallbackData struct

+ Status string

+ TaskID string

+ Time int64

+ type DefaultTaskDB struct

+ func NewDefaultTaskDB() *DefaultTaskDB

+ func (db *DefaultTaskDB) Clean() error

+ func (db *DefaultTaskDB) Close()

+ func (db *DefaultTaskDB) ListNonTerminalTasks() ([]*Task, error)

+ func (db *DefaultTaskDB) PutTask(task *Task) error

+ func (db *DefaultTaskDB) ReadTask(id string) (Task, error)

+ func (db *DefaultTaskDB) ReadUnmaskedTask(id string) (Task, error)

+ type Port struct

+ ContainerPort uint32

+ HostPort uint32

+ Protocol string

+ type Request struct

+ CallbackURI string

+ Command string

+ DockerImage string

+ Environment map[string]string

+ Fetch []URI

+ ForcePullImage bool

+ MaskedEnvironment map[string]string

+ Ports []Port

+ SlaveConstraints []SlaveConstraint

+ TaskCPUs float64

+ TaskMem float64

+ URIs []string

+ Volumes []Volume

+ type Scheduler interface

+ ScheduleTask func(request Request) (string, error)

+ type SlaveConstraint struct

+ AttributeName string

+ AttributeValue string

+ type Status struct

+ Status TaskState

+ Time int64

+ type Task struct

+ AgentIP string

+ AgentPort int32

+ CallbackURI string

+ Command string

+ Environment map[string]string

+ FetchURIs []URI

+ ForcePullImage bool

+ FrameworkId string

+ Hostname string

+ ID string

+ Image string

+ MaskedEnvironment map[string]string

+ Name string

+ Ports []Port

+ Retry int

+ SandboxPath string

+ SlaveConstraints []SlaveConstraint

+ SlaveId string

+ Status []Status

+ TaskCPUs float64

+ TaskMem float64

+ User string

+ Volumes []Volume

+ func NewTask(request Request, name string) (Task, error)

+ func (task *Task) IsRunning() bool

+ func (task *Task) IsTerminated() bool

+ func (task *Task) LastUpdated() time.Time

+ func (task *Task) UpdateStatus(status Status)

+ func (task *Task) WasRunning() bool

+ type TaskDB interface

+ Clean func() error

+ Close func()

+ ListNonTerminalTasks func() ([]*Task, error)

+ PutTask func(task *Task) error

+ ReadTask func(id string) (Task, error)

+ ReadUnmaskedTask func(id string) (Task, error)

+ type TaskState string

+ const TaskState_TASK_ERROR

+ const TaskState_TASK_FAILED

+ const TaskState_TASK_FINISHED

+ const TaskState_TASK_KILLED

+ const TaskState_TASK_LOST

+ const TaskState_TASK_QUEUED

+ const TaskState_TASK_RUNNING

+ const TaskState_TASK_STAGING

+ const TaskState_TASK_STARTING

+ func (s TaskState) String() string

+ type URI struct

+ Cache bool

+ Executable bool

+ Extract bool

+ URI string

+ type Volume struct

+ ContainerPath string

+ HostPath string

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