task

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2019 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const IDMaxLength = 50

Variables

This section is empty.

Functions

func ConvertTaskPhaseToHandlerStatus

func ConvertTaskPhaseToHandlerStatus(taskStatus pluginsV1.TaskStatus) (handler.Status, error)

func DisableTestMode

func DisableTestMode()

func IsTestModeEnabled

func IsTestModeEnabled() bool

func New

func New(eventSink events.EventSink, store *storage.DataStore, enqueueWf v1alpha1.EnqueueWorkflow, revalPeriod time.Duration,
	catalogClient catalog.Client, kubeClient executors.Client, scope promutils.Scope) handler.IFace

func NewTaskHandlerForFactory

func NewTaskHandlerForFactory(eventSink events.EventSink, store *storage.DataStore, enqueueWf v1alpha1.EnqueueWorkflow,
	tf Factory, catalogClient catalog.Client, kubeClient executors.Client, scope promutils.Scope) handler.IFace

func SetTestFactory

func SetTestFactory(tf Factory)

Types

type Factory

type Factory interface {
	GetTaskExecutor(taskType v1alpha1.TaskType) (types.Executor, error)
	ListAllTaskExecutors() []types.Executor
}

func NewFactory

func NewFactory(revalPeriod time.Duration) Factory

type FactoryFuncs

type FactoryFuncs struct {
	GetTaskExecutorCb      func(taskType v1alpha1.TaskType) (types.Executor, error)
	ListAllTaskExecutorsCb func() []types.Executor
}

func (*FactoryFuncs) GetTaskExecutor

func (t *FactoryFuncs) GetTaskExecutor(taskType v1alpha1.TaskType) (types.Executor, error)

func (*FactoryFuncs) ListAllTaskExecutors

func (t *FactoryFuncs) ListAllTaskExecutors() []types.Executor

Jump to

Keyboard shortcuts

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