task

Documentation

Index

• Constants
• func ConvertTaskPhaseToHandlerStatus(taskStatus pluginsV1.TaskStatus) (handler.Status, error)
• func DisableTestMode()
• func IsTestModeEnabled() bool
• func New(eventSink events.EventSink, store *storage.DataStore, ...) handler.IFace
• func NewTaskHandlerForFactory(eventSink events.EventSink, store *storage.DataStore, ...) handler.IFace
• func SetTestFactory(tf Factory)
• type Factory
  • func NewFactory(revalPeriod time.Duration) Factory
• type FactoryFuncs
  • func (t *FactoryFuncs) GetTaskExecutor(taskType v1alpha1.TaskType) (types.Executor, error)
  • func (t *FactoryFuncs) ListAllTaskExecutors() []types.Executor

Constants

const IDMaxLength = 50

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