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