mocks

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Backend 

type Backend struct {
	mock.Mock
}

Backend is an autogenerated mock type for the Backend type

func NewBackend 

func NewBackend(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

func (_m *Backend) CreateOrchestrationInstance(_a0 context.Context, _a1 *protos.HistoryEvent, _a2 ...backend.OrchestrationIdReusePolicyOptions) error

CreateOrchestrationInstance provides a mock function with given fields: _a0, _a1, _a2

func (*Backend) CreateTaskHub 

func (_m *Backend) CreateTaskHub(_a0 context.Context) error

CreateTaskHub provides a mock function with given fields: _a0

func (*Backend) DeleteTaskHub 

func (_m *Backend) DeleteTaskHub(_a0 context.Context) error

DeleteTaskHub provides a mock function with given fields: _a0

func (*Backend) EXPECT 

func (_m *Backend) EXPECT() *Backend_Expecter

func (*Backend) GetActivityWorkItem 

func (_m *Backend) GetActivityWorkItem(_a0 context.Context) (*backend.ActivityWorkItem, error)

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 

func (_m *Backend) PurgeOrchestrationState(_a0 context.Context, _a1 api.InstanceID) error

PurgeOrchestrationState provides a mock function with given fields: _a0, _a1

func (*Backend) Start 

func (_m *Backend) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*Backend) Stop 

func (_m *Backend) Stop(_a0 context.Context) error

Stop provides a mock function with given fields: _a0

type Backend_AbandonActivityWorkItem_Call 

type Backend_AbandonActivityWorkItem_Call struct {
	*mock.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

func (*Backend_AbandonActivityWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_AbandonActivityWorkItem_Call) RunAndReturn(run func(context.Context, *backend.ActivityWorkItem) error) *Backend_AbandonActivityWorkItem_Call

type Backend_AbandonOrchestrationWorkItem_Call 

type Backend_AbandonOrchestrationWorkItem_Call struct {
	*mock.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

func (*Backend_AbandonOrchestrationWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_AbandonOrchestrationWorkItem_Call) RunAndReturn(run func(context.Context, *backend.OrchestrationWorkItem) error) *Backend_AbandonOrchestrationWorkItem_Call

type Backend_AddNewOrchestrationEvent_Call 

type Backend_AddNewOrchestrationEvent_Call struct {
	*mock.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

func (*Backend_AddNewOrchestrationEvent_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_AddNewOrchestrationEvent_Call) RunAndReturn(run func(context.Context, api.InstanceID, *protos.HistoryEvent) error) *Backend_AddNewOrchestrationEvent_Call

type Backend_CompleteActivityWorkItem_Call 

type Backend_CompleteActivityWorkItem_Call struct {
	*mock.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

func (*Backend_CompleteActivityWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_CompleteActivityWorkItem_Call) RunAndReturn(run func(context.Context, *backend.ActivityWorkItem) error) *Backend_CompleteActivityWorkItem_Call

type Backend_CompleteOrchestrationWorkItem_Call 

type Backend_CompleteOrchestrationWorkItem_Call struct {
	*mock.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

func (*Backend_CompleteOrchestrationWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_CompleteOrchestrationWorkItem_Call) RunAndReturn(run func(context.Context, *backend.OrchestrationWorkItem) error) *Backend_CompleteOrchestrationWorkItem_Call

type Backend_CreateOrchestrationInstance_Call 

type Backend_CreateOrchestrationInstance_Call struct {
	*mock.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, _a2 ...backend.OrchestrationIdReusePolicyOptions)) *Backend_CreateOrchestrationInstance_Call

func (*Backend_CreateOrchestrationInstance_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_CreateOrchestrationInstance_Call) RunAndReturn(run func(context.Context, *protos.HistoryEvent, ...backend.OrchestrationIdReusePolicyOptions) error) *Backend_CreateOrchestrationInstance_Call

type Backend_CreateTaskHub_Call 

type Backend_CreateTaskHub_Call struct {
	*mock.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

func (*Backend_CreateTaskHub_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_CreateTaskHub_Call) RunAndReturn(run func(context.Context) error) *Backend_CreateTaskHub_Call

type Backend_DeleteTaskHub_Call 

type Backend_DeleteTaskHub_Call struct {
	*mock.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

func (*Backend_DeleteTaskHub_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_DeleteTaskHub_Call) RunAndReturn(run func(context.Context) error) *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{}, _a2 ...interface{}) *Backend_CreateOrchestrationInstance_Call

CreateOrchestrationInstance is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *protos.HistoryEvent
  • _a2 ...backend.OrchestrationIdReusePolicyOptions

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 

type Backend_GetActivityWorkItem_Call struct {
	*mock.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

func (*Backend_GetActivityWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_GetActivityWorkItem_Call) RunAndReturn(run func(context.Context) (*backend.ActivityWorkItem, error)) *Backend_GetActivityWorkItem_Call

type Backend_GetOrchestrationMetadata_Call 

type Backend_GetOrchestrationMetadata_Call struct {
	*mock.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

func (*Backend_GetOrchestrationMetadata_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_GetOrchestrationMetadata_Call) RunAndReturn(run func(context.Context, api.InstanceID) (*api.OrchestrationMetadata, error)) *Backend_GetOrchestrationMetadata_Call

type Backend_GetOrchestrationRuntimeState_Call 

type Backend_GetOrchestrationRuntimeState_Call struct {
	*mock.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

func (*Backend_GetOrchestrationRuntimeState_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_GetOrchestrationRuntimeState_Call) RunAndReturn(run func(context.Context, *backend.OrchestrationWorkItem) (*backend.OrchestrationRuntimeState, error)) *Backend_GetOrchestrationRuntimeState_Call

type Backend_GetOrchestrationWorkItem_Call 

type Backend_GetOrchestrationWorkItem_Call struct {
	*mock.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

func (*Backend_GetOrchestrationWorkItem_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_GetOrchestrationWorkItem_Call) RunAndReturn(run func(context.Context) (*backend.OrchestrationWorkItem, error)) *Backend_GetOrchestrationWorkItem_Call

type Backend_PurgeOrchestrationState_Call added in v0.2.0 

type Backend_PurgeOrchestrationState_Call struct {
	*mock.Call
}

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

func (*Backend_PurgeOrchestrationState_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_PurgeOrchestrationState_Call) RunAndReturn(run func(context.Context, api.InstanceID) error) *Backend_PurgeOrchestrationState_Call

type Backend_Start_Call 

type Backend_Start_Call struct {
	*mock.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

func (*Backend_Start_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_Start_Call) RunAndReturn(run func(context.Context) error) *Backend_Start_Call

type Backend_Stop_Call 

type Backend_Stop_Call struct {
	*mock.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

func (*Backend_Stop_Call) RunAndReturn added in v0.3.2 

func (_c *Backend_Stop_Call) RunAndReturn(run func(context.Context) error) *Backend_Stop_Call

type Executor 

type Executor struct {
	mock.Mock
}

Executor is an autogenerated mock type for the Executor type

func NewExecutor 

func NewExecutor(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type Executor_ExecuteActivity_Call struct {
	*mock.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

func (*Executor_ExecuteActivity_Call) RunAndReturn added in v0.3.2 

func (_c *Executor_ExecuteActivity_Call) RunAndReturn(run func(context.Context, api.InstanceID, *protos.HistoryEvent) (*protos.HistoryEvent, error)) *Executor_ExecuteActivity_Call

type Executor_ExecuteOrchestrator_Call 

type Executor_ExecuteOrchestrator_Call struct {
	*mock.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

func (*Executor_ExecuteOrchestrator_Call) RunAndReturn added in v0.3.2 

func (_c *Executor_ExecuteOrchestrator_Call) RunAndReturn(run func(context.Context, api.InstanceID, []*protos.HistoryEvent, []*protos.HistoryEvent) (*backend.ExecutionResults, error)) *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 

type TaskWorker struct {
	mock.Mock
}

TaskWorker is an autogenerated mock type for the TaskWorker type

func NewTaskWorker 

func NewTaskWorker(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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 

type TaskWorker_ProcessNext_Call struct {
	*mock.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

func (*TaskWorker_ProcessNext_Call) RunAndReturn added in v0.3.2 

func (_c *TaskWorker_ProcessNext_Call) RunAndReturn(run func(context.Context) (bool, error)) *TaskWorker_ProcessNext_Call

type TaskWorker_Start_Call 

type TaskWorker_Start_Call struct {
	*mock.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

func (*TaskWorker_Start_Call) RunAndReturn added in v0.3.2 

func (_c *TaskWorker_Start_Call) RunAndReturn(run func(context.Context)) *TaskWorker_Start_Call

type TaskWorker_StopAndDrain_Call 

type TaskWorker_StopAndDrain_Call struct {
	*mock.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

func (*TaskWorker_StopAndDrain_Call) RunAndReturn added in v0.3.2 

func (_c *TaskWorker_StopAndDrain_Call) RunAndReturn(run func()) *TaskWorker_StopAndDrain_Call

type TestTaskProcessor added in v0.6.0 

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

TestTaskProcessor implements a dummy task processor useful for testing

func NewTestTaskPocessor added in v0.6.0 

func NewTestTaskPocessor(name string) *TestTaskProcessor

func (*TestTaskProcessor) AbandonWorkItem added in v0.6.0 

func (t *TestTaskProcessor) AbandonWorkItem(ctx context.Context, wi backend.WorkItem) error

func (*TestTaskProcessor) AbandonedWorkItems added in v0.6.0 

func (t *TestTaskProcessor) AbandonedWorkItems() []backend.WorkItem

func (*TestTaskProcessor) AddWorkItems added in v0.6.0 

func (t *TestTaskProcessor) AddWorkItems(wis ...backend.WorkItem)

func (*TestTaskProcessor) BlockProcessing added in v0.6.0 

func (t *TestTaskProcessor) BlockProcessing()

func (*TestTaskProcessor) CompleteWorkItem added in v0.6.0 

func (t *TestTaskProcessor) CompleteWorkItem(ctx context.Context, wi backend.WorkItem) error

func (*TestTaskProcessor) CompletedWorkItems added in v0.6.0 

func (t *TestTaskProcessor) CompletedWorkItems() []backend.WorkItem

func (*TestTaskProcessor) FetchWorkItem added in v0.6.0 

func (t *TestTaskProcessor) FetchWorkItem(context.Context) (backend.WorkItem, error)

func (*TestTaskProcessor) Name added in v0.6.0 

func (t *TestTaskProcessor) Name() string

func (*TestTaskProcessor) PendingWorkItems added in v0.6.0 

func (t *TestTaskProcessor) PendingWorkItems() []backend.WorkItem

func (*TestTaskProcessor) ProcessWorkItem added in v0.6.0 

func (t *TestTaskProcessor) ProcessWorkItem(ctx context.Context, wi backend.WorkItem) error

func (*TestTaskProcessor) UnblockProcessing added in v0.6.0 

func (t *TestTaskProcessor) UnblockProcessing()

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.