mocks

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 6, 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) GetOrchestrationMetadata 

func (_m *Backend) GetOrchestrationMetadata(_a0 context.Context, _a1 api.InstanceID) (*protos.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) (*protos.OrchestrationRuntimeState, error)

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

func (*Backend) NextActivityWorkItem 

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

NextActivityWorkItem provides a mock function with given fields: _a0

func (*Backend) NextOrchestrationWorkItem 

func (_m *Backend) NextOrchestrationWorkItem(_a0 context.Context) (*backend.OrchestrationWorkItem, error)

NextOrchestrationWorkItem provides a mock function with given fields: _a0

func (*Backend) PurgeOrchestrationState 

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

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

func (*Backend) RerunWorkflowFromEvent added in v0.7.0 

func (_m *Backend) RerunWorkflowFromEvent(ctx context.Context, req *protos.RerunWorkflowFromEventRequest) (api.InstanceID, error)

RerunWorkflowFromEvent provides a mock function with given fields: ctx, req

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

func (*Backend) WatchOrchestrationRuntimeStatus 

func (_m *Backend) WatchOrchestrationRuntimeStatus(ctx context.Context, id api.InstanceID, ch chan<- *protos.OrchestrationMetadata) error

WatchOrchestrationRuntimeStatus provides a mock function with given fields: ctx, id, ch

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 

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 

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 

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 

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 

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 

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 

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 

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

func (_e *Backend_Expecter) NextActivityWorkItem(_a0 interface{}) *Backend_NextActivityWorkItem_Call

NextActivityWorkItem is a helper method to define mock.On call

  • _a0 context.Context

func (*Backend_Expecter) NextOrchestrationWorkItem 

func (_e *Backend_Expecter) NextOrchestrationWorkItem(_a0 interface{}) *Backend_NextOrchestrationWorkItem_Call

NextOrchestrationWorkItem is a helper method to define mock.On call

  • _a0 context.Context

func (*Backend_Expecter) PurgeOrchestrationState 

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) RerunWorkflowFromEvent added in v0.7.0 

func (_e *Backend_Expecter) RerunWorkflowFromEvent(ctx interface{}, req interface{}) *Backend_RerunWorkflowFromEvent_Call

RerunWorkflowFromEvent is a helper method to define mock.On call

  • ctx context.Context
  • req *protos.RerunWorkflowFromEventRequest

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

func (*Backend_Expecter) WatchOrchestrationRuntimeStatus 

func (_e *Backend_Expecter) WatchOrchestrationRuntimeStatus(ctx interface{}, id interface{}, ch interface{}) *Backend_WatchOrchestrationRuntimeStatus_Call

WatchOrchestrationRuntimeStatus is a helper method to define mock.On call

  • ctx context.Context
  • id api.InstanceID
  • ch chan<- *protos.OrchestrationMetadata

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 *protos.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 

func (_c *Backend_GetOrchestrationMetadata_Call) RunAndReturn(run func(context.Context, api.InstanceID) (*protos.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 *protos.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 

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

type Backend_NextActivityWorkItem_Call 

type Backend_NextActivityWorkItem_Call struct {
	*mock.Call
}

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

func (*Backend_NextActivityWorkItem_Call) Return 

func (_c *Backend_NextActivityWorkItem_Call) Return(_a0 *backend.ActivityWorkItem, _a1 error) *Backend_NextActivityWorkItem_Call

func (*Backend_NextActivityWorkItem_Call) Run 

func (_c *Backend_NextActivityWorkItem_Call) Run(run func(_a0 context.Context)) *Backend_NextActivityWorkItem_Call

func (*Backend_NextActivityWorkItem_Call) RunAndReturn 

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

type Backend_NextOrchestrationWorkItem_Call 

type Backend_NextOrchestrationWorkItem_Call struct {
	*mock.Call
}

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

func (*Backend_NextOrchestrationWorkItem_Call) Return 

func (_c *Backend_NextOrchestrationWorkItem_Call) Return(_a0 *backend.OrchestrationWorkItem, _a1 error) *Backend_NextOrchestrationWorkItem_Call

func (*Backend_NextOrchestrationWorkItem_Call) Run 

func (_c *Backend_NextOrchestrationWorkItem_Call) Run(run func(_a0 context.Context)) *Backend_NextOrchestrationWorkItem_Call

func (*Backend_NextOrchestrationWorkItem_Call) RunAndReturn 

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

type Backend_PurgeOrchestrationState_Call 

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 

func (_c *Backend_PurgeOrchestrationState_Call) Return(_a0 error) *Backend_PurgeOrchestrationState_Call

func (*Backend_PurgeOrchestrationState_Call) Run 

func (_c *Backend_PurgeOrchestrationState_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID)) *Backend_PurgeOrchestrationState_Call

func (*Backend_PurgeOrchestrationState_Call) RunAndReturn 

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

type Backend_RerunWorkflowFromEvent_Call added in v0.7.0 

type Backend_RerunWorkflowFromEvent_Call struct {
	*mock.Call
}

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

func (*Backend_RerunWorkflowFromEvent_Call) Return added in v0.7.0 

func (_c *Backend_RerunWorkflowFromEvent_Call) Return(_a0 api.InstanceID, _a1 error) *Backend_RerunWorkflowFromEvent_Call

func (*Backend_RerunWorkflowFromEvent_Call) Run added in v0.7.0 

func (_c *Backend_RerunWorkflowFromEvent_Call) Run(run func(ctx context.Context, req *protos.RerunWorkflowFromEventRequest)) *Backend_RerunWorkflowFromEvent_Call

func (*Backend_RerunWorkflowFromEvent_Call) RunAndReturn added in v0.7.0 

func (_c *Backend_RerunWorkflowFromEvent_Call) RunAndReturn(run func(context.Context, *protos.RerunWorkflowFromEventRequest) (api.InstanceID, error)) *Backend_RerunWorkflowFromEvent_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 

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 

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

type Backend_WatchOrchestrationRuntimeStatus_Call 

type Backend_WatchOrchestrationRuntimeStatus_Call struct {
	*mock.Call
}

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

func (*Backend_WatchOrchestrationRuntimeStatus_Call) Return 

func (_c *Backend_WatchOrchestrationRuntimeStatus_Call) Return(_a0 error) *Backend_WatchOrchestrationRuntimeStatus_Call

func (*Backend_WatchOrchestrationRuntimeStatus_Call) Run 

func (_c *Backend_WatchOrchestrationRuntimeStatus_Call) Run(run func(ctx context.Context, id api.InstanceID, ch chan<- *protos.OrchestrationMetadata)) *Backend_WatchOrchestrationRuntimeStatus_Call

func (*Backend_WatchOrchestrationRuntimeStatus_Call) RunAndReturn 

func (_c *Backend_WatchOrchestrationRuntimeStatus_Call) RunAndReturn(run func(context.Context, api.InstanceID, chan<- *protos.OrchestrationMetadata) error) *Backend_WatchOrchestrationRuntimeStatus_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

func (*Executor) Shutdown 

func (_m *Executor) Shutdown(ctx context.Context) error

Shutdown provides a mock function with given fields: ctx

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 

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 

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

func (*Executor_Expecter) Shutdown 

func (_e *Executor_Expecter) Shutdown(ctx interface{}) *Executor_Shutdown_Call

Shutdown is a helper method to define mock.On call

  • ctx context.Context

type Executor_Shutdown_Call 

type Executor_Shutdown_Call struct {
	*mock.Call
}

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

func (*Executor_Shutdown_Call) Return 

func (_c *Executor_Shutdown_Call) Return(_a0 error) *Executor_Shutdown_Call

func (*Executor_Shutdown_Call) Run 

func (_c *Executor_Shutdown_Call) Run(run func(ctx context.Context)) *Executor_Shutdown_Call

func (*Executor_Shutdown_Call) RunAndReturn 

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

type TaskWorker 

type TaskWorker[T backend.WorkItem] struct {
	mock.Mock
}

TaskWorker is an autogenerated mock type for the TaskWorker type

func NewTaskWorker 

func NewTaskWorker[T backend.WorkItem](t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskWorker[T]

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[T]) EXPECT 

func (_m *TaskWorker[T]) EXPECT() *TaskWorker_Expecter[T]

func (*TaskWorker[T]) Start 

func (_m *TaskWorker[T]) Start(_a0 context.Context)

Start provides a mock function with given fields: _a0

func (*TaskWorker[T]) StopAndDrain 

func (_m *TaskWorker[T]) StopAndDrain()

StopAndDrain provides a mock function with no fields

type TaskWorker_Expecter 

type TaskWorker_Expecter[T backend.WorkItem] struct {
	// contains filtered or unexported fields
}

func (*TaskWorker_Expecter[T]) Start 

func (_e *TaskWorker_Expecter[T]) Start(_a0 interface{}) *TaskWorker_Start_Call[T]

Start is a helper method to define mock.On call

  • _a0 context.Context

func (*TaskWorker_Expecter[T]) StopAndDrain 

func (_e *TaskWorker_Expecter[T]) StopAndDrain() *TaskWorker_StopAndDrain_Call[T]

StopAndDrain is a helper method to define mock.On call

type TaskWorker_Start_Call 

type TaskWorker_Start_Call[T backend.WorkItem] 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[T]) Return 

func (_c *TaskWorker_Start_Call[T]) Return() *TaskWorker_Start_Call[T]

func (*TaskWorker_Start_Call[T]) Run 

func (_c *TaskWorker_Start_Call[T]) Run(run func(_a0 context.Context)) *TaskWorker_Start_Call[T]

func (*TaskWorker_Start_Call[T]) RunAndReturn 

func (_c *TaskWorker_Start_Call[T]) RunAndReturn(run func(context.Context)) *TaskWorker_Start_Call[T]

type TaskWorker_StopAndDrain_Call 

type TaskWorker_StopAndDrain_Call[T backend.WorkItem] 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[T]) Return 

func (_c *TaskWorker_StopAndDrain_Call[T]) Return() *TaskWorker_StopAndDrain_Call[T]

func (*TaskWorker_StopAndDrain_Call[T]) Run 

func (_c *TaskWorker_StopAndDrain_Call[T]) Run(run func()) *TaskWorker_StopAndDrain_Call[T]

func (*TaskWorker_StopAndDrain_Call[T]) RunAndReturn 

func (_c *TaskWorker_StopAndDrain_Call[T]) RunAndReturn(run func()) *TaskWorker_StopAndDrain_Call[T]

type TestTaskProcessor 

type TestTaskProcessor[T backend.WorkItem] struct {
	// contains filtered or unexported fields
}

TestTaskProcessor implements a dummy task processor useful for testing

func NewTestTaskPocessor 

func NewTestTaskPocessor[T backend.WorkItem](name string) *TestTaskProcessor[T]

func (*TestTaskProcessor[T]) AbandonWorkItem 

func (t *TestTaskProcessor[T]) AbandonWorkItem(ctx context.Context, wi T) error

func (*TestTaskProcessor[T]) AbandonedWorkItems 

func (t *TestTaskProcessor[T]) AbandonedWorkItems() []T

func (*TestTaskProcessor[T]) AddWorkItems 

func (t *TestTaskProcessor[T]) AddWorkItems(wis ...T)

func (*TestTaskProcessor[T]) BlockProcessing 

func (t *TestTaskProcessor[T]) BlockProcessing()

func (*TestTaskProcessor[T]) CompleteWorkItem 

func (t *TestTaskProcessor[T]) CompleteWorkItem(ctx context.Context, wi T) error

func (*TestTaskProcessor[T]) CompletedWorkItems 

func (t *TestTaskProcessor[T]) CompletedWorkItems() []T

func (*TestTaskProcessor[T]) Name 

func (t *TestTaskProcessor[T]) Name() string

func (*TestTaskProcessor[T]) NextWorkItem 

func (t *TestTaskProcessor[T]) NextWorkItem(context.Context) (T, error)

func (*TestTaskProcessor[T]) PendingWorkItems 

func (t *TestTaskProcessor[T]) PendingWorkItems() []T

func (*TestTaskProcessor[T]) ProcessWorkItem 

func (t *TestTaskProcessor[T]) ProcessWorkItem(ctx context.Context, wi T) error

func (*TestTaskProcessor[T]) UnblockProcessing 

func (t *TestTaskProcessor[T]) 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.