Documentation ¶
Index ¶
- type Executor
- func (_m *Executor) GetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, 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
- 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
- type Executor_Initialize
- type Executor_Kill
- type Executor_Launch
- type FlyteAdmin
- 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, *core.LiteralMap, 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
- type FlyteAdmin_GetStatus
- type FlyteAdmin_Initialize
- type FlyteAdmin_Kill
- type FlyteAdmin_Launch
- type Reader
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
Executor is an autogenerated mock type for the Executor type
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 ¶
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) error
Launch provides a mock function with given fields: ctx, launchCtx, executionID, launchPlanRef, inputs
func (*Executor) OnGetStatus ¶
func (_m *Executor) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *Executor_GetStatus
func (*Executor) OnGetStatusMatch ¶
func (_m *Executor) OnGetStatusMatch(matchers ...interface{}) *Executor_GetStatus
func (*Executor) OnInitialize ¶
func (_m *Executor) OnInitialize(ctx context.Context) *Executor_Initialize
func (*Executor) OnInitializeMatch ¶
func (_m *Executor) OnInitializeMatch(matchers ...interface{}) *Executor_Initialize
func (*Executor) OnKill ¶
func (_m *Executor) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) *Executor_Kill
func (*Executor) OnKillMatch ¶
func (_m *Executor) OnKillMatch(matchers ...interface{}) *Executor_Kill
func (*Executor) OnLaunch ¶
func (_m *Executor) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap) *Executor_Launch
func (*Executor) OnLaunchMatch ¶
func (_m *Executor) OnLaunchMatch(matchers ...interface{}) *Executor_Launch
type Executor_GetStatus ¶
func (Executor_GetStatus) Return ¶
func (_m Executor_GetStatus) Return(_a0 *admin.ExecutionClosure, _a1 *core.LiteralMap, _a2 error) *Executor_GetStatus
type Executor_Initialize ¶
func (Executor_Initialize) Return ¶
func (_m Executor_Initialize) Return(_a0 error) *Executor_Initialize
type Executor_Kill ¶
func (Executor_Kill) Return ¶
func (_m Executor_Kill) Return(_a0 error) *Executor_Kill
type Executor_Launch ¶
func (Executor_Launch) Return ¶
func (_m Executor_Launch) Return(_a0 error) *Executor_Launch
type FlyteAdmin ¶
FlyteAdmin is an autogenerated mock type for the FlyteAdmin type
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) error
Launch provides a mock function with given fields: ctx, launchCtx, executionID, launchPlanRef, inputs
func (*FlyteAdmin) OnGetLaunchPlan ¶
func (_m *FlyteAdmin) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *FlyteAdmin_GetLaunchPlan
func (*FlyteAdmin) OnGetLaunchPlanMatch ¶
func (_m *FlyteAdmin) OnGetLaunchPlanMatch(matchers ...interface{}) *FlyteAdmin_GetLaunchPlan
func (*FlyteAdmin) OnGetStatus ¶
func (_m *FlyteAdmin) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *FlyteAdmin_GetStatus
func (*FlyteAdmin) OnGetStatusMatch ¶
func (_m *FlyteAdmin) OnGetStatusMatch(matchers ...interface{}) *FlyteAdmin_GetStatus
func (*FlyteAdmin) OnInitialize ¶
func (_m *FlyteAdmin) OnInitialize(ctx context.Context) *FlyteAdmin_Initialize
func (*FlyteAdmin) OnInitializeMatch ¶
func (_m *FlyteAdmin) OnInitializeMatch(matchers ...interface{}) *FlyteAdmin_Initialize
func (*FlyteAdmin) OnKill ¶
func (_m *FlyteAdmin) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) *FlyteAdmin_Kill
func (*FlyteAdmin) OnKillMatch ¶
func (_m *FlyteAdmin) OnKillMatch(matchers ...interface{}) *FlyteAdmin_Kill
func (*FlyteAdmin) OnLaunch ¶
func (_m *FlyteAdmin) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap) *FlyteAdmin_Launch
func (*FlyteAdmin) OnLaunchMatch ¶
func (_m *FlyteAdmin) OnLaunchMatch(matchers ...interface{}) *FlyteAdmin_Launch
type FlyteAdmin_GetLaunchPlan ¶
func (FlyteAdmin_GetLaunchPlan) Return ¶
func (_m FlyteAdmin_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *FlyteAdmin_GetLaunchPlan
type FlyteAdmin_GetStatus ¶
func (FlyteAdmin_GetStatus) Return ¶
func (_m FlyteAdmin_GetStatus) Return(_a0 *admin.ExecutionClosure, _a1 *core.LiteralMap, _a2 error) *FlyteAdmin_GetStatus
type FlyteAdmin_Initialize ¶
func (FlyteAdmin_Initialize) Return ¶
func (_m FlyteAdmin_Initialize) Return(_a0 error) *FlyteAdmin_Initialize
type FlyteAdmin_Kill ¶
func (FlyteAdmin_Kill) Return ¶
func (_m FlyteAdmin_Kill) Return(_a0 error) *FlyteAdmin_Kill
type FlyteAdmin_Launch ¶
func (FlyteAdmin_Launch) Return ¶
func (_m FlyteAdmin_Launch) Return(_a0 error) *FlyteAdmin_Launch
type Reader ¶
Reader is an autogenerated mock type for the Reader type
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
func (*Reader) OnGetLaunchPlan ¶
func (_m *Reader) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *Reader_GetLaunchPlan
func (*Reader) OnGetLaunchPlanMatch ¶
func (_m *Reader) OnGetLaunchPlanMatch(matchers ...interface{}) *Reader_GetLaunchPlan
type Reader_GetLaunchPlan ¶
func (Reader_GetLaunchPlan) Return ¶
func (_m Reader_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *Reader_GetLaunchPlan