mocks

package
v1.1.131 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockCompiler 

func NewMockCompiler() interfaces.Compiler

Types

type FlyteWorkflowBuilder added in v0.6.56 

type FlyteWorkflowBuilder struct {
	mock.Mock
}

FlyteWorkflowBuilder is an autogenerated mock type for the FlyteWorkflowBuilder type

func (*FlyteWorkflowBuilder) Build added in v0.6.56 

func (_m *FlyteWorkflowBuilder) Build(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, executionID *core.WorkflowExecutionIdentifier, namespace string) (*v1alpha1.FlyteWorkflow, error)

Build provides a mock function with given fields: wfClosure, inputs, executionID, namespace

func (*FlyteWorkflowBuilder) OnBuild added in v0.6.56 

func (_m *FlyteWorkflowBuilder) OnBuild(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, executionID *core.WorkflowExecutionIdentifier, namespace string) *FlyteWorkflowBuilder_Build

func (*FlyteWorkflowBuilder) OnBuildMatch added in v0.6.56 

func (_m *FlyteWorkflowBuilder) OnBuildMatch(matchers ...interface{}) *FlyteWorkflowBuilder_Build

type FlyteWorkflowBuilder_Build added in v0.6.56 

type FlyteWorkflowBuilder_Build struct {
	*mock.Call
}

func (FlyteWorkflowBuilder_Build) Return added in v0.6.56 

func (_m FlyteWorkflowBuilder_Build) Return(_a0 *v1alpha1.FlyteWorkflow, _a1 error) *FlyteWorkflowBuilder_Build

type MockCompiler 

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

func (*MockCompiler) AddCompileTaskCallback 

func (c *MockCompiler) AddCompileTaskCallback(
	callback func(task *core.TaskTemplate) (*core.CompiledTask, error))

func (*MockCompiler) AddCompileWorkflowCallback 

func (c *MockCompiler) AddCompileWorkflowCallback(callback func(
	primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, tasks []*core.CompiledTask,
	launchPlans []common.InterfaceProvider) (*core.CompiledWorkflowClosure, error))

func (*MockCompiler) AddGetRequirementCallback 

func (c *MockCompiler) AddGetRequirementCallback(
	callback func(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) (
		reqs compiler.WorkflowExecutionRequirements, err error))

func (*MockCompiler) CompileTask 

func (c *MockCompiler) CompileTask(task *core.TaskTemplate) (*core.CompiledTask, error)

func (*MockCompiler) CompileWorkflow 

func (c *MockCompiler) CompileWorkflow(
	primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, tasks []*core.CompiledTask,
	launchPlans []common.InterfaceProvider) (*core.CompiledWorkflowClosure, error)

func (*MockCompiler) GetRequirements 

func (c *MockCompiler) GetRequirements(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) (
	reqs compiler.WorkflowExecutionRequirements, err error)

type WorkflowExecutor added in v0.6.56 

type WorkflowExecutor struct {
	mock.Mock
}

WorkflowExecutor is an autogenerated mock type for the WorkflowExecutor type

func (*WorkflowExecutor) Abort added in v0.6.56 

func (_m *WorkflowExecutor) Abort(ctx context.Context, data interfaces.AbortData) error

Abort provides a mock function with given fields: ctx, data

func (*WorkflowExecutor) Execute added in v0.6.56 

func (_m *WorkflowExecutor) Execute(ctx context.Context, data interfaces.ExecutionData) (interfaces.ExecutionResponse, error)

Execute provides a mock function with given fields: ctx, data

func (*WorkflowExecutor) ID added in v0.6.56 

func (_m *WorkflowExecutor) ID() string

ID provides a mock function with given fields:

func (*WorkflowExecutor) OnAbort added in v0.6.56 

func (_m *WorkflowExecutor) OnAbort(ctx context.Context, data interfaces.AbortData) *WorkflowExecutor_Abort

func (*WorkflowExecutor) OnAbortMatch added in v0.6.56 

func (_m *WorkflowExecutor) OnAbortMatch(matchers ...interface{}) *WorkflowExecutor_Abort

func (*WorkflowExecutor) OnExecute added in v0.6.56 

func (_m *WorkflowExecutor) OnExecute(ctx context.Context, data interfaces.ExecutionData) *WorkflowExecutor_Execute

func (*WorkflowExecutor) OnExecuteMatch added in v0.6.56 

func (_m *WorkflowExecutor) OnExecuteMatch(matchers ...interface{}) *WorkflowExecutor_Execute

func (*WorkflowExecutor) OnID added in v0.6.56 

func (_m *WorkflowExecutor) OnID() *WorkflowExecutor_ID

func (*WorkflowExecutor) OnIDMatch added in v0.6.56 

func (_m *WorkflowExecutor) OnIDMatch(matchers ...interface{}) *WorkflowExecutor_ID

type WorkflowExecutor_Abort added in v0.6.56 

type WorkflowExecutor_Abort struct {
	*mock.Call
}

func (WorkflowExecutor_Abort) Return added in v0.6.56 

func (_m WorkflowExecutor_Abort) Return(_a0 error) *WorkflowExecutor_Abort

type WorkflowExecutor_Execute added in v0.6.56 

type WorkflowExecutor_Execute struct {
	*mock.Call
}

func (WorkflowExecutor_Execute) Return added in v0.6.56 

func (_m WorkflowExecutor_Execute) Return(_a0 interfaces.ExecutionResponse, _a1 error) *WorkflowExecutor_Execute

type WorkflowExecutor_ID added in v0.6.56 

type WorkflowExecutor_ID struct {
	*mock.Call
}

func (WorkflowExecutor_ID) Return added in v0.6.56 

func (_m WorkflowExecutor_ID) Return(_a0 string) *WorkflowExecutor_ID

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.