mocks

Apr 28, 2020

Changes in this version

+ type FlyteAdmin struct

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

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

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

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

+ func (_m *FlyteAdmin) Launch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) error

+ func (_m *FlyteAdmin) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *FlyteAdmin_GetLaunchPlan

+ func (_m *FlyteAdmin) OnGetLaunchPlanMatch(matchers ...interface{}) *FlyteAdmin_GetLaunchPlan

+ func (_m *FlyteAdmin) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *FlyteAdmin_GetStatus

+ func (_m *FlyteAdmin) OnGetStatusMatch(matchers ...interface{}) *FlyteAdmin_GetStatus

+ func (_m *FlyteAdmin) OnInitialize(ctx context.Context) *FlyteAdmin_Initialize

+ func (_m *FlyteAdmin) OnInitializeMatch(matchers ...interface{}) *FlyteAdmin_Initialize

+ func (_m *FlyteAdmin) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, ...) *FlyteAdmin_Kill

+ func (_m *FlyteAdmin) OnKillMatch(matchers ...interface{}) *FlyteAdmin_Kill

+ func (_m *FlyteAdmin) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) *FlyteAdmin_Launch

+ func (_m *FlyteAdmin) OnLaunchMatch(matchers ...interface{}) *FlyteAdmin_Launch

+ type FlyteAdmin_GetLaunchPlan struct

+ func (_m FlyteAdmin_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *FlyteAdmin_GetLaunchPlan

+ type FlyteAdmin_GetStatus struct

+ func (_m FlyteAdmin_GetStatus) Return(_a0 *admin.ExecutionClosure, _a1 error) *FlyteAdmin_GetStatus

+ type FlyteAdmin_Initialize struct

+ func (_m FlyteAdmin_Initialize) Return(_a0 error) *FlyteAdmin_Initialize

+ type FlyteAdmin_Kill struct

+ func (_m FlyteAdmin_Kill) Return(_a0 error) *FlyteAdmin_Kill

+ type FlyteAdmin_Launch struct

+ func (_m FlyteAdmin_Launch) Return(_a0 error) *FlyteAdmin_Launch

+ type Reader struct

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

+ func (_m *Reader) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *Reader_GetLaunchPlan

+ func (_m *Reader) OnGetLaunchPlanMatch(matchers ...interface{}) *Reader_GetLaunchPlan

+ type Reader_GetLaunchPlan struct

+ func (_m Reader_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *Reader_GetLaunchPlan

Apr 8, 2020

Changes in this version

type Executor

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

+ func (_m *Executor) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *Executor_GetLaunchPlan

+ func (_m *Executor) OnGetLaunchPlanMatch(matchers ...interface{}) *Executor_GetLaunchPlan

+ type Executor_GetLaunchPlan struct

+ func (_m Executor_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *Executor_GetLaunchPlan

Nov 12, 2019

Changes in this version

type Executor

+ func (_m *Executor) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *Executor_GetStatus

+ func (_m *Executor) OnGetStatusMatch(matchers ...interface{}) *Executor_GetStatus

+ func (_m *Executor) OnInitialize(ctx context.Context) *Executor_Initialize

+ func (_m *Executor) OnInitializeMatch(matchers ...interface{}) *Executor_Initialize

+ func (_m *Executor) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, ...) *Executor_Kill

+ func (_m *Executor) OnKillMatch(matchers ...interface{}) *Executor_Kill

+ func (_m *Executor) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) *Executor_Launch

+ func (_m *Executor) OnLaunchMatch(matchers ...interface{}) *Executor_Launch

+ type Executor_GetStatus struct

+ func (_m Executor_GetStatus) Return(_a0 *admin.ExecutionClosure, _a1 error) *Executor_GetStatus

+ type Executor_Initialize struct

+ func (_m Executor_Initialize) Return(_a0 error) *Executor_Initialize

+ type Executor_Kill struct

+ func (_m Executor_Kill) Return(_a0 error) *Executor_Kill

+ type Executor_Launch struct

+ func (_m Executor_Launch) Return(_a0 error) *Executor_Launch

Sep 6, 2019

Changes in this version

+ type Executor struct

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

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

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

+ func (_m *Executor) Launch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) error