taskrunner

Documentation

Index

• Constants
• func IsTimeoutError(err error) bool
• func NewTaskRunner() *taskRunner
• func NewTaskStatusRunner(identifiers []object.ObjMetadata, statusPoller poller.Poller) *taskStatusRunner
• type Options
• type Task
• type TaskContext
  • func NewTaskContext(eventChannel chan event.Event) *TaskContext
  • func (tc *TaskContext) EventChannel() chan event.Event
  • func (tc *TaskContext) TaskChannel() chan TaskResult
• type TaskResult
• type WaitTask
  • func NewWaitTask(ids []object.ObjMetadata, cond condition, timeout time.Duration) *WaitTask
  • func (w *WaitTask) ClearTimeout()
  • func (w *WaitTask) Start(taskContext *TaskContext)

Constants

const (
	// AllCurrent Condition means all the provided resources
	// has reached (and remains in) the Current status.
	AllCurrent condition = "AllCurrent"

	// AllNotFound Condition means all the provided resources
	// has reached the NotFound status, i.e. they are all deleted
	// from the cluster.
	AllNotFound condition = "AllNotFound"
)

Functions

func IsTimeoutError

func IsTimeoutError(err error) bool

IsTimeoutError checks whether a given error is a timeoutError.

func NewTaskRunner

func NewTaskRunner() *taskRunner

NewTaskRunner returns a new taskRunner. It can process taskqueues that does not contain any wait tasks.

func NewTaskStatusRunner

func NewTaskStatusRunner(identifiers []object.ObjMetadata, statusPoller poller.Poller) *taskStatusRunner

NewTaskStatusRunner returns a new TaskStatusRunner.

Types

type Options

type Options struct {
	PollInterval     time.Duration
	UseCache         bool
	EmitStatusEvents bool
}

Options defines properties that is passed along to the statusPoller.

type Task

type Task interface {
	Start(taskContext *TaskContext)
	ClearTimeout()
}

Task is the interface that must be implemented by all tasks that will be executed by the taskrunner.

type TaskContext

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

TaskContext defines a context that is passed between all the tasks that is in a taskqueue.

func NewTaskContext

func NewTaskContext(eventChannel chan event.Event) *TaskContext

NewTaskContext returns a new TaskContext

func (*TaskContext) EventChannel

func (tc *TaskContext) EventChannel() chan event.Event

func (*TaskContext) TaskChannel

func (tc *TaskContext) TaskChannel() chan TaskResult

type TaskResult

type TaskResult struct {
	Err error
}

TaskResult is the type returned from tasks once they have completed or failed. If it has failed or timed out, the Err property will be set.

type WaitTask

type WaitTask struct {
	// Identifiers is the list of resources that we are waiting for.
	Identifiers []object.ObjMetadata
	// Condition defines the status we want all resources to reach
	Condition condition
	// Timeout defines how long we are willing to wait for the condition
	// to be met.
	Timeout time.Duration
	// contains filtered or unexported fields
}

WaitTask is an implementation of the Task interface that is used to wait for a set of resources (identified by a slice of ObjMetadata) will all meet the condition specified. It also specifies a timeout for how long we are willing to wait for this to happen. Unlike other implementations of the Task interface, the wait task is handled in a special way to the taskrunner and is a part of the core package.

func NewWaitTask

func NewWaitTask(ids []object.ObjMetadata, cond condition, timeout time.Duration) *WaitTask

NewWaitTask creates a new wait task where we will wait until the resources specifies by ids all meet the specified condition.

func (*WaitTask) ClearTimeout

func (w *WaitTask) ClearTimeout()

ClearTimeout cancels the timeout for the wait task.

func (*WaitTask) Start

func (w *WaitTask) Start(taskContext *TaskContext)

Start kicks off the task. For the wait task, this just means setting up the timeout timer.