mocks

package
v1.16.7 Latest Latest
Warning

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

 Go to latest Published: May 28, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Executor 

type Executor struct {
	mock.Mock
}

Executor is an autogenerated mock type for the Executor type

func NewExecutor added in v1.15.1 

func NewExecutor(t interface {
	mock.TestingT
	Cleanup(func())
}) *Executor

NewExecutor creates a new instance of Executor. 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 (*Executor) EXPECT added in v1.15.1 

func (_m *Executor) EXPECT() *Executor_Expecter

func (*Executor) GetStatus 

func (_m *Executor) GetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)

GetStatus provides a mock function with given fields: ctx, executionID

func (*Executor) Initialize 

func (_m *Executor) Initialize(ctx context.Context) error

Initialize provides a mock function with given fields: ctx

func (*Executor) Kill 

func (_m *Executor) Kill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) error

Kill provides a mock function with given fields: ctx, executionID, reason

func (*Executor) Launch 

func (_m *Executor) Launch(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap, parentWorkflowID string) error

Launch provides a mock function with given fields: ctx, launchCtx, executionID, launchPlanRef, inputs, parentWorkflowID

type Executor_Expecter added in v1.15.1 

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

func (*Executor_Expecter) GetStatus added in v1.15.1 

func (_e *Executor_Expecter) GetStatus(ctx interface{}, executionID interface{}) *Executor_GetStatus_Call

GetStatus is a helper method to define mock.On call

  • ctx context.Context
  • executionID *core.WorkflowExecutionIdentifier

func (*Executor_Expecter) Initialize added in v1.15.1 

func (_e *Executor_Expecter) Initialize(ctx interface{}) *Executor_Initialize_Call

Initialize is a helper method to define mock.On call

  • ctx context.Context

func (*Executor_Expecter) Kill added in v1.15.1 

func (_e *Executor_Expecter) Kill(ctx interface{}, executionID interface{}, reason interface{}) *Executor_Kill_Call

Kill is a helper method to define mock.On call

  • ctx context.Context
  • executionID *core.WorkflowExecutionIdentifier
  • reason string

func (*Executor_Expecter) Launch added in v1.15.1 

func (_e *Executor_Expecter) Launch(ctx interface{}, launchCtx interface{}, executionID interface{}, launchPlanRef interface{}, inputs interface{}, parentWorkflowID interface{}) *Executor_Launch_Call

Launch is a helper method to define mock.On call

  • ctx context.Context
  • launchCtx launchplan.LaunchContext
  • executionID *core.WorkflowExecutionIdentifier
  • launchPlanRef *core.Identifier
  • inputs *core.LiteralMap
  • parentWorkflowID string

type Executor_GetStatus_Call added in v1.15.1 

type Executor_GetStatus_Call struct {
	*mock.Call
}

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

func (*Executor_GetStatus_Call) Return added in v1.15.1 

func (_c *Executor_GetStatus_Call) Return(_a0 *admin.ExecutionClosure, _a1 *core.LiteralMap, _a2 error) *Executor_GetStatus_Call

func (*Executor_GetStatus_Call) Run added in v1.15.1 

func (_c *Executor_GetStatus_Call) Run(run func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier)) *Executor_GetStatus_Call

func (*Executor_GetStatus_Call) RunAndReturn added in v1.15.1 

func (_c *Executor_GetStatus_Call) RunAndReturn(run func(context.Context, *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)) *Executor_GetStatus_Call

type Executor_Initialize_Call added in v1.15.1 

type Executor_Initialize_Call struct {
	*mock.Call
}

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

func (*Executor_Initialize_Call) Return added in v1.15.1 

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

func (*Executor_Initialize_Call) Run added in v1.15.1 

func (_c *Executor_Initialize_Call) Run(run func(ctx context.Context)) *Executor_Initialize_Call

func (*Executor_Initialize_Call) RunAndReturn added in v1.15.1 

func (_c *Executor_Initialize_Call) RunAndReturn(run func(context.Context) error) *Executor_Initialize_Call

type Executor_Kill_Call added in v1.15.1 

type Executor_Kill_Call struct {
	*mock.Call
}

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

func (*Executor_Kill_Call) Return added in v1.15.1 

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

func (*Executor_Kill_Call) Run added in v1.15.1 

func (_c *Executor_Kill_Call) Run(run func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string)) *Executor_Kill_Call

func (*Executor_Kill_Call) RunAndReturn added in v1.15.1 

func (_c *Executor_Kill_Call) RunAndReturn(run func(context.Context, *core.WorkflowExecutionIdentifier, string) error) *Executor_Kill_Call

type Executor_Launch_Call added in v1.15.1 

type Executor_Launch_Call struct {
	*mock.Call
}

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

func (*Executor_Launch_Call) Return added in v1.15.1 

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

func (*Executor_Launch_Call) Run added in v1.15.1 

func (_c *Executor_Launch_Call) Run(run func(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap, parentWorkflowID string)) *Executor_Launch_Call

func (*Executor_Launch_Call) RunAndReturn added in v1.15.1 

func (_c *Executor_Launch_Call) RunAndReturn(run func(context.Context, launchplan.LaunchContext, *core.WorkflowExecutionIdentifier, *core.Identifier, *core.LiteralMap, string) error) *Executor_Launch_Call

type FlyteAdmin 

type FlyteAdmin struct {
	mock.Mock
}

FlyteAdmin is an autogenerated mock type for the FlyteAdmin type

func NewFlyteAdmin added in v1.15.1 

func NewFlyteAdmin(t interface {
	mock.TestingT
	Cleanup(func())
}) *FlyteAdmin

NewFlyteAdmin creates a new instance of FlyteAdmin. 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 (*FlyteAdmin) EXPECT added in v1.15.1 

func (_m *FlyteAdmin) EXPECT() *FlyteAdmin_Expecter

func (*FlyteAdmin) GetLaunchPlan 

func (_m *FlyteAdmin) GetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) (*admin.LaunchPlan, error)

GetLaunchPlan provides a mock function with given fields: ctx, launchPlanRef

func (*FlyteAdmin) GetStatus 

func (_m *FlyteAdmin) GetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)

GetStatus provides a mock function with given fields: ctx, executionID

func (*FlyteAdmin) Initialize 

func (_m *FlyteAdmin) Initialize(ctx context.Context) error

Initialize provides a mock function with given fields: ctx

func (*FlyteAdmin) Kill 

func (_m *FlyteAdmin) Kill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) error

Kill provides a mock function with given fields: ctx, executionID, reason

func (*FlyteAdmin) Launch 

func (_m *FlyteAdmin) Launch(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap, parentWorkflowID string) error

Launch provides a mock function with given fields: ctx, launchCtx, executionID, launchPlanRef, inputs, parentWorkflowID

type FlyteAdmin_Expecter added in v1.15.1 

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

func (*FlyteAdmin_Expecter) GetLaunchPlan added in v1.15.1 

func (_e *FlyteAdmin_Expecter) GetLaunchPlan(ctx interface{}, launchPlanRef interface{}) *FlyteAdmin_GetLaunchPlan_Call

GetLaunchPlan is a helper method to define mock.On call

  • ctx context.Context
  • launchPlanRef *core.Identifier

func (*FlyteAdmin_Expecter) GetStatus added in v1.15.1 

func (_e *FlyteAdmin_Expecter) GetStatus(ctx interface{}, executionID interface{}) *FlyteAdmin_GetStatus_Call

GetStatus is a helper method to define mock.On call

  • ctx context.Context
  • executionID *core.WorkflowExecutionIdentifier

func (*FlyteAdmin_Expecter) Initialize added in v1.15.1 

func (_e *FlyteAdmin_Expecter) Initialize(ctx interface{}) *FlyteAdmin_Initialize_Call

Initialize is a helper method to define mock.On call

  • ctx context.Context

func (*FlyteAdmin_Expecter) Kill added in v1.15.1 

func (_e *FlyteAdmin_Expecter) Kill(ctx interface{}, executionID interface{}, reason interface{}) *FlyteAdmin_Kill_Call

Kill is a helper method to define mock.On call

  • ctx context.Context
  • executionID *core.WorkflowExecutionIdentifier
  • reason string

func (*FlyteAdmin_Expecter) Launch added in v1.15.1 

func (_e *FlyteAdmin_Expecter) Launch(ctx interface{}, launchCtx interface{}, executionID interface{}, launchPlanRef interface{}, inputs interface{}, parentWorkflowID interface{}) *FlyteAdmin_Launch_Call

Launch is a helper method to define mock.On call

  • ctx context.Context
  • launchCtx launchplan.LaunchContext
  • executionID *core.WorkflowExecutionIdentifier
  • launchPlanRef *core.Identifier
  • inputs *core.LiteralMap
  • parentWorkflowID string

type FlyteAdmin_GetLaunchPlan_Call added in v1.15.1 

type FlyteAdmin_GetLaunchPlan_Call struct {
	*mock.Call
}

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

func (*FlyteAdmin_GetLaunchPlan_Call) Return added in v1.15.1 

func (_c *FlyteAdmin_GetLaunchPlan_Call) Return(_a0 *admin.LaunchPlan, _a1 error) *FlyteAdmin_GetLaunchPlan_Call

func (*FlyteAdmin_GetLaunchPlan_Call) Run added in v1.15.1 

func (_c *FlyteAdmin_GetLaunchPlan_Call) Run(run func(ctx context.Context, launchPlanRef *core.Identifier)) *FlyteAdmin_GetLaunchPlan_Call

func (*FlyteAdmin_GetLaunchPlan_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteAdmin_GetLaunchPlan_Call) RunAndReturn(run func(context.Context, *core.Identifier) (*admin.LaunchPlan, error)) *FlyteAdmin_GetLaunchPlan_Call

type FlyteAdmin_GetStatus_Call added in v1.15.1 

type FlyteAdmin_GetStatus_Call struct {
	*mock.Call
}

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

func (*FlyteAdmin_GetStatus_Call) Return added in v1.15.1 

func (_c *FlyteAdmin_GetStatus_Call) Return(_a0 *admin.ExecutionClosure, _a1 *core.LiteralMap, _a2 error) *FlyteAdmin_GetStatus_Call

func (*FlyteAdmin_GetStatus_Call) Run added in v1.15.1 

func (_c *FlyteAdmin_GetStatus_Call) Run(run func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier)) *FlyteAdmin_GetStatus_Call

func (*FlyteAdmin_GetStatus_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteAdmin_GetStatus_Call) RunAndReturn(run func(context.Context, *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)) *FlyteAdmin_GetStatus_Call

type FlyteAdmin_Initialize_Call added in v1.15.1 

type FlyteAdmin_Initialize_Call struct {
	*mock.Call
}

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

func (*FlyteAdmin_Initialize_Call) Return added in v1.15.1 

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

func (*FlyteAdmin_Initialize_Call) Run added in v1.15.1 

func (_c *FlyteAdmin_Initialize_Call) Run(run func(ctx context.Context)) *FlyteAdmin_Initialize_Call

func (*FlyteAdmin_Initialize_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteAdmin_Initialize_Call) RunAndReturn(run func(context.Context) error) *FlyteAdmin_Initialize_Call

type FlyteAdmin_Kill_Call added in v1.15.1 

type FlyteAdmin_Kill_Call struct {
	*mock.Call
}

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

func (*FlyteAdmin_Kill_Call) Return added in v1.15.1 

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

func (*FlyteAdmin_Kill_Call) Run added in v1.15.1 

func (_c *FlyteAdmin_Kill_Call) Run(run func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string)) *FlyteAdmin_Kill_Call

func (*FlyteAdmin_Kill_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteAdmin_Kill_Call) RunAndReturn(run func(context.Context, *core.WorkflowExecutionIdentifier, string) error) *FlyteAdmin_Kill_Call

type FlyteAdmin_Launch_Call added in v1.15.1 

type FlyteAdmin_Launch_Call struct {
	*mock.Call
}

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

func (*FlyteAdmin_Launch_Call) Return added in v1.15.1 

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

func (*FlyteAdmin_Launch_Call) Run added in v1.15.1 

func (_c *FlyteAdmin_Launch_Call) Run(run func(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap, parentWorkflowID string)) *FlyteAdmin_Launch_Call

func (*FlyteAdmin_Launch_Call) RunAndReturn added in v1.15.1 

func (_c *FlyteAdmin_Launch_Call) RunAndReturn(run func(context.Context, launchplan.LaunchContext, *core.WorkflowExecutionIdentifier, *core.Identifier, *core.LiteralMap, string) error) *FlyteAdmin_Launch_Call

type Reader 

type Reader struct {
	mock.Mock
}

Reader is an autogenerated mock type for the Reader type

func NewReader added in v1.15.1 

func NewReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *Reader

NewReader creates a new instance of Reader. 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 (*Reader) EXPECT added in v1.15.1 

func (_m *Reader) EXPECT() *Reader_Expecter

func (*Reader) GetLaunchPlan 

func (_m *Reader) GetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) (*admin.LaunchPlan, error)

GetLaunchPlan provides a mock function with given fields: ctx, launchPlanRef

type Reader_Expecter added in v1.15.1 

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

func (*Reader_Expecter) GetLaunchPlan added in v1.15.1 

func (_e *Reader_Expecter) GetLaunchPlan(ctx interface{}, launchPlanRef interface{}) *Reader_GetLaunchPlan_Call

GetLaunchPlan is a helper method to define mock.On call

  • ctx context.Context
  • launchPlanRef *core.Identifier

type Reader_GetLaunchPlan_Call added in v1.15.1 

type Reader_GetLaunchPlan_Call struct {
	*mock.Call
}

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

func (*Reader_GetLaunchPlan_Call) Return added in v1.15.1 

func (_c *Reader_GetLaunchPlan_Call) Return(_a0 *admin.LaunchPlan, _a1 error) *Reader_GetLaunchPlan_Call

func (*Reader_GetLaunchPlan_Call) Run added in v1.15.1 

func (_c *Reader_GetLaunchPlan_Call) Run(run func(ctx context.Context, launchPlanRef *core.Identifier)) *Reader_GetLaunchPlan_Call

func (*Reader_GetLaunchPlan_Call) RunAndReturn added in v1.15.1 

func (_c *Reader_GetLaunchPlan_Call) RunAndReturn(run func(context.Context, *core.Identifier) (*admin.LaunchPlan, error)) *Reader_GetLaunchPlan_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.