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 KozmoAdmin
- func (_m *KozmoAdmin) GetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) (*admin.LaunchPlan, error)
- func (_m *KozmoAdmin) GetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)
- func (_m *KozmoAdmin) Initialize(ctx context.Context) error
- func (_m *KozmoAdmin) Kill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, ...) error
- func (_m *KozmoAdmin) Launch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) error
- func (_m *KozmoAdmin) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *KozmoAdmin_GetLaunchPlan
- func (_m *KozmoAdmin) OnGetLaunchPlanMatch(matchers ...interface{}) *KozmoAdmin_GetLaunchPlan
- func (_m *KozmoAdmin) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *KozmoAdmin_GetStatus
- func (_m *KozmoAdmin) OnGetStatusMatch(matchers ...interface{}) *KozmoAdmin_GetStatus
- func (_m *KozmoAdmin) OnInitialize(ctx context.Context) *KozmoAdmin_Initialize
- func (_m *KozmoAdmin) OnInitializeMatch(matchers ...interface{}) *KozmoAdmin_Initialize
- func (_m *KozmoAdmin) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, ...) *KozmoAdmin_Kill
- func (_m *KozmoAdmin) OnKillMatch(matchers ...interface{}) *KozmoAdmin_Kill
- func (_m *KozmoAdmin) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, ...) *KozmoAdmin_Launch
- func (_m *KozmoAdmin) OnLaunchMatch(matchers ...interface{}) *KozmoAdmin_Launch
- type KozmoAdmin_GetLaunchPlan
- type KozmoAdmin_GetStatus
- type KozmoAdmin_Initialize
- type KozmoAdmin_Kill
- type KozmoAdmin_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 KozmoAdmin ¶
KozmoAdmin is an autogenerated mock type for the KozmoAdmin type
func (*KozmoAdmin) GetLaunchPlan ¶
func (_m *KozmoAdmin) GetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) (*admin.LaunchPlan, error)
GetLaunchPlan provides a mock function with given fields: ctx, launchPlanRef
func (*KozmoAdmin) GetStatus ¶
func (_m *KozmoAdmin) GetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, *core.LiteralMap, error)
GetStatus provides a mock function with given fields: ctx, executionID
func (*KozmoAdmin) Initialize ¶
func (_m *KozmoAdmin) Initialize(ctx context.Context) error
Initialize provides a mock function with given fields: ctx
func (*KozmoAdmin) Kill ¶
func (_m *KozmoAdmin) Kill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) error
Kill provides a mock function with given fields: ctx, executionID, reason
func (*KozmoAdmin) Launch ¶
func (_m *KozmoAdmin) 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 (*KozmoAdmin) OnGetLaunchPlan ¶
func (_m *KozmoAdmin) OnGetLaunchPlan(ctx context.Context, launchPlanRef *core.Identifier) *KozmoAdmin_GetLaunchPlan
func (*KozmoAdmin) OnGetLaunchPlanMatch ¶
func (_m *KozmoAdmin) OnGetLaunchPlanMatch(matchers ...interface{}) *KozmoAdmin_GetLaunchPlan
func (*KozmoAdmin) OnGetStatus ¶
func (_m *KozmoAdmin) OnGetStatus(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) *KozmoAdmin_GetStatus
func (*KozmoAdmin) OnGetStatusMatch ¶
func (_m *KozmoAdmin) OnGetStatusMatch(matchers ...interface{}) *KozmoAdmin_GetStatus
func (*KozmoAdmin) OnInitialize ¶
func (_m *KozmoAdmin) OnInitialize(ctx context.Context) *KozmoAdmin_Initialize
func (*KozmoAdmin) OnInitializeMatch ¶
func (_m *KozmoAdmin) OnInitializeMatch(matchers ...interface{}) *KozmoAdmin_Initialize
func (*KozmoAdmin) OnKill ¶
func (_m *KozmoAdmin) OnKill(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, reason string) *KozmoAdmin_Kill
func (*KozmoAdmin) OnKillMatch ¶
func (_m *KozmoAdmin) OnKillMatch(matchers ...interface{}) *KozmoAdmin_Kill
func (*KozmoAdmin) OnLaunch ¶
func (_m *KozmoAdmin) OnLaunch(ctx context.Context, launchCtx launchplan.LaunchContext, executionID *core.WorkflowExecutionIdentifier, launchPlanRef *core.Identifier, inputs *core.LiteralMap) *KozmoAdmin_Launch
func (*KozmoAdmin) OnLaunchMatch ¶
func (_m *KozmoAdmin) OnLaunchMatch(matchers ...interface{}) *KozmoAdmin_Launch
type KozmoAdmin_GetLaunchPlan ¶
func (KozmoAdmin_GetLaunchPlan) Return ¶
func (_m KozmoAdmin_GetLaunchPlan) Return(_a0 *admin.LaunchPlan, _a1 error) *KozmoAdmin_GetLaunchPlan
type KozmoAdmin_GetStatus ¶
func (KozmoAdmin_GetStatus) Return ¶
func (_m KozmoAdmin_GetStatus) Return(_a0 *admin.ExecutionClosure, _a1 *core.LiteralMap, _a2 error) *KozmoAdmin_GetStatus
type KozmoAdmin_Initialize ¶
func (KozmoAdmin_Initialize) Return ¶
func (_m KozmoAdmin_Initialize) Return(_a0 error) *KozmoAdmin_Initialize
type KozmoAdmin_Kill ¶
func (KozmoAdmin_Kill) Return ¶
func (_m KozmoAdmin_Kill) Return(_a0 error) *KozmoAdmin_Kill
type KozmoAdmin_Launch ¶
func (KozmoAdmin_Launch) Return ¶
func (_m KozmoAdmin_Launch) Return(_a0 error) *KozmoAdmin_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