Documentation ¶
Index ¶
- type EventRecorder
- type Executor
- func (_m *Executor) CheckTaskStatus(ctx context.Context, taskCtx types.TaskContext, task *core.TaskTemplate) (types.TaskStatus, error)
- func (_m *Executor) GetID() string
- func (_m *Executor) GetProperties() types.ExecutorProperties
- func (_m *Executor) Initialize(ctx context.Context, param types.ExecutorInitializationParameters) error
- func (_m *Executor) KillTask(ctx context.Context, taskCtx types.TaskContext, reason string) error
- func (_m *Executor) ResolveOutputs(ctx context.Context, taskCtx types.TaskContext, outputVariables ...string) (map[string]*core.Literal, error)
- func (_m *Executor) StartTask(ctx context.Context, taskCtx types.TaskContext, task *core.TaskTemplate, ...) (types.TaskStatus, error)
- type TaskContext
- func (_m *TaskContext) GetAnnotations() map[string]string
- func (_m *TaskContext) GetCustomState() map[string]interface{}
- func (_m *TaskContext) GetDataDir() storage.DataReference
- func (_m *TaskContext) GetErrorFile() storage.DataReference
- func (_m *TaskContext) GetInputsFile() storage.DataReference
- func (_m *TaskContext) GetK8sServiceAccount() string
- func (_m *TaskContext) GetLabels() map[string]string
- func (_m *TaskContext) GetNamespace() string
- func (_m *TaskContext) GetOutputsFile() storage.DataReference
- func (_m *TaskContext) GetOverrides() types.TaskOverrides
- func (_m *TaskContext) GetOwnerID() pkgtypes.NamespacedName
- func (_m *TaskContext) GetOwnerReference() v1.OwnerReference
- func (_m *TaskContext) GetPhase() types.TaskPhase
- func (_m *TaskContext) GetPhaseVersion() uint32
- func (_m *TaskContext) GetTaskExecutionID() types.TaskExecutionID
- type TaskExecutionID
- type TaskOverrides
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventRecorder ¶
EventRecorder is an autogenerated mock type for the EventRecorder type
func (*EventRecorder) RecordTaskEvent ¶
func (_m *EventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) error
RecordTaskEvent provides a mock function with given fields: ctx, _a1
type Executor ¶
Executor is an autogenerated mock type for the Executor type
func (*Executor) CheckTaskStatus ¶
func (_m *Executor) CheckTaskStatus(ctx context.Context, taskCtx types.TaskContext, task *core.TaskTemplate) (types.TaskStatus, error)
CheckTaskStatus provides a mock function with given fields: ctx, taskCtx, task
func (*Executor) GetProperties ¶
func (_m *Executor) GetProperties() types.ExecutorProperties
GetProperties provides a mock function with given fields:
func (*Executor) Initialize ¶
func (_m *Executor) Initialize(ctx context.Context, param types.ExecutorInitializationParameters) error
Initialize provides a mock function with given fields: ctx, param
func (*Executor) KillTask ¶
KillTask provides a mock function with given fields: ctx, taskCtx, reason
func (*Executor) ResolveOutputs ¶
func (_m *Executor) ResolveOutputs(ctx context.Context, taskCtx types.TaskContext, outputVariables ...string) (map[string]*core.Literal, error)
ResolveOutputs provides a mock function with given fields: ctx, taskCtx, outputVariables
func (*Executor) StartTask ¶
func (_m *Executor) StartTask(ctx context.Context, taskCtx types.TaskContext, task *core.TaskTemplate, inputs *core.LiteralMap) (types.TaskStatus, error)
StartTask provides a mock function with given fields: ctx, taskCtx, task, inputs
type TaskContext ¶
TaskContext is an autogenerated mock type for the TaskContext type
func (*TaskContext) GetAnnotations ¶
func (_m *TaskContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*TaskContext) GetCustomState ¶
func (_m *TaskContext) GetCustomState() map[string]interface{}
GetCustomState provides a mock function with given fields:
func (*TaskContext) GetDataDir ¶
func (_m *TaskContext) GetDataDir() storage.DataReference
GetDataDir provides a mock function with given fields:
func (*TaskContext) GetErrorFile ¶
func (_m *TaskContext) GetErrorFile() storage.DataReference
GetErrorFile provides a mock function with given fields:
func (*TaskContext) GetInputsFile ¶
func (_m *TaskContext) GetInputsFile() storage.DataReference
GetInputsFile provides a mock function with given fields:
func (*TaskContext) GetK8sServiceAccount ¶
func (_m *TaskContext) GetK8sServiceAccount() string
GetK8sServiceAccount provides a mock function with given fields:
func (*TaskContext) GetLabels ¶
func (_m *TaskContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*TaskContext) GetNamespace ¶
func (_m *TaskContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*TaskContext) GetOutputsFile ¶
func (_m *TaskContext) GetOutputsFile() storage.DataReference
GetOutputsFile provides a mock function with given fields:
func (*TaskContext) GetOverrides ¶
func (_m *TaskContext) GetOverrides() types.TaskOverrides
GetOverrides provides a mock function with given fields:
func (*TaskContext) GetOwnerID ¶
func (_m *TaskContext) GetOwnerID() pkgtypes.NamespacedName
GetOwnerID provides a mock function with given fields:
func (*TaskContext) GetOwnerReference ¶
func (_m *TaskContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*TaskContext) GetPhase ¶
func (_m *TaskContext) GetPhase() types.TaskPhase
GetPhase provides a mock function with given fields:
func (*TaskContext) GetPhaseVersion ¶
func (_m *TaskContext) GetPhaseVersion() uint32
GetPhaseVersion provides a mock function with given fields:
func (*TaskContext) GetTaskExecutionID ¶
func (_m *TaskContext) GetTaskExecutionID() types.TaskExecutionID
GetTaskExecutionID provides a mock function with given fields:
type TaskExecutionID ¶
TaskExecutionID is an autogenerated mock type for the TaskExecutionID type
func (*TaskExecutionID) GetGeneratedName ¶
func (_m *TaskExecutionID) GetGeneratedName() string
GetGeneratedName provides a mock function with given fields:
func (*TaskExecutionID) GetID ¶
func (_m *TaskExecutionID) GetID() core.TaskExecutionIdentifier
GetID provides a mock function with given fields:
type TaskOverrides ¶
TaskOverrides is an autogenerated mock type for the TaskOverrides type
func (*TaskOverrides) GetConfig ¶
func (_m *TaskOverrides) GetConfig() *v1.ConfigMap
GetConfig provides a mock function with given fields:
func (*TaskOverrides) GetResources ¶
func (_m *TaskOverrides) GetResources() *v1.ResourceRequirements
GetResources provides a mock function with given fields: