mockdb

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 11, 2026 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient 

func NewClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *Client

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) EXPECT 

func (_m *Client) EXPECT() *Client_Expecter

func (*Client) RunSQLInTransaction 

func (_mock *Client) RunSQLInTransaction(ctx context.Context, coreLogic func(ctx context.Context, tx *gorm.DB) error) error

RunSQLInTransaction provides a mock function for the type Client

func (*Client) UseDatabaseInTransaction 

func (_mock *Client) UseDatabaseInTransaction(ctx context.Context, coreLogic func(ctx context.Context, dbClient db.Database) error) error

UseDatabaseInTransaction provides a mock function for the type Client

type Client_Expecter 

type Client_Expecter struct {
	// contains filtered or unexported fields
}

func (*Client_Expecter) RunSQLInTransaction 

func (_e *Client_Expecter) RunSQLInTransaction(ctx interface{}, coreLogic interface{}) *Client_RunSQLInTransaction_Call

RunSQLInTransaction is a helper method to define mock.On call

  • ctx context.Context
  • coreLogic func(ctx context.Context, tx *gorm.DB) error

func (*Client_Expecter) UseDatabaseInTransaction 

func (_e *Client_Expecter) UseDatabaseInTransaction(ctx interface{}, coreLogic interface{}) *Client_UseDatabaseInTransaction_Call

UseDatabaseInTransaction is a helper method to define mock.On call

  • ctx context.Context
  • coreLogic func(ctx context.Context, dbClient db.Database) error

type Client_RunSQLInTransaction_Call 

type Client_RunSQLInTransaction_Call struct {
	*mock.Call
}

Client_RunSQLInTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunSQLInTransaction'

func (*Client_RunSQLInTransaction_Call) Return 

func (_c *Client_RunSQLInTransaction_Call) Return(err error) *Client_RunSQLInTransaction_Call

func (*Client_RunSQLInTransaction_Call) Run 

func (_c *Client_RunSQLInTransaction_Call) Run(run func(ctx context.Context, coreLogic func(ctx context.Context, tx *gorm.DB) error)) *Client_RunSQLInTransaction_Call

func (*Client_RunSQLInTransaction_Call) RunAndReturn 

func (_c *Client_RunSQLInTransaction_Call) RunAndReturn(run func(ctx context.Context, coreLogic func(ctx context.Context, tx *gorm.DB) error) error) *Client_RunSQLInTransaction_Call

type Client_UseDatabaseInTransaction_Call 

type Client_UseDatabaseInTransaction_Call struct {
	*mock.Call
}

Client_UseDatabaseInTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UseDatabaseInTransaction'

func (*Client_UseDatabaseInTransaction_Call) Return 

func (_c *Client_UseDatabaseInTransaction_Call) Return(err error) *Client_UseDatabaseInTransaction_Call

func (*Client_UseDatabaseInTransaction_Call) Run 

func (_c *Client_UseDatabaseInTransaction_Call) Run(run func(ctx context.Context, coreLogic func(ctx context.Context, dbClient db.Database) error)) *Client_UseDatabaseInTransaction_Call

func (*Client_UseDatabaseInTransaction_Call) RunAndReturn 

func (_c *Client_UseDatabaseInTransaction_Call) RunAndReturn(run func(ctx context.Context, coreLogic func(ctx context.Context, dbClient db.Database) error) error) *Client_UseDatabaseInTransaction_Call

type Database 

type Database struct {
	mock.Mock
}

Database is an autogenerated mock type for the Database type

func NewDatabase 

func NewDatabase(t interface {
	mock.TestingT
	Cleanup(func())
}) *Database

NewDatabase creates a new instance of Database. 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 (*Database) DefineNewOneShotTask 

func (_mock *Database) DefineNewOneShotTask(ctx context.Context, params db.NewTaskParameter) (models.Task, error)

DefineNewOneShotTask provides a mock function for the type Database

func (*Database) DefineNewScheduledOneShotTask 

func (_mock *Database) DefineNewScheduledOneShotTask(ctx context.Context, params db.NewTaskParameter, targetRuntime time.Time) (models.Task, error)

DefineNewScheduledOneShotTask provides a mock function for the type Database

func (*Database) DefineNewTaskExecInstance 

func (_mock *Database) DefineNewTaskExecInstance(ctx context.Context, task models.Task) (models.TaskExecution, error)

DefineNewTaskExecInstance provides a mock function for the type Database

func (*Database) DefineNewTaskRetryExecInstance 

func (_mock *Database) DefineNewTaskRetryExecInstance(ctx context.Context, task models.Task, failedEntry models.TaskExecution, targetRunTime time.Time) (models.TaskExecution, error)

DefineNewTaskRetryExecInstance provides a mock function for the type Database

func (*Database) DefineNewWorkflow 

func (_mock *Database) DefineNewWorkflow(ctx context.Context, workflowSpec models.NewWorkflowParameter, creator string) (models.Workflow, error)

DefineNewWorkflow provides a mock function for the type Database

func (*Database) DeleteTask 

func (_mock *Database) DeleteTask(ctx context.Context, taskID string) error

DeleteTask provides a mock function for the type Database

func (*Database) DeleteWorkflow 

func (_mock *Database) DeleteWorkflow(ctx context.Context, workflowID string) error

DeleteWorkflow provides a mock function for the type Database

func (*Database) EXPECT 

func (_m *Database) EXPECT() *Database_Expecter

func (*Database) GetTask 

func (_mock *Database) GetTask(ctx context.Context, taskID string) (models.Task, error)

GetTask provides a mock function for the type Database

func (*Database) GetTaskExecution 

func (_mock *Database) GetTaskExecution(ctx context.Context, instanceID string) (models.TaskExecution, error)

GetTaskExecution provides a mock function for the type Database

func (*Database) GetWorkflow 

func (_mock *Database) GetWorkflow(ctx context.Context, workflowID string) (models.Workflow, error)

GetWorkflow provides a mock function for the type Database

func (*Database) GetWorkflowStep 

func (_mock *Database) GetWorkflowStep(ctx context.Context, stepID string) (models.WorkflowStep, error)

GetWorkflowStep provides a mock function for the type Database

func (*Database) GetWorkflowStepAndExecutorTask 

func (_mock *Database) GetWorkflowStepAndExecutorTask(cxt context.Context, stepID string, activeTask bool) (models.WorkflowStep, []models.Task, error)

GetWorkflowStepAndExecutorTask provides a mock function for the type Database

func (*Database) GetWorkflowStepProcessedByTask 

func (_mock *Database) GetWorkflowStepProcessedByTask(ctx context.Context, taskID string) (models.WorkflowStep, error)

GetWorkflowStepProcessedByTask provides a mock function for the type Database

func (*Database) LinkWorkflowStepWithExecutorTask 

func (_mock *Database) LinkWorkflowStepWithExecutorTask(ctx context.Context, stepID string, taskID string) error

LinkWorkflowStepWithExecutorTask provides a mock function for the type Database

func (*Database) ListAllExecutions 

func (_mock *Database) ListAllExecutions(ctx context.Context, filters db.TaskExecutionQueryFilter) ([]models.TaskExecution, error)

ListAllExecutions provides a mock function for the type Database

func (*Database) ListSystemEvents 

func (_mock *Database) ListSystemEvents(ctx context.Context, filters db.SystemEventQueryFilter) ([]models.SystemEventAudit, error)

ListSystemEvents provides a mock function for the type Database

func (*Database) ListTaskExecutions 

func (_mock *Database) ListTaskExecutions(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter) ([]models.TaskExecution, error)

ListTaskExecutions provides a mock function for the type Database

func (*Database) ListTasks 

func (_mock *Database) ListTasks(ctx context.Context, filters db.TaskQueryFilter) ([]models.Task, error)

ListTasks provides a mock function for the type Database

func (*Database) ListWorkflowSteps 

func (_mock *Database) ListWorkflowSteps(ctx context.Context, workflowID string) ([]models.WorkflowStep, error)

ListWorkflowSteps provides a mock function for the type Database

func (*Database) ListWorkflowStepsReadyToRun 

func (_mock *Database) ListWorkflowStepsReadyToRun(ctx context.Context, workflowID string) ([]models.WorkflowStep, error)

ListWorkflowStepsReadyToRun provides a mock function for the type Database

func (*Database) ListWorkflows 

func (_mock *Database) ListWorkflows(ctx context.Context, filters db.WorkflowQueryFilter) ([]models.Workflow, error)

ListWorkflows provides a mock function for the type Database

func (*Database) MarkSystemEventsBroadcast 

func (_mock *Database) MarkSystemEventsBroadcast(ctx context.Context, eventIDs []string, broadcastAt time.Time) error

MarkSystemEventsBroadcast provides a mock function for the type Database

func (*Database) MarkTaskActive 

func (_mock *Database) MarkTaskActive(ctx context.Context, taskID string) error

MarkTaskActive provides a mock function for the type Database

func (*Database) MarkTaskCancelled 

func (_mock *Database) MarkTaskCancelled(ctx context.Context, taskID string) error

MarkTaskCancelled provides a mock function for the type Database

func (*Database) MarkTaskCancelling 

func (_mock *Database) MarkTaskCancelling(ctx context.Context, taskID string) error

MarkTaskCancelling provides a mock function for the type Database

func (*Database) MarkTaskComplete 

func (_mock *Database) MarkTaskComplete(ctx context.Context, taskID string) error

MarkTaskComplete provides a mock function for the type Database

func (*Database) MarkTaskExecAcquired 

func (_mock *Database) MarkTaskExecAcquired(ctx context.Context, instanceID string, workerName string) error

MarkTaskExecAcquired provides a mock function for the type Database

func (*Database) MarkTaskExecCancelled 

func (_mock *Database) MarkTaskExecCancelled(ctx context.Context, instanceID string, cancelMsg string, terminatedAt time.Time) error

MarkTaskExecCancelled provides a mock function for the type Database

func (*Database) MarkTaskExecFailed 

func (_mock *Database) MarkTaskExecFailed(ctx context.Context, instanceID string, errorMsg string, disposition *models.TaskFailureDispositionENUM, terminatedAt time.Time) error

MarkTaskExecFailed provides a mock function for the type Database

func (*Database) MarkTaskExecFinalized 

func (_mock *Database) MarkTaskExecFinalized(ctx context.Context, instanceID string) error

MarkTaskExecFinalized provides a mock function for the type Database

func (*Database) MarkTaskExecProcessed 

func (_mock *Database) MarkTaskExecProcessed(ctx context.Context, instanceID string, terminatedAt time.Time) error

MarkTaskExecProcessed provides a mock function for the type Database

func (*Database) MarkTaskExecProcessing 

func (_mock *Database) MarkTaskExecProcessing(ctx context.Context, instanceID string) error

MarkTaskExecProcessing provides a mock function for the type Database

func (*Database) MarkTaskExecQueued 

func (_mock *Database) MarkTaskExecQueued(ctx context.Context, instanceID string) error

MarkTaskExecQueued provides a mock function for the type Database

func (*Database) MarkTaskFailed 

func (_mock *Database) MarkTaskFailed(ctx context.Context, taskID string) error

MarkTaskFailed provides a mock function for the type Database

func (*Database) MarkTaskTimedOut 

func (_mock *Database) MarkTaskTimedOut(ctx context.Context, taskID string) error

MarkTaskTimedOut provides a mock function for the type Database

func (*Database) MarkWorkflowCancelled 

func (_mock *Database) MarkWorkflowCancelled(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowCancelled provides a mock function for the type Database

func (*Database) MarkWorkflowCancelling 

func (_mock *Database) MarkWorkflowCancelling(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowCancelling provides a mock function for the type Database

func (*Database) MarkWorkflowComplete 

func (_mock *Database) MarkWorkflowComplete(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowComplete provides a mock function for the type Database

func (*Database) MarkWorkflowFailed 

func (_mock *Database) MarkWorkflowFailed(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowFailed provides a mock function for the type Database

func (*Database) MarkWorkflowPending 

func (_mock *Database) MarkWorkflowPending(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowPending provides a mock function for the type Database

func (*Database) MarkWorkflowRunning 

func (_mock *Database) MarkWorkflowRunning(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowRunning provides a mock function for the type Database

func (*Database) MarkWorkflowStepCancelled 

func (_mock *Database) MarkWorkflowStepCancelled(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepCancelled provides a mock function for the type Database

func (*Database) MarkWorkflowStepCancelling 

func (_mock *Database) MarkWorkflowStepCancelling(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepCancelling provides a mock function for the type Database

func (*Database) MarkWorkflowStepComplete 

func (_mock *Database) MarkWorkflowStepComplete(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepComplete provides a mock function for the type Database

func (*Database) MarkWorkflowStepDefined 

func (_mock *Database) MarkWorkflowStepDefined(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepDefined provides a mock function for the type Database

func (*Database) MarkWorkflowStepFailed 

func (_mock *Database) MarkWorkflowStepFailed(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepFailed provides a mock function for the type Database

func (*Database) MarkWorkflowStepPending 

func (_mock *Database) MarkWorkflowStepPending(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepPending provides a mock function for the type Database

func (*Database) MarkWorkflowStepRunning 

func (_mock *Database) MarkWorkflowStepRunning(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepRunning provides a mock function for the type Database

func (*Database) MarkWorkflowStepTimedOut 

func (_mock *Database) MarkWorkflowStepTimedOut(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error

MarkWorkflowStepTimedOut provides a mock function for the type Database

func (*Database) MarkWorkflowTimedOut 

func (_mock *Database) MarkWorkflowTimedOut(ctx context.Context, workflowID string, timestamp time.Time) error

MarkWorkflowTimedOut provides a mock function for the type Database

func (*Database) RecordInvalidTaskIPCMessage 

func (_mock *Database) RecordInvalidTaskIPCMessage(ctx context.Context, receiver string, rawMessage string, reason string) error

RecordInvalidTaskIPCMessage provides a mock function for the type Database

func (*Database) RecordTaskEngineFailure 

func (_mock *Database) RecordTaskEngineFailure(ctx context.Context, task models.Task, instanceID string, reason string) error

RecordTaskEngineFailure provides a mock function for the type Database

func (*Database) UpdateTaskDeadline 

func (_mock *Database) UpdateTaskDeadline(ctx context.Context, taskID string, deadline time.Time) error

UpdateTaskDeadline provides a mock function for the type Database

func (*Database) UpdateWorkflowDeadline 

func (_mock *Database) UpdateWorkflowDeadline(ctx context.Context, workflowID string, deadline time.Time) error

UpdateWorkflowDeadline provides a mock function for the type Database

type Database_DefineNewOneShotTask_Call 

type Database_DefineNewOneShotTask_Call struct {
	*mock.Call
}

Database_DefineNewOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineNewOneShotTask'

func (*Database_DefineNewOneShotTask_Call) Return 

func (_c *Database_DefineNewOneShotTask_Call) Return(task models.Task, err error) *Database_DefineNewOneShotTask_Call

func (*Database_DefineNewOneShotTask_Call) Run 

func (_c *Database_DefineNewOneShotTask_Call) Run(run func(ctx context.Context, params db.NewTaskParameter)) *Database_DefineNewOneShotTask_Call

func (*Database_DefineNewOneShotTask_Call) RunAndReturn 

func (_c *Database_DefineNewOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params db.NewTaskParameter) (models.Task, error)) *Database_DefineNewOneShotTask_Call

type Database_DefineNewScheduledOneShotTask_Call 

type Database_DefineNewScheduledOneShotTask_Call struct {
	*mock.Call
}

Database_DefineNewScheduledOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineNewScheduledOneShotTask'

func (*Database_DefineNewScheduledOneShotTask_Call) Return 

func (_c *Database_DefineNewScheduledOneShotTask_Call) Return(task models.Task, err error) *Database_DefineNewScheduledOneShotTask_Call

func (*Database_DefineNewScheduledOneShotTask_Call) Run 

func (_c *Database_DefineNewScheduledOneShotTask_Call) Run(run func(ctx context.Context, params db.NewTaskParameter, targetRuntime time.Time)) *Database_DefineNewScheduledOneShotTask_Call

func (*Database_DefineNewScheduledOneShotTask_Call) RunAndReturn 

func (_c *Database_DefineNewScheduledOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params db.NewTaskParameter, targetRuntime time.Time) (models.Task, error)) *Database_DefineNewScheduledOneShotTask_Call

type Database_DefineNewTaskExecInstance_Call 

type Database_DefineNewTaskExecInstance_Call struct {
	*mock.Call
}

Database_DefineNewTaskExecInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineNewTaskExecInstance'

func (*Database_DefineNewTaskExecInstance_Call) Return 

func (_c *Database_DefineNewTaskExecInstance_Call) Return(taskExecution models.TaskExecution, err error) *Database_DefineNewTaskExecInstance_Call

func (*Database_DefineNewTaskExecInstance_Call) Run 

func (_c *Database_DefineNewTaskExecInstance_Call) Run(run func(ctx context.Context, task models.Task)) *Database_DefineNewTaskExecInstance_Call

func (*Database_DefineNewTaskExecInstance_Call) RunAndReturn 

func (_c *Database_DefineNewTaskExecInstance_Call) RunAndReturn(run func(ctx context.Context, task models.Task) (models.TaskExecution, error)) *Database_DefineNewTaskExecInstance_Call

type Database_DefineNewTaskRetryExecInstance_Call 

type Database_DefineNewTaskRetryExecInstance_Call struct {
	*mock.Call
}

Database_DefineNewTaskRetryExecInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineNewTaskRetryExecInstance'

func (*Database_DefineNewTaskRetryExecInstance_Call) Return 

func (_c *Database_DefineNewTaskRetryExecInstance_Call) Return(taskExecution models.TaskExecution, err error) *Database_DefineNewTaskRetryExecInstance_Call

func (*Database_DefineNewTaskRetryExecInstance_Call) Run 

func (_c *Database_DefineNewTaskRetryExecInstance_Call) Run(run func(ctx context.Context, task models.Task, failedEntry models.TaskExecution, targetRunTime time.Time)) *Database_DefineNewTaskRetryExecInstance_Call

func (*Database_DefineNewTaskRetryExecInstance_Call) RunAndReturn 

func (_c *Database_DefineNewTaskRetryExecInstance_Call) RunAndReturn(run func(ctx context.Context, task models.Task, failedEntry models.TaskExecution, targetRunTime time.Time) (models.TaskExecution, error)) *Database_DefineNewTaskRetryExecInstance_Call

type Database_DefineNewWorkflow_Call 

type Database_DefineNewWorkflow_Call struct {
	*mock.Call
}

Database_DefineNewWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineNewWorkflow'

func (*Database_DefineNewWorkflow_Call) Return 

func (_c *Database_DefineNewWorkflow_Call) Return(workflow models.Workflow, err error) *Database_DefineNewWorkflow_Call

func (*Database_DefineNewWorkflow_Call) Run 

func (_c *Database_DefineNewWorkflow_Call) Run(run func(ctx context.Context, workflowSpec models.NewWorkflowParameter, creator string)) *Database_DefineNewWorkflow_Call

func (*Database_DefineNewWorkflow_Call) RunAndReturn 

func (_c *Database_DefineNewWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowSpec models.NewWorkflowParameter, creator string) (models.Workflow, error)) *Database_DefineNewWorkflow_Call

type Database_DeleteTask_Call 

type Database_DeleteTask_Call struct {
	*mock.Call
}

Database_DeleteTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTask'

func (*Database_DeleteTask_Call) Return 

func (_c *Database_DeleteTask_Call) Return(err error) *Database_DeleteTask_Call

func (*Database_DeleteTask_Call) Run 

func (_c *Database_DeleteTask_Call) Run(run func(ctx context.Context, taskID string)) *Database_DeleteTask_Call

func (*Database_DeleteTask_Call) RunAndReturn 

func (_c *Database_DeleteTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_DeleteTask_Call

type Database_DeleteWorkflow_Call 

type Database_DeleteWorkflow_Call struct {
	*mock.Call
}

Database_DeleteWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteWorkflow'

func (*Database_DeleteWorkflow_Call) Return 

func (_c *Database_DeleteWorkflow_Call) Return(err error) *Database_DeleteWorkflow_Call

func (*Database_DeleteWorkflow_Call) Run 

func (_c *Database_DeleteWorkflow_Call) Run(run func(ctx context.Context, workflowID string)) *Database_DeleteWorkflow_Call

func (*Database_DeleteWorkflow_Call) RunAndReturn 

func (_c *Database_DeleteWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string) error) *Database_DeleteWorkflow_Call

type Database_Expecter 

type Database_Expecter struct {
	// contains filtered or unexported fields
}

func (*Database_Expecter) DefineNewOneShotTask 

func (_e *Database_Expecter) DefineNewOneShotTask(ctx interface{}, params interface{}) *Database_DefineNewOneShotTask_Call

DefineNewOneShotTask is a helper method to define mock.On call

  • ctx context.Context
  • params db.NewTaskParameter

func (*Database_Expecter) DefineNewScheduledOneShotTask 

func (_e *Database_Expecter) DefineNewScheduledOneShotTask(ctx interface{}, params interface{}, targetRuntime interface{}) *Database_DefineNewScheduledOneShotTask_Call

DefineNewScheduledOneShotTask is a helper method to define mock.On call

  • ctx context.Context
  • params db.NewTaskParameter
  • targetRuntime time.Time

func (*Database_Expecter) DefineNewTaskExecInstance 

func (_e *Database_Expecter) DefineNewTaskExecInstance(ctx interface{}, task interface{}) *Database_DefineNewTaskExecInstance_Call

DefineNewTaskExecInstance is a helper method to define mock.On call

  • ctx context.Context
  • task models.Task

func (*Database_Expecter) DefineNewTaskRetryExecInstance 

func (_e *Database_Expecter) DefineNewTaskRetryExecInstance(ctx interface{}, task interface{}, failedEntry interface{}, targetRunTime interface{}) *Database_DefineNewTaskRetryExecInstance_Call

DefineNewTaskRetryExecInstance is a helper method to define mock.On call

  • ctx context.Context
  • task models.Task
  • failedEntry models.TaskExecution
  • targetRunTime time.Time

func (*Database_Expecter) DefineNewWorkflow 

func (_e *Database_Expecter) DefineNewWorkflow(ctx interface{}, workflowSpec interface{}, creator interface{}) *Database_DefineNewWorkflow_Call

DefineNewWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowSpec models.NewWorkflowParameter
  • creator string

func (*Database_Expecter) DeleteTask 

func (_e *Database_Expecter) DeleteTask(ctx interface{}, taskID interface{}) *Database_DeleteTask_Call

DeleteTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) DeleteWorkflow 

func (_e *Database_Expecter) DeleteWorkflow(ctx interface{}, workflowID interface{}) *Database_DeleteWorkflow_Call

DeleteWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*Database_Expecter) GetTask 

func (_e *Database_Expecter) GetTask(ctx interface{}, taskID interface{}) *Database_GetTask_Call

GetTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) GetTaskExecution 

func (_e *Database_Expecter) GetTaskExecution(ctx interface{}, instanceID interface{}) *Database_GetTaskExecution_Call

GetTaskExecution is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string

func (*Database_Expecter) GetWorkflow 

func (_e *Database_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}) *Database_GetWorkflow_Call

GetWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*Database_Expecter) GetWorkflowStep 

func (_e *Database_Expecter) GetWorkflowStep(ctx interface{}, stepID interface{}) *Database_GetWorkflowStep_Call

GetWorkflowStep is a helper method to define mock.On call

  • ctx context.Context
  • stepID string

func (*Database_Expecter) GetWorkflowStepAndExecutorTask 

func (_e *Database_Expecter) GetWorkflowStepAndExecutorTask(cxt interface{}, stepID interface{}, activeTask interface{}) *Database_GetWorkflowStepAndExecutorTask_Call

GetWorkflowStepAndExecutorTask is a helper method to define mock.On call

  • cxt context.Context
  • stepID string
  • activeTask bool

func (*Database_Expecter) GetWorkflowStepProcessedByTask 

func (_e *Database_Expecter) GetWorkflowStepProcessedByTask(ctx interface{}, taskID interface{}) *Database_GetWorkflowStepProcessedByTask_Call

GetWorkflowStepProcessedByTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) LinkWorkflowStepWithExecutorTask 

func (_e *Database_Expecter) LinkWorkflowStepWithExecutorTask(ctx interface{}, stepID interface{}, taskID interface{}) *Database_LinkWorkflowStepWithExecutorTask_Call

LinkWorkflowStepWithExecutorTask is a helper method to define mock.On call

  • ctx context.Context
  • stepID string
  • taskID string

func (*Database_Expecter) ListAllExecutions 

func (_e *Database_Expecter) ListAllExecutions(ctx interface{}, filters interface{}) *Database_ListAllExecutions_Call

ListAllExecutions is a helper method to define mock.On call

  • ctx context.Context
  • filters db.TaskExecutionQueryFilter

func (*Database_Expecter) ListSystemEvents 

func (_e *Database_Expecter) ListSystemEvents(ctx interface{}, filters interface{}) *Database_ListSystemEvents_Call

ListSystemEvents is a helper method to define mock.On call

  • ctx context.Context
  • filters db.SystemEventQueryFilter

func (*Database_Expecter) ListTaskExecutions 

func (_e *Database_Expecter) ListTaskExecutions(ctx interface{}, taskID interface{}, filters interface{}) *Database_ListTaskExecutions_Call

ListTaskExecutions is a helper method to define mock.On call

  • ctx context.Context
  • taskID string
  • filters db.TaskExecutionQueryFilter

func (*Database_Expecter) ListTasks 

func (_e *Database_Expecter) ListTasks(ctx interface{}, filters interface{}) *Database_ListTasks_Call

ListTasks is a helper method to define mock.On call

  • ctx context.Context
  • filters db.TaskQueryFilter

func (*Database_Expecter) ListWorkflowSteps 

func (_e *Database_Expecter) ListWorkflowSteps(ctx interface{}, workflowID interface{}) *Database_ListWorkflowSteps_Call

ListWorkflowSteps is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*Database_Expecter) ListWorkflowStepsReadyToRun 

func (_e *Database_Expecter) ListWorkflowStepsReadyToRun(ctx interface{}, workflowID interface{}) *Database_ListWorkflowStepsReadyToRun_Call

ListWorkflowStepsReadyToRun is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*Database_Expecter) ListWorkflows 

func (_e *Database_Expecter) ListWorkflows(ctx interface{}, filters interface{}) *Database_ListWorkflows_Call

ListWorkflows is a helper method to define mock.On call

  • ctx context.Context
  • filters db.WorkflowQueryFilter

func (*Database_Expecter) MarkSystemEventsBroadcast 

func (_e *Database_Expecter) MarkSystemEventsBroadcast(ctx interface{}, eventIDs interface{}, broadcastAt interface{}) *Database_MarkSystemEventsBroadcast_Call

MarkSystemEventsBroadcast is a helper method to define mock.On call

  • ctx context.Context
  • eventIDs []string
  • broadcastAt time.Time

func (*Database_Expecter) MarkTaskActive 

func (_e *Database_Expecter) MarkTaskActive(ctx interface{}, taskID interface{}) *Database_MarkTaskActive_Call

MarkTaskActive is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkTaskCancelled 

func (_e *Database_Expecter) MarkTaskCancelled(ctx interface{}, taskID interface{}) *Database_MarkTaskCancelled_Call

MarkTaskCancelled is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkTaskCancelling 

func (_e *Database_Expecter) MarkTaskCancelling(ctx interface{}, taskID interface{}) *Database_MarkTaskCancelling_Call

MarkTaskCancelling is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkTaskComplete 

func (_e *Database_Expecter) MarkTaskComplete(ctx interface{}, taskID interface{}) *Database_MarkTaskComplete_Call

MarkTaskComplete is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkTaskExecAcquired 

func (_e *Database_Expecter) MarkTaskExecAcquired(ctx interface{}, instanceID interface{}, workerName interface{}) *Database_MarkTaskExecAcquired_Call

MarkTaskExecAcquired is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string
  • workerName string

func (*Database_Expecter) MarkTaskExecCancelled 

func (_e *Database_Expecter) MarkTaskExecCancelled(ctx interface{}, instanceID interface{}, cancelMsg interface{}, terminatedAt interface{}) *Database_MarkTaskExecCancelled_Call

MarkTaskExecCancelled is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string
  • cancelMsg string
  • terminatedAt time.Time

func (*Database_Expecter) MarkTaskExecFailed 

func (_e *Database_Expecter) MarkTaskExecFailed(ctx interface{}, instanceID interface{}, errorMsg interface{}, disposition interface{}, terminatedAt interface{}) *Database_MarkTaskExecFailed_Call

MarkTaskExecFailed is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string
  • errorMsg string
  • disposition *models.TaskFailureDispositionENUM
  • terminatedAt time.Time

func (*Database_Expecter) MarkTaskExecFinalized 

func (_e *Database_Expecter) MarkTaskExecFinalized(ctx interface{}, instanceID interface{}) *Database_MarkTaskExecFinalized_Call

MarkTaskExecFinalized is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string

func (*Database_Expecter) MarkTaskExecProcessed 

func (_e *Database_Expecter) MarkTaskExecProcessed(ctx interface{}, instanceID interface{}, terminatedAt interface{}) *Database_MarkTaskExecProcessed_Call

MarkTaskExecProcessed is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string
  • terminatedAt time.Time

func (*Database_Expecter) MarkTaskExecProcessing 

func (_e *Database_Expecter) MarkTaskExecProcessing(ctx interface{}, instanceID interface{}) *Database_MarkTaskExecProcessing_Call

MarkTaskExecProcessing is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string

func (*Database_Expecter) MarkTaskExecQueued 

func (_e *Database_Expecter) MarkTaskExecQueued(ctx interface{}, instanceID interface{}) *Database_MarkTaskExecQueued_Call

MarkTaskExecQueued is a helper method to define mock.On call

  • ctx context.Context
  • instanceID string

func (*Database_Expecter) MarkTaskFailed 

func (_e *Database_Expecter) MarkTaskFailed(ctx interface{}, taskID interface{}) *Database_MarkTaskFailed_Call

MarkTaskFailed is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkTaskTimedOut 

func (_e *Database_Expecter) MarkTaskTimedOut(ctx interface{}, taskID interface{}) *Database_MarkTaskTimedOut_Call

MarkTaskTimedOut is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*Database_Expecter) MarkWorkflowCancelled 

func (_e *Database_Expecter) MarkWorkflowCancelled(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowCancelled_Call

MarkWorkflowCancelled is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowCancelling 

func (_e *Database_Expecter) MarkWorkflowCancelling(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowCancelling_Call

MarkWorkflowCancelling is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowComplete 

func (_e *Database_Expecter) MarkWorkflowComplete(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowComplete_Call

MarkWorkflowComplete is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowFailed 

func (_e *Database_Expecter) MarkWorkflowFailed(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowFailed_Call

MarkWorkflowFailed is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowPending 

func (_e *Database_Expecter) MarkWorkflowPending(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowPending_Call

MarkWorkflowPending is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowRunning 

func (_e *Database_Expecter) MarkWorkflowRunning(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowRunning_Call

MarkWorkflowRunning is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepCancelled 

func (_e *Database_Expecter) MarkWorkflowStepCancelled(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepCancelled_Call

MarkWorkflowStepCancelled is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepCancelling 

func (_e *Database_Expecter) MarkWorkflowStepCancelling(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepCancelling_Call

MarkWorkflowStepCancelling is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepComplete 

func (_e *Database_Expecter) MarkWorkflowStepComplete(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepComplete_Call

MarkWorkflowStepComplete is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepDefined 

func (_e *Database_Expecter) MarkWorkflowStepDefined(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepDefined_Call

MarkWorkflowStepDefined is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepFailed 

func (_e *Database_Expecter) MarkWorkflowStepFailed(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepFailed_Call

MarkWorkflowStepFailed is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepPending 

func (_e *Database_Expecter) MarkWorkflowStepPending(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepPending_Call

MarkWorkflowStepPending is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepRunning 

func (_e *Database_Expecter) MarkWorkflowStepRunning(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepRunning_Call

MarkWorkflowStepRunning is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowStepTimedOut 

func (_e *Database_Expecter) MarkWorkflowStepTimedOut(ctx interface{}, workflowID interface{}, stepIDs interface{}, timestamp interface{}) *Database_MarkWorkflowStepTimedOut_Call

MarkWorkflowStepTimedOut is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • stepIDs []string
  • timestamp time.Time

func (*Database_Expecter) MarkWorkflowTimedOut 

func (_e *Database_Expecter) MarkWorkflowTimedOut(ctx interface{}, workflowID interface{}, timestamp interface{}) *Database_MarkWorkflowTimedOut_Call

MarkWorkflowTimedOut is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • timestamp time.Time

func (*Database_Expecter) RecordInvalidTaskIPCMessage 

func (_e *Database_Expecter) RecordInvalidTaskIPCMessage(ctx interface{}, receiver interface{}, rawMessage interface{}, reason interface{}) *Database_RecordInvalidTaskIPCMessage_Call

RecordInvalidTaskIPCMessage is a helper method to define mock.On call

  • ctx context.Context
  • receiver string
  • rawMessage string
  • reason string

func (*Database_Expecter) RecordTaskEngineFailure 

func (_e *Database_Expecter) RecordTaskEngineFailure(ctx interface{}, task interface{}, instanceID interface{}, reason interface{}) *Database_RecordTaskEngineFailure_Call

RecordTaskEngineFailure is a helper method to define mock.On call

  • ctx context.Context
  • task models.Task
  • instanceID string
  • reason string

func (*Database_Expecter) UpdateTaskDeadline 

func (_e *Database_Expecter) UpdateTaskDeadline(ctx interface{}, taskID interface{}, deadline interface{}) *Database_UpdateTaskDeadline_Call

UpdateTaskDeadline is a helper method to define mock.On call

  • ctx context.Context
  • taskID string
  • deadline time.Time

func (*Database_Expecter) UpdateWorkflowDeadline 

func (_e *Database_Expecter) UpdateWorkflowDeadline(ctx interface{}, workflowID interface{}, deadline interface{}) *Database_UpdateWorkflowDeadline_Call

UpdateWorkflowDeadline is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • deadline time.Time

type Database_GetTaskExecution_Call 

type Database_GetTaskExecution_Call struct {
	*mock.Call
}

Database_GetTaskExecution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskExecution'

func (*Database_GetTaskExecution_Call) Return 

func (_c *Database_GetTaskExecution_Call) Return(taskExecution models.TaskExecution, err error) *Database_GetTaskExecution_Call

func (*Database_GetTaskExecution_Call) Run 

func (_c *Database_GetTaskExecution_Call) Run(run func(ctx context.Context, instanceID string)) *Database_GetTaskExecution_Call

func (*Database_GetTaskExecution_Call) RunAndReturn 

func (_c *Database_GetTaskExecution_Call) RunAndReturn(run func(ctx context.Context, instanceID string) (models.TaskExecution, error)) *Database_GetTaskExecution_Call

type Database_GetTask_Call 

type Database_GetTask_Call struct {
	*mock.Call
}

Database_GetTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTask'

func (*Database_GetTask_Call) Return 

func (_c *Database_GetTask_Call) Return(task models.Task, err error) *Database_GetTask_Call

func (*Database_GetTask_Call) Run 

func (_c *Database_GetTask_Call) Run(run func(ctx context.Context, taskID string)) *Database_GetTask_Call

func (*Database_GetTask_Call) RunAndReturn 

func (_c *Database_GetTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) (models.Task, error)) *Database_GetTask_Call

type Database_GetWorkflowStepAndExecutorTask_Call 

type Database_GetWorkflowStepAndExecutorTask_Call struct {
	*mock.Call
}

Database_GetWorkflowStepAndExecutorTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowStepAndExecutorTask'

func (*Database_GetWorkflowStepAndExecutorTask_Call) Return 

func (_c *Database_GetWorkflowStepAndExecutorTask_Call) Return(workflowStep models.WorkflowStep, tasks []models.Task, err error) *Database_GetWorkflowStepAndExecutorTask_Call

func (*Database_GetWorkflowStepAndExecutorTask_Call) Run 

func (_c *Database_GetWorkflowStepAndExecutorTask_Call) Run(run func(cxt context.Context, stepID string, activeTask bool)) *Database_GetWorkflowStepAndExecutorTask_Call

func (*Database_GetWorkflowStepAndExecutorTask_Call) RunAndReturn 

func (_c *Database_GetWorkflowStepAndExecutorTask_Call) RunAndReturn(run func(cxt context.Context, stepID string, activeTask bool) (models.WorkflowStep, []models.Task, error)) *Database_GetWorkflowStepAndExecutorTask_Call

type Database_GetWorkflowStepProcessedByTask_Call 

type Database_GetWorkflowStepProcessedByTask_Call struct {
	*mock.Call
}

Database_GetWorkflowStepProcessedByTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowStepProcessedByTask'

func (*Database_GetWorkflowStepProcessedByTask_Call) Return 

func (_c *Database_GetWorkflowStepProcessedByTask_Call) Return(workflowStep models.WorkflowStep, err error) *Database_GetWorkflowStepProcessedByTask_Call

func (*Database_GetWorkflowStepProcessedByTask_Call) Run 

func (_c *Database_GetWorkflowStepProcessedByTask_Call) Run(run func(ctx context.Context, taskID string)) *Database_GetWorkflowStepProcessedByTask_Call

func (*Database_GetWorkflowStepProcessedByTask_Call) RunAndReturn 

func (_c *Database_GetWorkflowStepProcessedByTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) (models.WorkflowStep, error)) *Database_GetWorkflowStepProcessedByTask_Call

type Database_GetWorkflowStep_Call 

type Database_GetWorkflowStep_Call struct {
	*mock.Call
}

Database_GetWorkflowStep_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowStep'

func (*Database_GetWorkflowStep_Call) Return 

func (_c *Database_GetWorkflowStep_Call) Return(workflowStep models.WorkflowStep, err error) *Database_GetWorkflowStep_Call

func (*Database_GetWorkflowStep_Call) Run 

func (_c *Database_GetWorkflowStep_Call) Run(run func(ctx context.Context, stepID string)) *Database_GetWorkflowStep_Call

func (*Database_GetWorkflowStep_Call) RunAndReturn 

func (_c *Database_GetWorkflowStep_Call) RunAndReturn(run func(ctx context.Context, stepID string) (models.WorkflowStep, error)) *Database_GetWorkflowStep_Call

type Database_GetWorkflow_Call 

type Database_GetWorkflow_Call struct {
	*mock.Call
}

Database_GetWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflow'

func (*Database_GetWorkflow_Call) Return 

func (_c *Database_GetWorkflow_Call) Return(workflow models.Workflow, err error) *Database_GetWorkflow_Call

func (*Database_GetWorkflow_Call) Run 

func (_c *Database_GetWorkflow_Call) Run(run func(ctx context.Context, workflowID string)) *Database_GetWorkflow_Call

func (*Database_GetWorkflow_Call) RunAndReturn 

func (_c *Database_GetWorkflow_Call) RunAndReturn(run func(ctx context.Context, workflowID string) (models.Workflow, error)) *Database_GetWorkflow_Call

type Database_LinkWorkflowStepWithExecutorTask_Call 

type Database_LinkWorkflowStepWithExecutorTask_Call struct {
	*mock.Call
}

Database_LinkWorkflowStepWithExecutorTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LinkWorkflowStepWithExecutorTask'

func (*Database_LinkWorkflowStepWithExecutorTask_Call) Return 

func (_c *Database_LinkWorkflowStepWithExecutorTask_Call) Return(err error) *Database_LinkWorkflowStepWithExecutorTask_Call

func (*Database_LinkWorkflowStepWithExecutorTask_Call) Run 

func (_c *Database_LinkWorkflowStepWithExecutorTask_Call) Run(run func(ctx context.Context, stepID string, taskID string)) *Database_LinkWorkflowStepWithExecutorTask_Call

func (*Database_LinkWorkflowStepWithExecutorTask_Call) RunAndReturn 

func (_c *Database_LinkWorkflowStepWithExecutorTask_Call) RunAndReturn(run func(ctx context.Context, stepID string, taskID string) error) *Database_LinkWorkflowStepWithExecutorTask_Call

type Database_ListAllExecutions_Call 

type Database_ListAllExecutions_Call struct {
	*mock.Call
}

Database_ListAllExecutions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllExecutions'

func (*Database_ListAllExecutions_Call) Return 

func (_c *Database_ListAllExecutions_Call) Return(taskExecutions []models.TaskExecution, err error) *Database_ListAllExecutions_Call

func (*Database_ListAllExecutions_Call) Run 

func (_c *Database_ListAllExecutions_Call) Run(run func(ctx context.Context, filters db.TaskExecutionQueryFilter)) *Database_ListAllExecutions_Call

func (*Database_ListAllExecutions_Call) RunAndReturn 

func (_c *Database_ListAllExecutions_Call) RunAndReturn(run func(ctx context.Context, filters db.TaskExecutionQueryFilter) ([]models.TaskExecution, error)) *Database_ListAllExecutions_Call

type Database_ListSystemEvents_Call 

type Database_ListSystemEvents_Call struct {
	*mock.Call
}

Database_ListSystemEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSystemEvents'

func (*Database_ListSystemEvents_Call) Return 

func (_c *Database_ListSystemEvents_Call) Return(systemEventAudits []models.SystemEventAudit, err error) *Database_ListSystemEvents_Call

func (*Database_ListSystemEvents_Call) Run 

func (_c *Database_ListSystemEvents_Call) Run(run func(ctx context.Context, filters db.SystemEventQueryFilter)) *Database_ListSystemEvents_Call

func (*Database_ListSystemEvents_Call) RunAndReturn 

func (_c *Database_ListSystemEvents_Call) RunAndReturn(run func(ctx context.Context, filters db.SystemEventQueryFilter) ([]models.SystemEventAudit, error)) *Database_ListSystemEvents_Call

type Database_ListTaskExecutions_Call 

type Database_ListTaskExecutions_Call struct {
	*mock.Call
}

Database_ListTaskExecutions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTaskExecutions'

func (*Database_ListTaskExecutions_Call) Return 

func (_c *Database_ListTaskExecutions_Call) Return(taskExecutions []models.TaskExecution, err error) *Database_ListTaskExecutions_Call

func (*Database_ListTaskExecutions_Call) Run 

func (_c *Database_ListTaskExecutions_Call) Run(run func(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter)) *Database_ListTaskExecutions_Call

func (*Database_ListTaskExecutions_Call) RunAndReturn 

func (_c *Database_ListTaskExecutions_Call) RunAndReturn(run func(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter) ([]models.TaskExecution, error)) *Database_ListTaskExecutions_Call

type Database_ListTasks_Call 

type Database_ListTasks_Call struct {
	*mock.Call
}

Database_ListTasks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTasks'

func (*Database_ListTasks_Call) Return 

func (_c *Database_ListTasks_Call) Return(tasks []models.Task, err error) *Database_ListTasks_Call

func (*Database_ListTasks_Call) Run 

func (_c *Database_ListTasks_Call) Run(run func(ctx context.Context, filters db.TaskQueryFilter)) *Database_ListTasks_Call

func (*Database_ListTasks_Call) RunAndReturn 

func (_c *Database_ListTasks_Call) RunAndReturn(run func(ctx context.Context, filters db.TaskQueryFilter) ([]models.Task, error)) *Database_ListTasks_Call

type Database_ListWorkflowStepsReadyToRun_Call 

type Database_ListWorkflowStepsReadyToRun_Call struct {
	*mock.Call
}

Database_ListWorkflowStepsReadyToRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflowStepsReadyToRun'

func (*Database_ListWorkflowStepsReadyToRun_Call) Return 

func (_c *Database_ListWorkflowStepsReadyToRun_Call) Return(workflowSteps []models.WorkflowStep, err error) *Database_ListWorkflowStepsReadyToRun_Call

func (*Database_ListWorkflowStepsReadyToRun_Call) Run 

func (_c *Database_ListWorkflowStepsReadyToRun_Call) Run(run func(ctx context.Context, workflowID string)) *Database_ListWorkflowStepsReadyToRun_Call

func (*Database_ListWorkflowStepsReadyToRun_Call) RunAndReturn 

func (_c *Database_ListWorkflowStepsReadyToRun_Call) RunAndReturn(run func(ctx context.Context, workflowID string) ([]models.WorkflowStep, error)) *Database_ListWorkflowStepsReadyToRun_Call

type Database_ListWorkflowSteps_Call 

type Database_ListWorkflowSteps_Call struct {
	*mock.Call
}

Database_ListWorkflowSteps_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflowSteps'

func (*Database_ListWorkflowSteps_Call) Return 

func (_c *Database_ListWorkflowSteps_Call) Return(workflowSteps []models.WorkflowStep, err error) *Database_ListWorkflowSteps_Call

func (*Database_ListWorkflowSteps_Call) Run 

func (_c *Database_ListWorkflowSteps_Call) Run(run func(ctx context.Context, workflowID string)) *Database_ListWorkflowSteps_Call

func (*Database_ListWorkflowSteps_Call) RunAndReturn 

func (_c *Database_ListWorkflowSteps_Call) RunAndReturn(run func(ctx context.Context, workflowID string) ([]models.WorkflowStep, error)) *Database_ListWorkflowSteps_Call

type Database_ListWorkflows_Call 

type Database_ListWorkflows_Call struct {
	*mock.Call
}

Database_ListWorkflows_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflows'

func (*Database_ListWorkflows_Call) Return 

func (_c *Database_ListWorkflows_Call) Return(workflows []models.Workflow, err error) *Database_ListWorkflows_Call

func (*Database_ListWorkflows_Call) Run 

func (_c *Database_ListWorkflows_Call) Run(run func(ctx context.Context, filters db.WorkflowQueryFilter)) *Database_ListWorkflows_Call

func (*Database_ListWorkflows_Call) RunAndReturn 

func (_c *Database_ListWorkflows_Call) RunAndReturn(run func(ctx context.Context, filters db.WorkflowQueryFilter) ([]models.Workflow, error)) *Database_ListWorkflows_Call

type Database_MarkSystemEventsBroadcast_Call 

type Database_MarkSystemEventsBroadcast_Call struct {
	*mock.Call
}

Database_MarkSystemEventsBroadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkSystemEventsBroadcast'

func (*Database_MarkSystemEventsBroadcast_Call) Return 

func (_c *Database_MarkSystemEventsBroadcast_Call) Return(err error) *Database_MarkSystemEventsBroadcast_Call

func (*Database_MarkSystemEventsBroadcast_Call) Run 

func (_c *Database_MarkSystemEventsBroadcast_Call) Run(run func(ctx context.Context, eventIDs []string, broadcastAt time.Time)) *Database_MarkSystemEventsBroadcast_Call

func (*Database_MarkSystemEventsBroadcast_Call) RunAndReturn 

func (_c *Database_MarkSystemEventsBroadcast_Call) RunAndReturn(run func(ctx context.Context, eventIDs []string, broadcastAt time.Time) error) *Database_MarkSystemEventsBroadcast_Call

type Database_MarkTaskActive_Call 

type Database_MarkTaskActive_Call struct {
	*mock.Call
}

Database_MarkTaskActive_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskActive'

func (*Database_MarkTaskActive_Call) Return 

func (_c *Database_MarkTaskActive_Call) Return(err error) *Database_MarkTaskActive_Call

func (*Database_MarkTaskActive_Call) Run 

func (_c *Database_MarkTaskActive_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskActive_Call

func (*Database_MarkTaskActive_Call) RunAndReturn 

func (_c *Database_MarkTaskActive_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskActive_Call

type Database_MarkTaskCancelled_Call 

type Database_MarkTaskCancelled_Call struct {
	*mock.Call
}

Database_MarkTaskCancelled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskCancelled'

func (*Database_MarkTaskCancelled_Call) Return 

func (_c *Database_MarkTaskCancelled_Call) Return(err error) *Database_MarkTaskCancelled_Call

func (*Database_MarkTaskCancelled_Call) Run 

func (_c *Database_MarkTaskCancelled_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskCancelled_Call

func (*Database_MarkTaskCancelled_Call) RunAndReturn 

func (_c *Database_MarkTaskCancelled_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskCancelled_Call

type Database_MarkTaskCancelling_Call 

type Database_MarkTaskCancelling_Call struct {
	*mock.Call
}

Database_MarkTaskCancelling_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskCancelling'

func (*Database_MarkTaskCancelling_Call) Return 

func (_c *Database_MarkTaskCancelling_Call) Return(err error) *Database_MarkTaskCancelling_Call

func (*Database_MarkTaskCancelling_Call) Run 

func (_c *Database_MarkTaskCancelling_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskCancelling_Call

func (*Database_MarkTaskCancelling_Call) RunAndReturn 

func (_c *Database_MarkTaskCancelling_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskCancelling_Call

type Database_MarkTaskComplete_Call 

type Database_MarkTaskComplete_Call struct {
	*mock.Call
}

Database_MarkTaskComplete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskComplete'

func (*Database_MarkTaskComplete_Call) Return 

func (_c *Database_MarkTaskComplete_Call) Return(err error) *Database_MarkTaskComplete_Call

func (*Database_MarkTaskComplete_Call) Run 

func (_c *Database_MarkTaskComplete_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskComplete_Call

func (*Database_MarkTaskComplete_Call) RunAndReturn 

func (_c *Database_MarkTaskComplete_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskComplete_Call

type Database_MarkTaskExecAcquired_Call 

type Database_MarkTaskExecAcquired_Call struct {
	*mock.Call
}

Database_MarkTaskExecAcquired_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecAcquired'

func (*Database_MarkTaskExecAcquired_Call) Return 

func (_c *Database_MarkTaskExecAcquired_Call) Return(err error) *Database_MarkTaskExecAcquired_Call

func (*Database_MarkTaskExecAcquired_Call) Run 

func (_c *Database_MarkTaskExecAcquired_Call) Run(run func(ctx context.Context, instanceID string, workerName string)) *Database_MarkTaskExecAcquired_Call

func (*Database_MarkTaskExecAcquired_Call) RunAndReturn 

func (_c *Database_MarkTaskExecAcquired_Call) RunAndReturn(run func(ctx context.Context, instanceID string, workerName string) error) *Database_MarkTaskExecAcquired_Call

type Database_MarkTaskExecCancelled_Call 

type Database_MarkTaskExecCancelled_Call struct {
	*mock.Call
}

Database_MarkTaskExecCancelled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecCancelled'

func (*Database_MarkTaskExecCancelled_Call) Return 

func (_c *Database_MarkTaskExecCancelled_Call) Return(err error) *Database_MarkTaskExecCancelled_Call

func (*Database_MarkTaskExecCancelled_Call) Run 

func (_c *Database_MarkTaskExecCancelled_Call) Run(run func(ctx context.Context, instanceID string, cancelMsg string, terminatedAt time.Time)) *Database_MarkTaskExecCancelled_Call

func (*Database_MarkTaskExecCancelled_Call) RunAndReturn 

func (_c *Database_MarkTaskExecCancelled_Call) RunAndReturn(run func(ctx context.Context, instanceID string, cancelMsg string, terminatedAt time.Time) error) *Database_MarkTaskExecCancelled_Call

type Database_MarkTaskExecFailed_Call 

type Database_MarkTaskExecFailed_Call struct {
	*mock.Call
}

Database_MarkTaskExecFailed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecFailed'

func (*Database_MarkTaskExecFailed_Call) Return 

func (_c *Database_MarkTaskExecFailed_Call) Return(err error) *Database_MarkTaskExecFailed_Call

func (*Database_MarkTaskExecFailed_Call) Run 

func (_c *Database_MarkTaskExecFailed_Call) Run(run func(ctx context.Context, instanceID string, errorMsg string, disposition *models.TaskFailureDispositionENUM, terminatedAt time.Time)) *Database_MarkTaskExecFailed_Call

func (*Database_MarkTaskExecFailed_Call) RunAndReturn 

func (_c *Database_MarkTaskExecFailed_Call) RunAndReturn(run func(ctx context.Context, instanceID string, errorMsg string, disposition *models.TaskFailureDispositionENUM, terminatedAt time.Time) error) *Database_MarkTaskExecFailed_Call

type Database_MarkTaskExecFinalized_Call 

type Database_MarkTaskExecFinalized_Call struct {
	*mock.Call
}

Database_MarkTaskExecFinalized_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecFinalized'

func (*Database_MarkTaskExecFinalized_Call) Return 

func (_c *Database_MarkTaskExecFinalized_Call) Return(err error) *Database_MarkTaskExecFinalized_Call

func (*Database_MarkTaskExecFinalized_Call) Run 

func (_c *Database_MarkTaskExecFinalized_Call) Run(run func(ctx context.Context, instanceID string)) *Database_MarkTaskExecFinalized_Call

func (*Database_MarkTaskExecFinalized_Call) RunAndReturn 

func (_c *Database_MarkTaskExecFinalized_Call) RunAndReturn(run func(ctx context.Context, instanceID string) error) *Database_MarkTaskExecFinalized_Call

type Database_MarkTaskExecProcessed_Call 

type Database_MarkTaskExecProcessed_Call struct {
	*mock.Call
}

Database_MarkTaskExecProcessed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecProcessed'

func (*Database_MarkTaskExecProcessed_Call) Return 

func (_c *Database_MarkTaskExecProcessed_Call) Return(err error) *Database_MarkTaskExecProcessed_Call

func (*Database_MarkTaskExecProcessed_Call) Run 

func (_c *Database_MarkTaskExecProcessed_Call) Run(run func(ctx context.Context, instanceID string, terminatedAt time.Time)) *Database_MarkTaskExecProcessed_Call

func (*Database_MarkTaskExecProcessed_Call) RunAndReturn 

func (_c *Database_MarkTaskExecProcessed_Call) RunAndReturn(run func(ctx context.Context, instanceID string, terminatedAt time.Time) error) *Database_MarkTaskExecProcessed_Call

type Database_MarkTaskExecProcessing_Call 

type Database_MarkTaskExecProcessing_Call struct {
	*mock.Call
}

Database_MarkTaskExecProcessing_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecProcessing'

func (*Database_MarkTaskExecProcessing_Call) Return 

func (_c *Database_MarkTaskExecProcessing_Call) Return(err error) *Database_MarkTaskExecProcessing_Call

func (*Database_MarkTaskExecProcessing_Call) Run 

func (_c *Database_MarkTaskExecProcessing_Call) Run(run func(ctx context.Context, instanceID string)) *Database_MarkTaskExecProcessing_Call

func (*Database_MarkTaskExecProcessing_Call) RunAndReturn 

func (_c *Database_MarkTaskExecProcessing_Call) RunAndReturn(run func(ctx context.Context, instanceID string) error) *Database_MarkTaskExecProcessing_Call

type Database_MarkTaskExecQueued_Call 

type Database_MarkTaskExecQueued_Call struct {
	*mock.Call
}

Database_MarkTaskExecQueued_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskExecQueued'

func (*Database_MarkTaskExecQueued_Call) Return 

func (_c *Database_MarkTaskExecQueued_Call) Return(err error) *Database_MarkTaskExecQueued_Call

func (*Database_MarkTaskExecQueued_Call) Run 

func (_c *Database_MarkTaskExecQueued_Call) Run(run func(ctx context.Context, instanceID string)) *Database_MarkTaskExecQueued_Call

func (*Database_MarkTaskExecQueued_Call) RunAndReturn 

func (_c *Database_MarkTaskExecQueued_Call) RunAndReturn(run func(ctx context.Context, instanceID string) error) *Database_MarkTaskExecQueued_Call

type Database_MarkTaskFailed_Call 

type Database_MarkTaskFailed_Call struct {
	*mock.Call
}

Database_MarkTaskFailed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskFailed'

func (*Database_MarkTaskFailed_Call) Return 

func (_c *Database_MarkTaskFailed_Call) Return(err error) *Database_MarkTaskFailed_Call

func (*Database_MarkTaskFailed_Call) Run 

func (_c *Database_MarkTaskFailed_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskFailed_Call

func (*Database_MarkTaskFailed_Call) RunAndReturn 

func (_c *Database_MarkTaskFailed_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskFailed_Call

type Database_MarkTaskTimedOut_Call 

type Database_MarkTaskTimedOut_Call struct {
	*mock.Call
}

Database_MarkTaskTimedOut_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkTaskTimedOut'

func (*Database_MarkTaskTimedOut_Call) Return 

func (_c *Database_MarkTaskTimedOut_Call) Return(err error) *Database_MarkTaskTimedOut_Call

func (*Database_MarkTaskTimedOut_Call) Run 

func (_c *Database_MarkTaskTimedOut_Call) Run(run func(ctx context.Context, taskID string)) *Database_MarkTaskTimedOut_Call

func (*Database_MarkTaskTimedOut_Call) RunAndReturn 

func (_c *Database_MarkTaskTimedOut_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Database_MarkTaskTimedOut_Call

type Database_MarkWorkflowCancelled_Call 

type Database_MarkWorkflowCancelled_Call struct {
	*mock.Call
}

Database_MarkWorkflowCancelled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowCancelled'

func (*Database_MarkWorkflowCancelled_Call) Return 

func (_c *Database_MarkWorkflowCancelled_Call) Return(err error) *Database_MarkWorkflowCancelled_Call

func (*Database_MarkWorkflowCancelled_Call) Run 

func (_c *Database_MarkWorkflowCancelled_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowCancelled_Call

func (*Database_MarkWorkflowCancelled_Call) RunAndReturn 

func (_c *Database_MarkWorkflowCancelled_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowCancelled_Call

type Database_MarkWorkflowCancelling_Call 

type Database_MarkWorkflowCancelling_Call struct {
	*mock.Call
}

Database_MarkWorkflowCancelling_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowCancelling'

func (*Database_MarkWorkflowCancelling_Call) Return 

func (_c *Database_MarkWorkflowCancelling_Call) Return(err error) *Database_MarkWorkflowCancelling_Call

func (*Database_MarkWorkflowCancelling_Call) Run 

func (_c *Database_MarkWorkflowCancelling_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowCancelling_Call

func (*Database_MarkWorkflowCancelling_Call) RunAndReturn 

func (_c *Database_MarkWorkflowCancelling_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowCancelling_Call

type Database_MarkWorkflowComplete_Call 

type Database_MarkWorkflowComplete_Call struct {
	*mock.Call
}

Database_MarkWorkflowComplete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowComplete'

func (*Database_MarkWorkflowComplete_Call) Return 

func (_c *Database_MarkWorkflowComplete_Call) Return(err error) *Database_MarkWorkflowComplete_Call

func (*Database_MarkWorkflowComplete_Call) Run 

func (_c *Database_MarkWorkflowComplete_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowComplete_Call

func (*Database_MarkWorkflowComplete_Call) RunAndReturn 

func (_c *Database_MarkWorkflowComplete_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowComplete_Call

type Database_MarkWorkflowFailed_Call 

type Database_MarkWorkflowFailed_Call struct {
	*mock.Call
}

Database_MarkWorkflowFailed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowFailed'

func (*Database_MarkWorkflowFailed_Call) Return 

func (_c *Database_MarkWorkflowFailed_Call) Return(err error) *Database_MarkWorkflowFailed_Call

func (*Database_MarkWorkflowFailed_Call) Run 

func (_c *Database_MarkWorkflowFailed_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowFailed_Call

func (*Database_MarkWorkflowFailed_Call) RunAndReturn 

func (_c *Database_MarkWorkflowFailed_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowFailed_Call

type Database_MarkWorkflowPending_Call 

type Database_MarkWorkflowPending_Call struct {
	*mock.Call
}

Database_MarkWorkflowPending_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowPending'

func (*Database_MarkWorkflowPending_Call) Return 

func (_c *Database_MarkWorkflowPending_Call) Return(err error) *Database_MarkWorkflowPending_Call

func (*Database_MarkWorkflowPending_Call) Run 

func (_c *Database_MarkWorkflowPending_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowPending_Call

func (*Database_MarkWorkflowPending_Call) RunAndReturn 

func (_c *Database_MarkWorkflowPending_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowPending_Call

type Database_MarkWorkflowRunning_Call 

type Database_MarkWorkflowRunning_Call struct {
	*mock.Call
}

Database_MarkWorkflowRunning_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowRunning'

func (*Database_MarkWorkflowRunning_Call) Return 

func (_c *Database_MarkWorkflowRunning_Call) Return(err error) *Database_MarkWorkflowRunning_Call

func (*Database_MarkWorkflowRunning_Call) Run 

func (_c *Database_MarkWorkflowRunning_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowRunning_Call

func (*Database_MarkWorkflowRunning_Call) RunAndReturn 

func (_c *Database_MarkWorkflowRunning_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowRunning_Call

type Database_MarkWorkflowStepCancelled_Call 

type Database_MarkWorkflowStepCancelled_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepCancelled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepCancelled'

func (*Database_MarkWorkflowStepCancelled_Call) Return 

func (_c *Database_MarkWorkflowStepCancelled_Call) Return(err error) *Database_MarkWorkflowStepCancelled_Call

func (*Database_MarkWorkflowStepCancelled_Call) Run 

func (_c *Database_MarkWorkflowStepCancelled_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepCancelled_Call

func (*Database_MarkWorkflowStepCancelled_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepCancelled_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepCancelled_Call

type Database_MarkWorkflowStepCancelling_Call 

type Database_MarkWorkflowStepCancelling_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepCancelling_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepCancelling'

func (*Database_MarkWorkflowStepCancelling_Call) Return 

func (_c *Database_MarkWorkflowStepCancelling_Call) Return(err error) *Database_MarkWorkflowStepCancelling_Call

func (*Database_MarkWorkflowStepCancelling_Call) Run 

func (_c *Database_MarkWorkflowStepCancelling_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepCancelling_Call

func (*Database_MarkWorkflowStepCancelling_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepCancelling_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepCancelling_Call

type Database_MarkWorkflowStepComplete_Call 

type Database_MarkWorkflowStepComplete_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepComplete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepComplete'

func (*Database_MarkWorkflowStepComplete_Call) Return 

func (_c *Database_MarkWorkflowStepComplete_Call) Return(err error) *Database_MarkWorkflowStepComplete_Call

func (*Database_MarkWorkflowStepComplete_Call) Run 

func (_c *Database_MarkWorkflowStepComplete_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepComplete_Call

func (*Database_MarkWorkflowStepComplete_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepComplete_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepComplete_Call

type Database_MarkWorkflowStepDefined_Call 

type Database_MarkWorkflowStepDefined_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepDefined_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepDefined'

func (*Database_MarkWorkflowStepDefined_Call) Return 

func (_c *Database_MarkWorkflowStepDefined_Call) Return(err error) *Database_MarkWorkflowStepDefined_Call

func (*Database_MarkWorkflowStepDefined_Call) Run 

func (_c *Database_MarkWorkflowStepDefined_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepDefined_Call

func (*Database_MarkWorkflowStepDefined_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepDefined_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepDefined_Call

type Database_MarkWorkflowStepFailed_Call 

type Database_MarkWorkflowStepFailed_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepFailed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepFailed'

func (*Database_MarkWorkflowStepFailed_Call) Return 

func (_c *Database_MarkWorkflowStepFailed_Call) Return(err error) *Database_MarkWorkflowStepFailed_Call

func (*Database_MarkWorkflowStepFailed_Call) Run 

func (_c *Database_MarkWorkflowStepFailed_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepFailed_Call

func (*Database_MarkWorkflowStepFailed_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepFailed_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepFailed_Call

type Database_MarkWorkflowStepPending_Call 

type Database_MarkWorkflowStepPending_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepPending_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepPending'

func (*Database_MarkWorkflowStepPending_Call) Return 

func (_c *Database_MarkWorkflowStepPending_Call) Return(err error) *Database_MarkWorkflowStepPending_Call

func (*Database_MarkWorkflowStepPending_Call) Run 

func (_c *Database_MarkWorkflowStepPending_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepPending_Call

func (*Database_MarkWorkflowStepPending_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepPending_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepPending_Call

type Database_MarkWorkflowStepRunning_Call 

type Database_MarkWorkflowStepRunning_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepRunning_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepRunning'

func (*Database_MarkWorkflowStepRunning_Call) Return 

func (_c *Database_MarkWorkflowStepRunning_Call) Return(err error) *Database_MarkWorkflowStepRunning_Call

func (*Database_MarkWorkflowStepRunning_Call) Run 

func (_c *Database_MarkWorkflowStepRunning_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepRunning_Call

func (*Database_MarkWorkflowStepRunning_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepRunning_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepRunning_Call

type Database_MarkWorkflowStepTimedOut_Call 

type Database_MarkWorkflowStepTimedOut_Call struct {
	*mock.Call
}

Database_MarkWorkflowStepTimedOut_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowStepTimedOut'

func (*Database_MarkWorkflowStepTimedOut_Call) Return 

func (_c *Database_MarkWorkflowStepTimedOut_Call) Return(err error) *Database_MarkWorkflowStepTimedOut_Call

func (*Database_MarkWorkflowStepTimedOut_Call) Run 

func (_c *Database_MarkWorkflowStepTimedOut_Call) Run(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time)) *Database_MarkWorkflowStepTimedOut_Call

func (*Database_MarkWorkflowStepTimedOut_Call) RunAndReturn 

func (_c *Database_MarkWorkflowStepTimedOut_Call) RunAndReturn(run func(ctx context.Context, workflowID string, stepIDs []string, timestamp time.Time) error) *Database_MarkWorkflowStepTimedOut_Call

type Database_MarkWorkflowTimedOut_Call 

type Database_MarkWorkflowTimedOut_Call struct {
	*mock.Call
}

Database_MarkWorkflowTimedOut_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkWorkflowTimedOut'

func (*Database_MarkWorkflowTimedOut_Call) Return 

func (_c *Database_MarkWorkflowTimedOut_Call) Return(err error) *Database_MarkWorkflowTimedOut_Call

func (*Database_MarkWorkflowTimedOut_Call) Run 

func (_c *Database_MarkWorkflowTimedOut_Call) Run(run func(ctx context.Context, workflowID string, timestamp time.Time)) *Database_MarkWorkflowTimedOut_Call

func (*Database_MarkWorkflowTimedOut_Call) RunAndReturn 

func (_c *Database_MarkWorkflowTimedOut_Call) RunAndReturn(run func(ctx context.Context, workflowID string, timestamp time.Time) error) *Database_MarkWorkflowTimedOut_Call

type Database_RecordInvalidTaskIPCMessage_Call 

type Database_RecordInvalidTaskIPCMessage_Call struct {
	*mock.Call
}

Database_RecordInvalidTaskIPCMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordInvalidTaskIPCMessage'

func (*Database_RecordInvalidTaskIPCMessage_Call) Return 

func (_c *Database_RecordInvalidTaskIPCMessage_Call) Return(err error) *Database_RecordInvalidTaskIPCMessage_Call

func (*Database_RecordInvalidTaskIPCMessage_Call) Run 

func (_c *Database_RecordInvalidTaskIPCMessage_Call) Run(run func(ctx context.Context, receiver string, rawMessage string, reason string)) *Database_RecordInvalidTaskIPCMessage_Call

func (*Database_RecordInvalidTaskIPCMessage_Call) RunAndReturn 

func (_c *Database_RecordInvalidTaskIPCMessage_Call) RunAndReturn(run func(ctx context.Context, receiver string, rawMessage string, reason string) error) *Database_RecordInvalidTaskIPCMessage_Call

type Database_RecordTaskEngineFailure_Call 

type Database_RecordTaskEngineFailure_Call struct {
	*mock.Call
}

Database_RecordTaskEngineFailure_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordTaskEngineFailure'

func (*Database_RecordTaskEngineFailure_Call) Return 

func (_c *Database_RecordTaskEngineFailure_Call) Return(err error) *Database_RecordTaskEngineFailure_Call

func (*Database_RecordTaskEngineFailure_Call) Run 

func (_c *Database_RecordTaskEngineFailure_Call) Run(run func(ctx context.Context, task models.Task, instanceID string, reason string)) *Database_RecordTaskEngineFailure_Call

func (*Database_RecordTaskEngineFailure_Call) RunAndReturn 

func (_c *Database_RecordTaskEngineFailure_Call) RunAndReturn(run func(ctx context.Context, task models.Task, instanceID string, reason string) error) *Database_RecordTaskEngineFailure_Call

type Database_UpdateTaskDeadline_Call 

type Database_UpdateTaskDeadline_Call struct {
	*mock.Call
}

Database_UpdateTaskDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTaskDeadline'

func (*Database_UpdateTaskDeadline_Call) Return 

func (_c *Database_UpdateTaskDeadline_Call) Return(err error) *Database_UpdateTaskDeadline_Call

func (*Database_UpdateTaskDeadline_Call) Run 

func (_c *Database_UpdateTaskDeadline_Call) Run(run func(ctx context.Context, taskID string, deadline time.Time)) *Database_UpdateTaskDeadline_Call

func (*Database_UpdateTaskDeadline_Call) RunAndReturn 

func (_c *Database_UpdateTaskDeadline_Call) RunAndReturn(run func(ctx context.Context, taskID string, deadline time.Time) error) *Database_UpdateTaskDeadline_Call

type Database_UpdateWorkflowDeadline_Call 

type Database_UpdateWorkflowDeadline_Call struct {
	*mock.Call
}

Database_UpdateWorkflowDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateWorkflowDeadline'

func (*Database_UpdateWorkflowDeadline_Call) Return 

func (_c *Database_UpdateWorkflowDeadline_Call) Return(err error) *Database_UpdateWorkflowDeadline_Call

func (*Database_UpdateWorkflowDeadline_Call) Run 

func (_c *Database_UpdateWorkflowDeadline_Call) Run(run func(ctx context.Context, workflowID string, deadline time.Time)) *Database_UpdateWorkflowDeadline_Call

func (*Database_UpdateWorkflowDeadline_Call) RunAndReturn 

func (_c *Database_UpdateWorkflowDeadline_Call) RunAndReturn(run func(ctx context.Context, workflowID string, deadline time.Time) error) *Database_UpdateWorkflowDeadline_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.