Documentation
¶
Index ¶
- type Client
- func (_mock *Client) CancelWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) error
- func (_mock *Client) DefineAndRunWorkflow(ctx context.Context, params workflow.DefineWorkflowParams, ...) (models.Workflow, error)
- func (_mock *Client) DefineWorkflow(ctx context.Context, params workflow.DefineWorkflowParams, ...) (models.Workflow, error)
- func (_mock *Client) DeleteWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) error
- func (_m *Client) EXPECT() *Client_Expecter
- func (_mock *Client) GetWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) (models.Workflow, error)
- func (_mock *Client) GetWorkflowStep(ctx context.Context, stepID string, activeDBClient db.Database) (models.WorkflowStep, []models.WorkflowStepExecution, error)
- func (_mock *Client) ListWorkflowSteps(ctx context.Context, workflowID string, activeDBClient db.Database) ([]models.WorkflowStep, error)
- func (_mock *Client) ListWorkflows(ctx context.Context, filters db.WorkflowQueryFilter, ...) ([]models.Workflow, error)
- func (_mock *Client) ReviveWorkflow(ctx context.Context, workflowID string, newDeadline *time.Time, ...) error
- func (_mock *Client) SubmitWorkflow(ctx context.Context, workflowID string) error
- type Client_CancelWorkflow_Call
- func (_c *Client_CancelWorkflow_Call) Return(err error) *Client_CancelWorkflow_Call
- func (_c *Client_CancelWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_CancelWorkflow_Call
- func (_c *Client_CancelWorkflow_Call) RunAndReturn(...) *Client_CancelWorkflow_Call
- type Client_DefineAndRunWorkflow_Call
- func (_c *Client_DefineAndRunWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_DefineAndRunWorkflow_Call
- func (_c *Client_DefineAndRunWorkflow_Call) Run(run func(ctx context.Context, params workflow.DefineWorkflowParams, ...)) *Client_DefineAndRunWorkflow_Call
- func (_c *Client_DefineAndRunWorkflow_Call) RunAndReturn(...) *Client_DefineAndRunWorkflow_Call
- type Client_DefineWorkflow_Call
- func (_c *Client_DefineWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_DefineWorkflow_Call
- func (_c *Client_DefineWorkflow_Call) Run(run func(ctx context.Context, params workflow.DefineWorkflowParams, ...)) *Client_DefineWorkflow_Call
- func (_c *Client_DefineWorkflow_Call) RunAndReturn(...) *Client_DefineWorkflow_Call
- type Client_DeleteWorkflow_Call
- func (_c *Client_DeleteWorkflow_Call) Return(err error) *Client_DeleteWorkflow_Call
- func (_c *Client_DeleteWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_DeleteWorkflow_Call
- func (_c *Client_DeleteWorkflow_Call) RunAndReturn(...) *Client_DeleteWorkflow_Call
- type Client_Expecter
- func (_e *Client_Expecter) CancelWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_CancelWorkflow_Call
- func (_e *Client_Expecter) DefineAndRunWorkflow(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineAndRunWorkflow_Call
- func (_e *Client_Expecter) DefineWorkflow(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineWorkflow_Call
- func (_e *Client_Expecter) DeleteWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_DeleteWorkflow_Call
- func (_e *Client_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_GetWorkflow_Call
- func (_e *Client_Expecter) GetWorkflowStep(ctx interface{}, stepID interface{}, activeDBClient interface{}) *Client_GetWorkflowStep_Call
- func (_e *Client_Expecter) ListWorkflowSteps(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_ListWorkflowSteps_Call
- func (_e *Client_Expecter) ListWorkflows(ctx interface{}, filters interface{}, activeDBClient interface{}) *Client_ListWorkflows_Call
- func (_e *Client_Expecter) ReviveWorkflow(ctx interface{}, workflowID interface{}, newDeadline interface{}, ...) *Client_ReviveWorkflow_Call
- func (_e *Client_Expecter) SubmitWorkflow(ctx interface{}, workflowID interface{}) *Client_SubmitWorkflow_Call
- type Client_GetWorkflowStep_Call
- func (_c *Client_GetWorkflowStep_Call) Return(workflowStep models.WorkflowStep, ...) *Client_GetWorkflowStep_Call
- func (_c *Client_GetWorkflowStep_Call) Run(run func(ctx context.Context, stepID string, activeDBClient db.Database)) *Client_GetWorkflowStep_Call
- func (_c *Client_GetWorkflowStep_Call) RunAndReturn(...) *Client_GetWorkflowStep_Call
- type Client_GetWorkflow_Call
- func (_c *Client_GetWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_GetWorkflow_Call
- func (_c *Client_GetWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_GetWorkflow_Call
- func (_c *Client_GetWorkflow_Call) RunAndReturn(...) *Client_GetWorkflow_Call
- type Client_ListWorkflowSteps_Call
- func (_c *Client_ListWorkflowSteps_Call) Return(workflowSteps []models.WorkflowStep, err error) *Client_ListWorkflowSteps_Call
- func (_c *Client_ListWorkflowSteps_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_ListWorkflowSteps_Call
- func (_c *Client_ListWorkflowSteps_Call) RunAndReturn(...) *Client_ListWorkflowSteps_Call
- type Client_ListWorkflows_Call
- func (_c *Client_ListWorkflows_Call) Return(workflows []models.Workflow, err error) *Client_ListWorkflows_Call
- func (_c *Client_ListWorkflows_Call) Run(run func(ctx context.Context, filters db.WorkflowQueryFilter, ...)) *Client_ListWorkflows_Call
- func (_c *Client_ListWorkflows_Call) RunAndReturn(...) *Client_ListWorkflows_Call
- type Client_ReviveWorkflow_Call
- func (_c *Client_ReviveWorkflow_Call) Return(err error) *Client_ReviveWorkflow_Call
- func (_c *Client_ReviveWorkflow_Call) Run(run func(ctx context.Context, workflowID string, newDeadline *time.Time, ...)) *Client_ReviveWorkflow_Call
- func (_c *Client_ReviveWorkflow_Call) RunAndReturn(...) *Client_ReviveWorkflow_Call
- type Client_SubmitWorkflow_Call
- func (_c *Client_SubmitWorkflow_Call) Return(err error) *Client_SubmitWorkflow_Call
- func (_c *Client_SubmitWorkflow_Call) Run(run func(ctx context.Context, workflowID string)) *Client_SubmitWorkflow_Call
- func (_c *Client_SubmitWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string) error) *Client_SubmitWorkflow_Call
- type Scheduler
- type Scheduler_Expecter
- type Scheduler_Start_Call
- type Scheduler_Stop_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
NewClient creates a new instance of Client. 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 (*Client) CancelWorkflow ¶
func (_mock *Client) CancelWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) error
CancelWorkflow provides a mock function for the type Client
func (*Client) DefineAndRunWorkflow ¶
func (_mock *Client) DefineAndRunWorkflow(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database) (models.Workflow, error)
DefineAndRunWorkflow provides a mock function for the type Client
func (*Client) DefineWorkflow ¶
func (_mock *Client) DefineWorkflow(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database) (models.Workflow, error)
DefineWorkflow provides a mock function for the type Client
func (*Client) DeleteWorkflow ¶
func (_mock *Client) DeleteWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) error
DeleteWorkflow provides a mock function for the type Client
func (*Client) EXPECT ¶
func (_m *Client) EXPECT() *Client_Expecter
func (*Client) GetWorkflow ¶
func (_mock *Client) GetWorkflow(ctx context.Context, workflowID string, activeDBClient db.Database) (models.Workflow, error)
GetWorkflow provides a mock function for the type Client
func (*Client) GetWorkflowStep ¶
func (_mock *Client) GetWorkflowStep(ctx context.Context, stepID string, activeDBClient db.Database) (models.WorkflowStep, []models.WorkflowStepExecution, error)
GetWorkflowStep provides a mock function for the type Client
func (*Client) ListWorkflowSteps ¶
func (_mock *Client) ListWorkflowSteps(ctx context.Context, workflowID string, activeDBClient db.Database) ([]models.WorkflowStep, error)
ListWorkflowSteps provides a mock function for the type Client
func (*Client) ListWorkflows ¶
func (_mock *Client) ListWorkflows(ctx context.Context, filters db.WorkflowQueryFilter, activeDBClient db.Database) ([]models.Workflow, error)
ListWorkflows provides a mock function for the type Client
type Client_CancelWorkflow_Call ¶
Client_CancelWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelWorkflow'
func (*Client_CancelWorkflow_Call) Return ¶
func (_c *Client_CancelWorkflow_Call) Return(err error) *Client_CancelWorkflow_Call
func (*Client_CancelWorkflow_Call) Run ¶
func (_c *Client_CancelWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_CancelWorkflow_Call
func (*Client_CancelWorkflow_Call) RunAndReturn ¶
func (_c *Client_CancelWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string, activeDBClient db.Database) error) *Client_CancelWorkflow_Call
type Client_DefineAndRunWorkflow_Call ¶
Client_DefineAndRunWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineAndRunWorkflow'
func (*Client_DefineAndRunWorkflow_Call) Return ¶
func (_c *Client_DefineAndRunWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_DefineAndRunWorkflow_Call
func (*Client_DefineAndRunWorkflow_Call) Run ¶
func (_c *Client_DefineAndRunWorkflow_Call) Run(run func(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database)) *Client_DefineAndRunWorkflow_Call
func (*Client_DefineAndRunWorkflow_Call) RunAndReturn ¶
func (_c *Client_DefineAndRunWorkflow_Call) RunAndReturn(run func(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database) (models.Workflow, error)) *Client_DefineAndRunWorkflow_Call
type Client_DefineWorkflow_Call ¶
Client_DefineWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineWorkflow'
func (*Client_DefineWorkflow_Call) Return ¶
func (_c *Client_DefineWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_DefineWorkflow_Call
func (*Client_DefineWorkflow_Call) Run ¶
func (_c *Client_DefineWorkflow_Call) Run(run func(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database)) *Client_DefineWorkflow_Call
func (*Client_DefineWorkflow_Call) RunAndReturn ¶
func (_c *Client_DefineWorkflow_Call) RunAndReturn(run func(ctx context.Context, params workflow.DefineWorkflowParams, activeDBClient db.Database) (models.Workflow, error)) *Client_DefineWorkflow_Call
type Client_DeleteWorkflow_Call ¶
Client_DeleteWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteWorkflow'
func (*Client_DeleteWorkflow_Call) Return ¶
func (_c *Client_DeleteWorkflow_Call) Return(err error) *Client_DeleteWorkflow_Call
func (*Client_DeleteWorkflow_Call) Run ¶
func (_c *Client_DeleteWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_DeleteWorkflow_Call
func (*Client_DeleteWorkflow_Call) RunAndReturn ¶
func (_c *Client_DeleteWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string, activeDBClient db.Database) error) *Client_DeleteWorkflow_Call
type Client_Expecter ¶
type Client_Expecter struct {
// contains filtered or unexported fields
}
func (*Client_Expecter) CancelWorkflow ¶
func (_e *Client_Expecter) CancelWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_CancelWorkflow_Call
CancelWorkflow is a helper method to define mock.On call
- ctx context.Context
- workflowID string
- activeDBClient db.Database
func (*Client_Expecter) DefineAndRunWorkflow ¶
func (_e *Client_Expecter) DefineAndRunWorkflow(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineAndRunWorkflow_Call
DefineAndRunWorkflow is a helper method to define mock.On call
- ctx context.Context
- params workflow.DefineWorkflowParams
- activeDBClient db.Database
func (*Client_Expecter) DefineWorkflow ¶
func (_e *Client_Expecter) DefineWorkflow(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineWorkflow_Call
DefineWorkflow is a helper method to define mock.On call
- ctx context.Context
- params workflow.DefineWorkflowParams
- activeDBClient db.Database
func (*Client_Expecter) DeleteWorkflow ¶
func (_e *Client_Expecter) DeleteWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_DeleteWorkflow_Call
DeleteWorkflow is a helper method to define mock.On call
- ctx context.Context
- workflowID string
- activeDBClient db.Database
func (*Client_Expecter) GetWorkflow ¶
func (_e *Client_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_GetWorkflow_Call
GetWorkflow is a helper method to define mock.On call
- ctx context.Context
- workflowID string
- activeDBClient db.Database
func (*Client_Expecter) GetWorkflowStep ¶
func (_e *Client_Expecter) GetWorkflowStep(ctx interface{}, stepID interface{}, activeDBClient interface{}) *Client_GetWorkflowStep_Call
GetWorkflowStep is a helper method to define mock.On call
- ctx context.Context
- stepID string
- activeDBClient db.Database
func (*Client_Expecter) ListWorkflowSteps ¶
func (_e *Client_Expecter) ListWorkflowSteps(ctx interface{}, workflowID interface{}, activeDBClient interface{}) *Client_ListWorkflowSteps_Call
ListWorkflowSteps is a helper method to define mock.On call
- ctx context.Context
- workflowID string
- activeDBClient db.Database
func (*Client_Expecter) ListWorkflows ¶
func (_e *Client_Expecter) ListWorkflows(ctx interface{}, filters interface{}, activeDBClient interface{}) *Client_ListWorkflows_Call
ListWorkflows is a helper method to define mock.On call
- ctx context.Context
- filters db.WorkflowQueryFilter
- activeDBClient db.Database
func (*Client_Expecter) ReviveWorkflow ¶
func (_e *Client_Expecter) ReviveWorkflow(ctx interface{}, workflowID interface{}, newDeadline interface{}, activeDBClient interface{}) *Client_ReviveWorkflow_Call
ReviveWorkflow is a helper method to define mock.On call
- ctx context.Context
- workflowID string
- newDeadline *time.Time
- activeDBClient db.Database
func (*Client_Expecter) SubmitWorkflow ¶
func (_e *Client_Expecter) SubmitWorkflow(ctx interface{}, workflowID interface{}) *Client_SubmitWorkflow_Call
SubmitWorkflow is a helper method to define mock.On call
- ctx context.Context
- workflowID string
type Client_GetWorkflowStep_Call ¶
Client_GetWorkflowStep_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowStep'
func (*Client_GetWorkflowStep_Call) Return ¶
func (_c *Client_GetWorkflowStep_Call) Return(workflowStep models.WorkflowStep, workflowStepExecutions []models.WorkflowStepExecution, err error) *Client_GetWorkflowStep_Call
func (*Client_GetWorkflowStep_Call) Run ¶
func (_c *Client_GetWorkflowStep_Call) Run(run func(ctx context.Context, stepID string, activeDBClient db.Database)) *Client_GetWorkflowStep_Call
func (*Client_GetWorkflowStep_Call) RunAndReturn ¶
func (_c *Client_GetWorkflowStep_Call) RunAndReturn(run func(ctx context.Context, stepID string, activeDBClient db.Database) (models.WorkflowStep, []models.WorkflowStepExecution, error)) *Client_GetWorkflowStep_Call
type Client_GetWorkflow_Call ¶
Client_GetWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflow'
func (*Client_GetWorkflow_Call) Return ¶
func (_c *Client_GetWorkflow_Call) Return(workflow1 models.Workflow, err error) *Client_GetWorkflow_Call
func (*Client_GetWorkflow_Call) Run ¶
func (_c *Client_GetWorkflow_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_GetWorkflow_Call
func (*Client_GetWorkflow_Call) RunAndReturn ¶
func (_c *Client_GetWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string, activeDBClient db.Database) (models.Workflow, error)) *Client_GetWorkflow_Call
type Client_ListWorkflowSteps_Call ¶
Client_ListWorkflowSteps_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflowSteps'
func (*Client_ListWorkflowSteps_Call) Return ¶
func (_c *Client_ListWorkflowSteps_Call) Return(workflowSteps []models.WorkflowStep, err error) *Client_ListWorkflowSteps_Call
func (*Client_ListWorkflowSteps_Call) Run ¶
func (_c *Client_ListWorkflowSteps_Call) Run(run func(ctx context.Context, workflowID string, activeDBClient db.Database)) *Client_ListWorkflowSteps_Call
func (*Client_ListWorkflowSteps_Call) RunAndReturn ¶
func (_c *Client_ListWorkflowSteps_Call) RunAndReturn(run func(ctx context.Context, workflowID string, activeDBClient db.Database) ([]models.WorkflowStep, error)) *Client_ListWorkflowSteps_Call
type Client_ListWorkflows_Call ¶
Client_ListWorkflows_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflows'
func (*Client_ListWorkflows_Call) Return ¶
func (_c *Client_ListWorkflows_Call) Return(workflows []models.Workflow, err error) *Client_ListWorkflows_Call
func (*Client_ListWorkflows_Call) Run ¶
func (_c *Client_ListWorkflows_Call) Run(run func(ctx context.Context, filters db.WorkflowQueryFilter, activeDBClient db.Database)) *Client_ListWorkflows_Call
func (*Client_ListWorkflows_Call) RunAndReturn ¶
func (_c *Client_ListWorkflows_Call) RunAndReturn(run func(ctx context.Context, filters db.WorkflowQueryFilter, activeDBClient db.Database) ([]models.Workflow, error)) *Client_ListWorkflows_Call
type Client_ReviveWorkflow_Call ¶
Client_ReviveWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReviveWorkflow'
func (*Client_ReviveWorkflow_Call) Return ¶
func (_c *Client_ReviveWorkflow_Call) Return(err error) *Client_ReviveWorkflow_Call
func (*Client_ReviveWorkflow_Call) Run ¶
func (_c *Client_ReviveWorkflow_Call) Run(run func(ctx context.Context, workflowID string, newDeadline *time.Time, activeDBClient db.Database)) *Client_ReviveWorkflow_Call
func (*Client_ReviveWorkflow_Call) RunAndReturn ¶
func (_c *Client_ReviveWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string, newDeadline *time.Time, activeDBClient db.Database) error) *Client_ReviveWorkflow_Call
type Client_SubmitWorkflow_Call ¶
Client_SubmitWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitWorkflow'
func (*Client_SubmitWorkflow_Call) Return ¶
func (_c *Client_SubmitWorkflow_Call) Return(err error) *Client_SubmitWorkflow_Call
func (*Client_SubmitWorkflow_Call) Run ¶
func (_c *Client_SubmitWorkflow_Call) Run(run func(ctx context.Context, workflowID string)) *Client_SubmitWorkflow_Call
func (*Client_SubmitWorkflow_Call) RunAndReturn ¶
func (_c *Client_SubmitWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string) error) *Client_SubmitWorkflow_Call
type Scheduler ¶
Scheduler is an autogenerated mock type for the Scheduler type
func NewScheduler ¶
NewScheduler creates a new instance of Scheduler. 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 (*Scheduler) EXPECT ¶
func (_m *Scheduler) EXPECT() *Scheduler_Expecter
type Scheduler_Expecter ¶
type Scheduler_Expecter struct {
// contains filtered or unexported fields
}
func (*Scheduler_Expecter) Start ¶
func (_e *Scheduler_Expecter) Start(ctx interface{}) *Scheduler_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Scheduler_Expecter) Stop ¶
func (_e *Scheduler_Expecter) Stop(ctx interface{}) *Scheduler_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
type Scheduler_Start_Call ¶
Scheduler_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Scheduler_Start_Call) Return ¶
func (_c *Scheduler_Start_Call) Return(err error) *Scheduler_Start_Call
func (*Scheduler_Start_Call) Run ¶
func (_c *Scheduler_Start_Call) Run(run func(ctx context.Context)) *Scheduler_Start_Call
func (*Scheduler_Start_Call) RunAndReturn ¶
func (_c *Scheduler_Start_Call) RunAndReturn(run func(ctx context.Context) error) *Scheduler_Start_Call
type Scheduler_Stop_Call ¶
Scheduler_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Scheduler_Stop_Call) Return ¶
func (_c *Scheduler_Stop_Call) Return(err error) *Scheduler_Stop_Call
func (*Scheduler_Stop_Call) Run ¶
func (_c *Scheduler_Stop_Call) Run(run func(ctx context.Context)) *Scheduler_Stop_Call
func (*Scheduler_Stop_Call) RunAndReturn ¶
func (_c *Scheduler_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Scheduler_Stop_Call