mocks

package
v1.16.3 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2025 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 

type FlyteWorkflowBuilder struct {
	mock.Mock
}

FlyteWorkflowBuilder is an autogenerated mock type for the FlyteWorkflowBuilder type

func NewFlyteWorkflowBuilder added in v1.15.1 

func NewFlyteWorkflowBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *FlyteWorkflowBuilder

NewFlyteWorkflowBuilder creates a new instance of FlyteWorkflowBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*FlyteWorkflowBuilder) Build 

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) EXPECT added in v1.15.1 

func (_m *FlyteWorkflowBuilder) EXPECT() *FlyteWorkflowBuilder_Expecter

type FlyteWorkflowBuilder_Build_Call added in v1.15.1 

type FlyteWorkflowBuilder_Build_Call struct {
	*mock.Call
}

FlyteWorkflowBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'

func (*FlyteWorkflowBuilder_Build_Call) Return added in v1.15.1 

func (_c *FlyteWorkflowBuilder_Build_Call) Return(_a0 *v1alpha1.FlyteWorkflow, _a1 error) *FlyteWorkflowBuilder_Build_Call

func (*FlyteWorkflowBuilder_Build_Call) Run added in v1.15.1 

func (_c *FlyteWorkflowBuilder_Build_Call) Run(run func(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, executionID *core.WorkflowExecutionIdentifier, namespace string)) *FlyteWorkflowBuilder_Build_Call

func (*FlyteWorkflowBuilder_Build_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteWorkflowBuilder_Build_Call) RunAndReturn(run func(*core.CompiledWorkflowClosure, *core.LiteralMap, *core.WorkflowExecutionIdentifier, string) (*v1alpha1.FlyteWorkflow, error)) *FlyteWorkflowBuilder_Build_Call

type FlyteWorkflowBuilder_Expecter added in v1.15.1 

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

func (*FlyteWorkflowBuilder_Expecter) Build added in v1.15.1 

func (_e *FlyteWorkflowBuilder_Expecter) Build(wfClosure interface{}, inputs interface{}, executionID interface{}, namespace interface{}) *FlyteWorkflowBuilder_Build_Call

Build is a helper method to define mock.On call

  • wfClosure *core.CompiledWorkflowClosure
  • inputs *core.LiteralMap
  • executionID *core.WorkflowExecutionIdentifier
  • namespace string

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 

type WorkflowExecutor struct {
	mock.Mock
}

WorkflowExecutor is an autogenerated mock type for the WorkflowExecutor type

func NewWorkflowExecutor added in v1.15.1 

func NewWorkflowExecutor(t interface {
	mock.TestingT
	Cleanup(func())
}) *WorkflowExecutor

NewWorkflowExecutor creates a new instance of WorkflowExecutor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*WorkflowExecutor) Abort 

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

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

func (*WorkflowExecutor) EXPECT added in v1.15.1 

func (_m *WorkflowExecutor) EXPECT() *WorkflowExecutor_Expecter

func (*WorkflowExecutor) Execute 

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 

func (_m *WorkflowExecutor) ID() string

ID provides a mock function with no fields

type WorkflowExecutor_Abort_Call added in v1.15.1 

type WorkflowExecutor_Abort_Call struct {
	*mock.Call
}

WorkflowExecutor_Abort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Abort'

func (*WorkflowExecutor_Abort_Call) Return added in v1.15.1 

func (_c *WorkflowExecutor_Abort_Call) Return(_a0 error) *WorkflowExecutor_Abort_Call

func (*WorkflowExecutor_Abort_Call) Run added in v1.15.1 

func (_c *WorkflowExecutor_Abort_Call) Run(run func(ctx context.Context, data interfaces.AbortData)) *WorkflowExecutor_Abort_Call

func (*WorkflowExecutor_Abort_Call) RunAndReturn added in v1.15.1 

func (_c *WorkflowExecutor_Abort_Call) RunAndReturn(run func(context.Context, interfaces.AbortData) error) *WorkflowExecutor_Abort_Call

type WorkflowExecutor_Execute_Call added in v1.15.1 

type WorkflowExecutor_Execute_Call struct {
	*mock.Call
}

WorkflowExecutor_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*WorkflowExecutor_Execute_Call) Return added in v1.15.1 

func (_c *WorkflowExecutor_Execute_Call) Return(_a0 interfaces.ExecutionResponse, _a1 error) *WorkflowExecutor_Execute_Call

func (*WorkflowExecutor_Execute_Call) Run added in v1.15.1 

func (_c *WorkflowExecutor_Execute_Call) Run(run func(ctx context.Context, data interfaces.ExecutionData)) *WorkflowExecutor_Execute_Call

func (*WorkflowExecutor_Execute_Call) RunAndReturn added in v1.15.1 

func (_c *WorkflowExecutor_Execute_Call) RunAndReturn(run func(context.Context, interfaces.ExecutionData) (interfaces.ExecutionResponse, error)) *WorkflowExecutor_Execute_Call

type WorkflowExecutor_Expecter added in v1.15.1 

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

func (*WorkflowExecutor_Expecter) Abort added in v1.15.1 

func (_e *WorkflowExecutor_Expecter) Abort(ctx interface{}, data interface{}) *WorkflowExecutor_Abort_Call

Abort is a helper method to define mock.On call

  • ctx context.Context
  • data interfaces.AbortData

func (*WorkflowExecutor_Expecter) Execute added in v1.15.1 

func (_e *WorkflowExecutor_Expecter) Execute(ctx interface{}, data interface{}) *WorkflowExecutor_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • data interfaces.ExecutionData

func (*WorkflowExecutor_Expecter) ID added in v1.15.1 

func (_e *WorkflowExecutor_Expecter) ID() *WorkflowExecutor_ID_Call

ID is a helper method to define mock.On call

type WorkflowExecutor_ID_Call added in v1.15.1 

type WorkflowExecutor_ID_Call struct {
	*mock.Call
}

WorkflowExecutor_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*WorkflowExecutor_ID_Call) Return added in v1.15.1 

func (_c *WorkflowExecutor_ID_Call) Return(_a0 string) *WorkflowExecutor_ID_Call

func (*WorkflowExecutor_ID_Call) Run added in v1.15.1 

func (_c *WorkflowExecutor_ID_Call) Run(run func()) *WorkflowExecutor_ID_Call

func (*WorkflowExecutor_ID_Call) RunAndReturn added in v1.15.1 

func (_c *WorkflowExecutor_ID_Call) RunAndReturn(run func() string) *WorkflowExecutor_ID_Call

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.