Documentation
¶
Index ¶
- type Backend
- func (_m *Backend) AbandonActivityWorkItem(_a0 context.Context, _a1 *backend.ActivityWorkItem) error
- func (_m *Backend) AbandonOrchestrationWorkItem(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) error
- func (_m *Backend) AddNewOrchestrationEvent(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent) error
- func (_m *Backend) CompleteActivityWorkItem(_a0 context.Context, _a1 *backend.ActivityWorkItem) error
- func (_m *Backend) CompleteOrchestrationWorkItem(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) error
- func (_m *Backend) CreateOrchestrationInstance(_a0 context.Context, _a1 *protos.HistoryEvent) error
- func (_m *Backend) CreateTaskHub(_a0 context.Context) error
- func (_m *Backend) DeleteTaskHub(_a0 context.Context) error
- func (_m *Backend) EXPECT() *Backend_Expecter
- func (_m *Backend) GetActivityWorkItem(_a0 context.Context) (*backend.ActivityWorkItem, error)
- func (_m *Backend) GetOrchestrationMetadata(_a0 context.Context, _a1 api.InstanceID) (*api.OrchestrationMetadata, error)
- func (_m *Backend) GetOrchestrationRuntimeState(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) (*backend.OrchestrationRuntimeState, error)
- func (_m *Backend) GetOrchestrationWorkItem(_a0 context.Context) (*backend.OrchestrationWorkItem, error)
- func (_m *Backend) PurgeOrchestrationState(_a0 context.Context, _a1 api.InstanceID) error
- func (_m *Backend) Start(_a0 context.Context) error
- func (_m *Backend) Stop(_a0 context.Context) error
- type Backend_AbandonActivityWorkItem_Call
- type Backend_AbandonOrchestrationWorkItem_Call
- type Backend_AddNewOrchestrationEvent_Call
- type Backend_CompleteActivityWorkItem_Call
- type Backend_CompleteOrchestrationWorkItem_Call
- type Backend_CreateOrchestrationInstance_Call
- type Backend_CreateTaskHub_Call
- type Backend_DeleteTaskHub_Call
- type Backend_Expecter
- func (_e *Backend_Expecter) AbandonActivityWorkItem(_a0 interface{}, _a1 interface{}) *Backend_AbandonActivityWorkItem_Call
- func (_e *Backend_Expecter) AbandonOrchestrationWorkItem(_a0 interface{}, _a1 interface{}) *Backend_AbandonOrchestrationWorkItem_Call
- func (_e *Backend_Expecter) AddNewOrchestrationEvent(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Backend_AddNewOrchestrationEvent_Call
- func (_e *Backend_Expecter) CompleteActivityWorkItem(_a0 interface{}, _a1 interface{}) *Backend_CompleteActivityWorkItem_Call
- func (_e *Backend_Expecter) CompleteOrchestrationWorkItem(_a0 interface{}, _a1 interface{}) *Backend_CompleteOrchestrationWorkItem_Call
- func (_e *Backend_Expecter) CreateOrchestrationInstance(_a0 interface{}, _a1 interface{}) *Backend_CreateOrchestrationInstance_Call
- func (_e *Backend_Expecter) CreateTaskHub(_a0 interface{}) *Backend_CreateTaskHub_Call
- func (_e *Backend_Expecter) DeleteTaskHub(_a0 interface{}) *Backend_DeleteTaskHub_Call
- func (_e *Backend_Expecter) GetActivityWorkItem(_a0 interface{}) *Backend_GetActivityWorkItem_Call
- func (_e *Backend_Expecter) GetOrchestrationMetadata(_a0 interface{}, _a1 interface{}) *Backend_GetOrchestrationMetadata_Call
- func (_e *Backend_Expecter) GetOrchestrationRuntimeState(_a0 interface{}, _a1 interface{}) *Backend_GetOrchestrationRuntimeState_Call
- func (_e *Backend_Expecter) GetOrchestrationWorkItem(_a0 interface{}) *Backend_GetOrchestrationWorkItem_Call
- func (_e *Backend_Expecter) PurgeOrchestrationState(_a0 interface{}, _a1 interface{}) *Backend_PurgeOrchestrationState_Call
- func (_e *Backend_Expecter) Start(_a0 interface{}) *Backend_Start_Call
- func (_e *Backend_Expecter) Stop(_a0 interface{}) *Backend_Stop_Call
- type Backend_GetActivityWorkItem_Call
- type Backend_GetOrchestrationMetadata_Call
- type Backend_GetOrchestrationRuntimeState_Call
- func (_c *Backend_GetOrchestrationRuntimeState_Call) Return(_a0 *backend.OrchestrationRuntimeState, _a1 error) *Backend_GetOrchestrationRuntimeState_Call
- func (_c *Backend_GetOrchestrationRuntimeState_Call) Run(run func(_a0 context.Context, _a1 *backend.OrchestrationWorkItem)) *Backend_GetOrchestrationRuntimeState_Call
- type Backend_GetOrchestrationWorkItem_Call
- type Backend_PurgeOrchestrationState_Call
- type Backend_Start_Call
- type Backend_Stop_Call
- type Executor
- func (_m *Executor) EXPECT() *Executor_Expecter
- func (_m *Executor) ExecuteActivity(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent) (*protos.HistoryEvent, error)
- func (_m *Executor) ExecuteOrchestrator(ctx context.Context, iid api.InstanceID, oldEvents []*protos.HistoryEvent, ...) (*backend.ExecutionResults, error)
- type Executor_ExecuteActivity_Call
- type Executor_ExecuteOrchestrator_Call
- type Executor_Expecter
- type TaskWorker
- type TaskWorker_Expecter
- type TaskWorker_ProcessNext_Call
- type TaskWorker_Start_Call
- type TaskWorker_StopAndDrain_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Backend ¶
Backend is an autogenerated mock type for the Backend type
func NewBackend ¶
func NewBackend(t mockConstructorTestingTNewBackend) *Backend
NewBackend creates a new instance of Backend. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Backend) AbandonActivityWorkItem ¶
func (_m *Backend) AbandonActivityWorkItem(_a0 context.Context, _a1 *backend.ActivityWorkItem) error
AbandonActivityWorkItem provides a mock function with given fields: _a0, _a1
func (*Backend) AbandonOrchestrationWorkItem ¶
func (_m *Backend) AbandonOrchestrationWorkItem(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) error
AbandonOrchestrationWorkItem provides a mock function with given fields: _a0, _a1
func (*Backend) AddNewOrchestrationEvent ¶
func (_m *Backend) AddNewOrchestrationEvent(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent) error
AddNewOrchestrationEvent provides a mock function with given fields: _a0, _a1, _a2
func (*Backend) CompleteActivityWorkItem ¶
func (_m *Backend) CompleteActivityWorkItem(_a0 context.Context, _a1 *backend.ActivityWorkItem) error
CompleteActivityWorkItem provides a mock function with given fields: _a0, _a1
func (*Backend) CompleteOrchestrationWorkItem ¶
func (_m *Backend) CompleteOrchestrationWorkItem(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) error
CompleteOrchestrationWorkItem provides a mock function with given fields: _a0, _a1
func (*Backend) CreateOrchestrationInstance ¶
CreateOrchestrationInstance provides a mock function with given fields: _a0, _a1
func (*Backend) CreateTaskHub ¶
CreateTaskHub provides a mock function with given fields: _a0
func (*Backend) DeleteTaskHub ¶
DeleteTaskHub provides a mock function with given fields: _a0
func (*Backend) EXPECT ¶
func (_m *Backend) EXPECT() *Backend_Expecter
func (*Backend) GetActivityWorkItem ¶
GetActivityWorkItem provides a mock function with given fields: _a0
func (*Backend) GetOrchestrationMetadata ¶
func (_m *Backend) GetOrchestrationMetadata(_a0 context.Context, _a1 api.InstanceID) (*api.OrchestrationMetadata, error)
GetOrchestrationMetadata provides a mock function with given fields: _a0, _a1
func (*Backend) GetOrchestrationRuntimeState ¶
func (_m *Backend) GetOrchestrationRuntimeState(_a0 context.Context, _a1 *backend.OrchestrationWorkItem) (*backend.OrchestrationRuntimeState, error)
GetOrchestrationRuntimeState provides a mock function with given fields: _a0, _a1
func (*Backend) GetOrchestrationWorkItem ¶
func (_m *Backend) GetOrchestrationWorkItem(_a0 context.Context) (*backend.OrchestrationWorkItem, error)
GetOrchestrationWorkItem provides a mock function with given fields: _a0
func (*Backend) PurgeOrchestrationState ¶ added in v0.2.0
PurgeOrchestrationState provides a mock function with given fields: _a0, _a1
type Backend_AbandonActivityWorkItem_Call ¶
Backend_AbandonActivityWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AbandonActivityWorkItem'
func (*Backend_AbandonActivityWorkItem_Call) Return ¶
func (_c *Backend_AbandonActivityWorkItem_Call) Return(_a0 error) *Backend_AbandonActivityWorkItem_Call
func (*Backend_AbandonActivityWorkItem_Call) Run ¶
func (_c *Backend_AbandonActivityWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.ActivityWorkItem)) *Backend_AbandonActivityWorkItem_Call
type Backend_AbandonOrchestrationWorkItem_Call ¶
Backend_AbandonOrchestrationWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AbandonOrchestrationWorkItem'
func (*Backend_AbandonOrchestrationWorkItem_Call) Return ¶
func (_c *Backend_AbandonOrchestrationWorkItem_Call) Return(_a0 error) *Backend_AbandonOrchestrationWorkItem_Call
func (*Backend_AbandonOrchestrationWorkItem_Call) Run ¶
func (_c *Backend_AbandonOrchestrationWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.OrchestrationWorkItem)) *Backend_AbandonOrchestrationWorkItem_Call
type Backend_AddNewOrchestrationEvent_Call ¶
Backend_AddNewOrchestrationEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddNewOrchestrationEvent'
func (*Backend_AddNewOrchestrationEvent_Call) Return ¶
func (_c *Backend_AddNewOrchestrationEvent_Call) Return(_a0 error) *Backend_AddNewOrchestrationEvent_Call
func (*Backend_AddNewOrchestrationEvent_Call) Run ¶
func (_c *Backend_AddNewOrchestrationEvent_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent)) *Backend_AddNewOrchestrationEvent_Call
type Backend_CompleteActivityWorkItem_Call ¶
Backend_CompleteActivityWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteActivityWorkItem'
func (*Backend_CompleteActivityWorkItem_Call) Return ¶
func (_c *Backend_CompleteActivityWorkItem_Call) Return(_a0 error) *Backend_CompleteActivityWorkItem_Call
func (*Backend_CompleteActivityWorkItem_Call) Run ¶
func (_c *Backend_CompleteActivityWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.ActivityWorkItem)) *Backend_CompleteActivityWorkItem_Call
type Backend_CompleteOrchestrationWorkItem_Call ¶
Backend_CompleteOrchestrationWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteOrchestrationWorkItem'
func (*Backend_CompleteOrchestrationWorkItem_Call) Return ¶
func (_c *Backend_CompleteOrchestrationWorkItem_Call) Return(_a0 error) *Backend_CompleteOrchestrationWorkItem_Call
func (*Backend_CompleteOrchestrationWorkItem_Call) Run ¶
func (_c *Backend_CompleteOrchestrationWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.OrchestrationWorkItem)) *Backend_CompleteOrchestrationWorkItem_Call
type Backend_CreateOrchestrationInstance_Call ¶
Backend_CreateOrchestrationInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOrchestrationInstance'
func (*Backend_CreateOrchestrationInstance_Call) Return ¶
func (_c *Backend_CreateOrchestrationInstance_Call) Return(_a0 error) *Backend_CreateOrchestrationInstance_Call
func (*Backend_CreateOrchestrationInstance_Call) Run ¶
func (_c *Backend_CreateOrchestrationInstance_Call) Run(run func(_a0 context.Context, _a1 *protos.HistoryEvent)) *Backend_CreateOrchestrationInstance_Call
type Backend_CreateTaskHub_Call ¶
Backend_CreateTaskHub_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTaskHub'
func (*Backend_CreateTaskHub_Call) Return ¶
func (_c *Backend_CreateTaskHub_Call) Return(_a0 error) *Backend_CreateTaskHub_Call
func (*Backend_CreateTaskHub_Call) Run ¶
func (_c *Backend_CreateTaskHub_Call) Run(run func(_a0 context.Context)) *Backend_CreateTaskHub_Call
type Backend_DeleteTaskHub_Call ¶
Backend_DeleteTaskHub_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTaskHub'
func (*Backend_DeleteTaskHub_Call) Return ¶
func (_c *Backend_DeleteTaskHub_Call) Return(_a0 error) *Backend_DeleteTaskHub_Call
func (*Backend_DeleteTaskHub_Call) Run ¶
func (_c *Backend_DeleteTaskHub_Call) Run(run func(_a0 context.Context)) *Backend_DeleteTaskHub_Call
type Backend_Expecter ¶
type Backend_Expecter struct {
// contains filtered or unexported fields
}
func (*Backend_Expecter) AbandonActivityWorkItem ¶
func (_e *Backend_Expecter) AbandonActivityWorkItem(_a0 interface{}, _a1 interface{}) *Backend_AbandonActivityWorkItem_Call
AbandonActivityWorkItem is a helper method to define mock.On call
- _a0 context.Context
- _a1 *backend.ActivityWorkItem
func (*Backend_Expecter) AbandonOrchestrationWorkItem ¶
func (_e *Backend_Expecter) AbandonOrchestrationWorkItem(_a0 interface{}, _a1 interface{}) *Backend_AbandonOrchestrationWorkItem_Call
AbandonOrchestrationWorkItem is a helper method to define mock.On call
- _a0 context.Context
- _a1 *backend.OrchestrationWorkItem
func (*Backend_Expecter) AddNewOrchestrationEvent ¶
func (_e *Backend_Expecter) AddNewOrchestrationEvent(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Backend_AddNewOrchestrationEvent_Call
AddNewOrchestrationEvent is a helper method to define mock.On call
- _a0 context.Context
- _a1 api.InstanceID
- _a2 *protos.HistoryEvent
func (*Backend_Expecter) CompleteActivityWorkItem ¶
func (_e *Backend_Expecter) CompleteActivityWorkItem(_a0 interface{}, _a1 interface{}) *Backend_CompleteActivityWorkItem_Call
CompleteActivityWorkItem is a helper method to define mock.On call
- _a0 context.Context
- _a1 *backend.ActivityWorkItem
func (*Backend_Expecter) CompleteOrchestrationWorkItem ¶
func (_e *Backend_Expecter) CompleteOrchestrationWorkItem(_a0 interface{}, _a1 interface{}) *Backend_CompleteOrchestrationWorkItem_Call
CompleteOrchestrationWorkItem is a helper method to define mock.On call
- _a0 context.Context
- _a1 *backend.OrchestrationWorkItem
func (*Backend_Expecter) CreateOrchestrationInstance ¶
func (_e *Backend_Expecter) CreateOrchestrationInstance(_a0 interface{}, _a1 interface{}) *Backend_CreateOrchestrationInstance_Call
CreateOrchestrationInstance is a helper method to define mock.On call
- _a0 context.Context
- _a1 *protos.HistoryEvent
func (*Backend_Expecter) CreateTaskHub ¶
func (_e *Backend_Expecter) CreateTaskHub(_a0 interface{}) *Backend_CreateTaskHub_Call
CreateTaskHub is a helper method to define mock.On call
- _a0 context.Context
func (*Backend_Expecter) DeleteTaskHub ¶
func (_e *Backend_Expecter) DeleteTaskHub(_a0 interface{}) *Backend_DeleteTaskHub_Call
DeleteTaskHub is a helper method to define mock.On call
- _a0 context.Context
func (*Backend_Expecter) GetActivityWorkItem ¶
func (_e *Backend_Expecter) GetActivityWorkItem(_a0 interface{}) *Backend_GetActivityWorkItem_Call
GetActivityWorkItem is a helper method to define mock.On call
- _a0 context.Context
func (*Backend_Expecter) GetOrchestrationMetadata ¶
func (_e *Backend_Expecter) GetOrchestrationMetadata(_a0 interface{}, _a1 interface{}) *Backend_GetOrchestrationMetadata_Call
GetOrchestrationMetadata is a helper method to define mock.On call
- _a0 context.Context
- _a1 api.InstanceID
func (*Backend_Expecter) GetOrchestrationRuntimeState ¶
func (_e *Backend_Expecter) GetOrchestrationRuntimeState(_a0 interface{}, _a1 interface{}) *Backend_GetOrchestrationRuntimeState_Call
GetOrchestrationRuntimeState is a helper method to define mock.On call
- _a0 context.Context
- _a1 *backend.OrchestrationWorkItem
func (*Backend_Expecter) GetOrchestrationWorkItem ¶
func (_e *Backend_Expecter) GetOrchestrationWorkItem(_a0 interface{}) *Backend_GetOrchestrationWorkItem_Call
GetOrchestrationWorkItem is a helper method to define mock.On call
- _a0 context.Context
func (*Backend_Expecter) PurgeOrchestrationState ¶ added in v0.2.0
func (_e *Backend_Expecter) PurgeOrchestrationState(_a0 interface{}, _a1 interface{}) *Backend_PurgeOrchestrationState_Call
PurgeOrchestrationState is a helper method to define mock.On call
- _a0 context.Context
- _a1 api.InstanceID
func (*Backend_Expecter) Start ¶
func (_e *Backend_Expecter) Start(_a0 interface{}) *Backend_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
func (*Backend_Expecter) Stop ¶
func (_e *Backend_Expecter) Stop(_a0 interface{}) *Backend_Stop_Call
Stop is a helper method to define mock.On call
- _a0 context.Context
type Backend_GetActivityWorkItem_Call ¶
Backend_GetActivityWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetActivityWorkItem'
func (*Backend_GetActivityWorkItem_Call) Return ¶
func (_c *Backend_GetActivityWorkItem_Call) Return(_a0 *backend.ActivityWorkItem, _a1 error) *Backend_GetActivityWorkItem_Call
func (*Backend_GetActivityWorkItem_Call) Run ¶
func (_c *Backend_GetActivityWorkItem_Call) Run(run func(_a0 context.Context)) *Backend_GetActivityWorkItem_Call
type Backend_GetOrchestrationMetadata_Call ¶
Backend_GetOrchestrationMetadata_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOrchestrationMetadata'
func (*Backend_GetOrchestrationMetadata_Call) Return ¶
func (_c *Backend_GetOrchestrationMetadata_Call) Return(_a0 *api.OrchestrationMetadata, _a1 error) *Backend_GetOrchestrationMetadata_Call
func (*Backend_GetOrchestrationMetadata_Call) Run ¶
func (_c *Backend_GetOrchestrationMetadata_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID)) *Backend_GetOrchestrationMetadata_Call
type Backend_GetOrchestrationRuntimeState_Call ¶
Backend_GetOrchestrationRuntimeState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOrchestrationRuntimeState'
func (*Backend_GetOrchestrationRuntimeState_Call) Return ¶
func (_c *Backend_GetOrchestrationRuntimeState_Call) Return(_a0 *backend.OrchestrationRuntimeState, _a1 error) *Backend_GetOrchestrationRuntimeState_Call
func (*Backend_GetOrchestrationRuntimeState_Call) Run ¶
func (_c *Backend_GetOrchestrationRuntimeState_Call) Run(run func(_a0 context.Context, _a1 *backend.OrchestrationWorkItem)) *Backend_GetOrchestrationRuntimeState_Call
type Backend_GetOrchestrationWorkItem_Call ¶
Backend_GetOrchestrationWorkItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOrchestrationWorkItem'
func (*Backend_GetOrchestrationWorkItem_Call) Return ¶
func (_c *Backend_GetOrchestrationWorkItem_Call) Return(_a0 *backend.OrchestrationWorkItem, _a1 error) *Backend_GetOrchestrationWorkItem_Call
func (*Backend_GetOrchestrationWorkItem_Call) Run ¶
func (_c *Backend_GetOrchestrationWorkItem_Call) Run(run func(_a0 context.Context)) *Backend_GetOrchestrationWorkItem_Call
type Backend_PurgeOrchestrationState_Call ¶ added in v0.2.0
Backend_PurgeOrchestrationState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeOrchestrationState'
func (*Backend_PurgeOrchestrationState_Call) Return ¶ added in v0.2.0
func (_c *Backend_PurgeOrchestrationState_Call) Return(_a0 error) *Backend_PurgeOrchestrationState_Call
func (*Backend_PurgeOrchestrationState_Call) Run ¶ added in v0.2.0
func (_c *Backend_PurgeOrchestrationState_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID)) *Backend_PurgeOrchestrationState_Call
type Backend_Start_Call ¶
Backend_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Backend_Start_Call) Return ¶
func (_c *Backend_Start_Call) Return(_a0 error) *Backend_Start_Call
func (*Backend_Start_Call) Run ¶
func (_c *Backend_Start_Call) Run(run func(_a0 context.Context)) *Backend_Start_Call
type Backend_Stop_Call ¶
Backend_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Backend_Stop_Call) Return ¶
func (_c *Backend_Stop_Call) Return(_a0 error) *Backend_Stop_Call
func (*Backend_Stop_Call) Run ¶
func (_c *Backend_Stop_Call) Run(run func(_a0 context.Context)) *Backend_Stop_Call
type Executor ¶
Executor is an autogenerated mock type for the Executor type
func NewExecutor ¶
func NewExecutor(t mockConstructorTestingTNewExecutor) *Executor
NewExecutor creates a new instance of Executor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Executor) EXPECT ¶
func (_m *Executor) EXPECT() *Executor_Expecter
func (*Executor) ExecuteActivity ¶
func (_m *Executor) ExecuteActivity(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent) (*protos.HistoryEvent, error)
ExecuteActivity provides a mock function with given fields: _a0, _a1, _a2
func (*Executor) ExecuteOrchestrator ¶
func (_m *Executor) ExecuteOrchestrator(ctx context.Context, iid api.InstanceID, oldEvents []*protos.HistoryEvent, newEvents []*protos.HistoryEvent) (*backend.ExecutionResults, error)
ExecuteOrchestrator provides a mock function with given fields: ctx, iid, oldEvents, newEvents
type Executor_ExecuteActivity_Call ¶
Executor_ExecuteActivity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteActivity'
func (*Executor_ExecuteActivity_Call) Return ¶
func (_c *Executor_ExecuteActivity_Call) Return(_a0 *protos.HistoryEvent, _a1 error) *Executor_ExecuteActivity_Call
func (*Executor_ExecuteActivity_Call) Run ¶
func (_c *Executor_ExecuteActivity_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent)) *Executor_ExecuteActivity_Call
type Executor_ExecuteOrchestrator_Call ¶
Executor_ExecuteOrchestrator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteOrchestrator'
func (*Executor_ExecuteOrchestrator_Call) Return ¶
func (_c *Executor_ExecuteOrchestrator_Call) Return(_a0 *backend.ExecutionResults, _a1 error) *Executor_ExecuteOrchestrator_Call
func (*Executor_ExecuteOrchestrator_Call) Run ¶
func (_c *Executor_ExecuteOrchestrator_Call) Run(run func(ctx context.Context, iid api.InstanceID, oldEvents []*protos.HistoryEvent, newEvents []*protos.HistoryEvent)) *Executor_ExecuteOrchestrator_Call
type Executor_Expecter ¶
type Executor_Expecter struct {
// contains filtered or unexported fields
}
func (*Executor_Expecter) ExecuteActivity ¶
func (_e *Executor_Expecter) ExecuteActivity(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Executor_ExecuteActivity_Call
ExecuteActivity is a helper method to define mock.On call
- _a0 context.Context
- _a1 api.InstanceID
- _a2 *protos.HistoryEvent
func (*Executor_Expecter) ExecuteOrchestrator ¶
func (_e *Executor_Expecter) ExecuteOrchestrator(ctx interface{}, iid interface{}, oldEvents interface{}, newEvents interface{}) *Executor_ExecuteOrchestrator_Call
ExecuteOrchestrator is a helper method to define mock.On call
- ctx context.Context
- iid api.InstanceID
- oldEvents []*protos.HistoryEvent
- newEvents []*protos.HistoryEvent
type TaskWorker ¶
TaskWorker is an autogenerated mock type for the TaskWorker type
func NewTaskWorker ¶
func NewTaskWorker(t mockConstructorTestingTNewTaskWorker) *TaskWorker
NewTaskWorker creates a new instance of TaskWorker. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TaskWorker) EXPECT ¶
func (_m *TaskWorker) EXPECT() *TaskWorker_Expecter
func (*TaskWorker) ProcessNext ¶
func (_m *TaskWorker) ProcessNext(_a0 context.Context) (bool, error)
ProcessNext provides a mock function with given fields: _a0
func (*TaskWorker) Start ¶
func (_m *TaskWorker) Start(_a0 context.Context)
Start provides a mock function with given fields: _a0
func (*TaskWorker) StopAndDrain ¶
func (_m *TaskWorker) StopAndDrain()
StopAndDrain provides a mock function with given fields:
type TaskWorker_Expecter ¶
type TaskWorker_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskWorker_Expecter) ProcessNext ¶
func (_e *TaskWorker_Expecter) ProcessNext(_a0 interface{}) *TaskWorker_ProcessNext_Call
ProcessNext is a helper method to define mock.On call
- _a0 context.Context
func (*TaskWorker_Expecter) Start ¶
func (_e *TaskWorker_Expecter) Start(_a0 interface{}) *TaskWorker_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
func (*TaskWorker_Expecter) StopAndDrain ¶
func (_e *TaskWorker_Expecter) StopAndDrain() *TaskWorker_StopAndDrain_Call
StopAndDrain is a helper method to define mock.On call
type TaskWorker_ProcessNext_Call ¶
TaskWorker_ProcessNext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessNext'
func (*TaskWorker_ProcessNext_Call) Return ¶
func (_c *TaskWorker_ProcessNext_Call) Return(_a0 bool, _a1 error) *TaskWorker_ProcessNext_Call
func (*TaskWorker_ProcessNext_Call) Run ¶
func (_c *TaskWorker_ProcessNext_Call) Run(run func(_a0 context.Context)) *TaskWorker_ProcessNext_Call
type TaskWorker_Start_Call ¶
TaskWorker_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*TaskWorker_Start_Call) Return ¶
func (_c *TaskWorker_Start_Call) Return() *TaskWorker_Start_Call
func (*TaskWorker_Start_Call) Run ¶
func (_c *TaskWorker_Start_Call) Run(run func(_a0 context.Context)) *TaskWorker_Start_Call
type TaskWorker_StopAndDrain_Call ¶
TaskWorker_StopAndDrain_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopAndDrain'
func (*TaskWorker_StopAndDrain_Call) Return ¶
func (_c *TaskWorker_StopAndDrain_Call) Return() *TaskWorker_StopAndDrain_Call
func (*TaskWorker_StopAndDrain_Call) Run ¶
func (_c *TaskWorker_StopAndDrain_Call) Run(run func()) *TaskWorker_StopAndDrain_Call