mocks

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: May 21, 2026 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) AbandonWorkflowWorkItem added in v0.12.0 

func (_m *Backend) AbandonWorkflowWorkItem(_a0 context.Context, _a1 *backend.WorkflowWorkItem) error

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

func (*Backend) AddNewWorkflowEvent added in v0.12.0 

func (_m *Backend) AddNewWorkflowEvent(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent) error

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

func (*Backend) CancelActivityTask added in v0.8.0 

func (_m *Backend) CancelActivityTask(_a0 context.Context, _a1 api.InstanceID, _a2 int32) error

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

func (*Backend) CancelWorkflowTask added in v0.12.0 

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

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

func (*Backend) CompleteActivityTask added in v0.8.0 

func (_m *Backend) CompleteActivityTask(_a0 context.Context, _a1 *protos.ActivityResponse) error

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

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) CompleteWorkflowTask added in v0.12.0 

func (_m *Backend) CompleteWorkflowTask(_a0 context.Context, _a1 *protos.WorkflowResponse) error

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

func (*Backend) CompleteWorkflowWorkItem added in v0.12.0 

func (_m *Backend) CompleteWorkflowWorkItem(_a0 context.Context, _a1 *backend.WorkflowWorkItem) error

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

func (*Backend) CreateTaskHub 

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

CreateTaskHub provides a mock function with given fields: _a0

func (*Backend) CreateWorkflowInstance added in v0.12.0 

func (_m *Backend) CreateWorkflowInstance(_a0 context.Context, _a1 *protos.HistoryEvent) error

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

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) GetInstanceHistory added in v0.11.0 

func (_m *Backend) GetInstanceHistory(ctx context.Context, req *protos.GetInstanceHistoryRequest) (*protos.GetInstanceHistoryResponse, error)

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

func (*Backend) GetWorkflowMetadata added in v0.12.0 

func (_m *Backend) GetWorkflowMetadata(_a0 context.Context, _a1 api.InstanceID) (*protos.WorkflowMetadata, error)

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

func (*Backend) GetWorkflowRuntimeState added in v0.12.0 

func (_m *Backend) GetWorkflowRuntimeState(_a0 context.Context, _a1 *backend.WorkflowWorkItem) (*protos.WorkflowRuntimeState, error)

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

func (*Backend) ListInstanceIDs added in v0.11.0 

func (_m *Backend) ListInstanceIDs(ctx context.Context, req *protos.ListInstanceIDsRequest) (*protos.ListInstanceIDsResponse, error)

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

func (*Backend) NextActivityWorkItem 

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

NextActivityWorkItem provides a mock function with given fields: _a0

func (*Backend) NextWorkflowWorkItem added in v0.12.0 

func (_m *Backend) NextWorkflowWorkItem(_a0 context.Context) (*backend.WorkflowWorkItem, error)

NextWorkflowWorkItem provides a mock function with given fields: _a0

func (*Backend) PurgeWorkflowState added in v0.12.0 

func (_m *Backend) PurgeWorkflowState(ctx context.Context, id api.InstanceID, router *protos.TaskRouter, force bool) (int, error)

PurgeWorkflowState provides a mock function with given fields: ctx, id, router, force

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) WaitForActivityCompletion added in v0.8.0 

func (_m *Backend) WaitForActivityCompletion(_a0 *protos.ActivityRequest) func(context.Context) (*protos.ActivityResponse, error)

WaitForActivityCompletion provides a mock function with given fields: _a0

func (*Backend) WaitForWorkflowTaskCompletion added in v0.12.0 

func (_m *Backend) WaitForWorkflowTaskCompletion(_a0 *protos.WorkflowRequest) func(context.Context) (*protos.WorkflowResponse, error)

WaitForWorkflowTaskCompletion provides a mock function with given fields: _a0

func (*Backend) WatchWorkflowRuntimeStatus added in v0.12.0 

func (_m *Backend) WatchWorkflowRuntimeStatus(ctx context.Context, id api.InstanceID, condition func(*protos.WorkflowMetadata) bool) error

WatchWorkflowRuntimeStatus provides a mock function with given fields: ctx, id, condition

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_AbandonWorkflowWorkItem_Call added in v0.12.0 

type Backend_AbandonWorkflowWorkItem_Call struct {
	*mock.Call
}

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

func (*Backend_AbandonWorkflowWorkItem_Call) Return added in v0.12.0 

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

func (*Backend_AbandonWorkflowWorkItem_Call) Run added in v0.12.0 

func (_c *Backend_AbandonWorkflowWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.WorkflowWorkItem)) *Backend_AbandonWorkflowWorkItem_Call

func (*Backend_AbandonWorkflowWorkItem_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_AbandonWorkflowWorkItem_Call) RunAndReturn(run func(context.Context, *backend.WorkflowWorkItem) error) *Backend_AbandonWorkflowWorkItem_Call

type Backend_AddNewWorkflowEvent_Call added in v0.12.0 

type Backend_AddNewWorkflowEvent_Call struct {
	*mock.Call
}

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

func (*Backend_AddNewWorkflowEvent_Call) Return added in v0.12.0 

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

func (*Backend_AddNewWorkflowEvent_Call) Run added in v0.12.0 

func (_c *Backend_AddNewWorkflowEvent_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID, _a2 *protos.HistoryEvent)) *Backend_AddNewWorkflowEvent_Call

func (*Backend_AddNewWorkflowEvent_Call) RunAndReturn added in v0.12.0 

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

type Backend_CancelActivityTask_Call added in v0.8.0 

type Backend_CancelActivityTask_Call struct {
	*mock.Call
}

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

func (*Backend_CancelActivityTask_Call) Return added in v0.8.0 

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

func (*Backend_CancelActivityTask_Call) Run added in v0.8.0 

func (_c *Backend_CancelActivityTask_Call) Run(run func(_a0 context.Context, _a1 api.InstanceID, _a2 int32)) *Backend_CancelActivityTask_Call

func (*Backend_CancelActivityTask_Call) RunAndReturn added in v0.8.0 

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

type Backend_CancelWorkflowTask_Call added in v0.12.0 

type Backend_CancelWorkflowTask_Call struct {
	*mock.Call
}

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

func (*Backend_CancelWorkflowTask_Call) Return added in v0.12.0 

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

func (*Backend_CancelWorkflowTask_Call) Run added in v0.12.0 

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

func (*Backend_CancelWorkflowTask_Call) RunAndReturn added in v0.12.0 

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

type Backend_CompleteActivityTask_Call added in v0.8.0 

type Backend_CompleteActivityTask_Call struct {
	*mock.Call
}

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

func (*Backend_CompleteActivityTask_Call) Return added in v0.8.0 

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

func (*Backend_CompleteActivityTask_Call) Run added in v0.8.0 

func (_c *Backend_CompleteActivityTask_Call) Run(run func(_a0 context.Context, _a1 *protos.ActivityResponse)) *Backend_CompleteActivityTask_Call

func (*Backend_CompleteActivityTask_Call) RunAndReturn added in v0.8.0 

func (_c *Backend_CompleteActivityTask_Call) RunAndReturn(run func(context.Context, *protos.ActivityResponse) error) *Backend_CompleteActivityTask_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_CompleteWorkflowTask_Call added in v0.12.0 

type Backend_CompleteWorkflowTask_Call struct {
	*mock.Call
}

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

func (*Backend_CompleteWorkflowTask_Call) Return added in v0.12.0 

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

func (*Backend_CompleteWorkflowTask_Call) Run added in v0.12.0 

func (_c *Backend_CompleteWorkflowTask_Call) Run(run func(_a0 context.Context, _a1 *protos.WorkflowResponse)) *Backend_CompleteWorkflowTask_Call

func (*Backend_CompleteWorkflowTask_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_CompleteWorkflowTask_Call) RunAndReturn(run func(context.Context, *protos.WorkflowResponse) error) *Backend_CompleteWorkflowTask_Call

type Backend_CompleteWorkflowWorkItem_Call added in v0.12.0 

type Backend_CompleteWorkflowWorkItem_Call struct {
	*mock.Call
}

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

func (*Backend_CompleteWorkflowWorkItem_Call) Return added in v0.12.0 

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

func (*Backend_CompleteWorkflowWorkItem_Call) Run added in v0.12.0 

func (_c *Backend_CompleteWorkflowWorkItem_Call) Run(run func(_a0 context.Context, _a1 *backend.WorkflowWorkItem)) *Backend_CompleteWorkflowWorkItem_Call

func (*Backend_CompleteWorkflowWorkItem_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_CompleteWorkflowWorkItem_Call) RunAndReturn(run func(context.Context, *backend.WorkflowWorkItem) error) *Backend_CompleteWorkflowWorkItem_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_CreateWorkflowInstance_Call added in v0.12.0 

type Backend_CreateWorkflowInstance_Call struct {
	*mock.Call
}

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

func (*Backend_CreateWorkflowInstance_Call) Return added in v0.12.0 

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

func (*Backend_CreateWorkflowInstance_Call) Run added in v0.12.0 

func (_c *Backend_CreateWorkflowInstance_Call) Run(run func(_a0 context.Context, _a1 *protos.HistoryEvent)) *Backend_CreateWorkflowInstance_Call

func (*Backend_CreateWorkflowInstance_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_CreateWorkflowInstance_Call) RunAndReturn(run func(context.Context, *protos.HistoryEvent) error) *Backend_CreateWorkflowInstance_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) AbandonWorkflowWorkItem added in v0.12.0 

func (_e *Backend_Expecter) AbandonWorkflowWorkItem(_a0 interface{}, _a1 interface{}) *Backend_AbandonWorkflowWorkItem_Call

AbandonWorkflowWorkItem is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *backend.WorkflowWorkItem

func (*Backend_Expecter) AddNewWorkflowEvent added in v0.12.0 

func (_e *Backend_Expecter) AddNewWorkflowEvent(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Backend_AddNewWorkflowEvent_Call

AddNewWorkflowEvent is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 api.InstanceID
  • _a2 *protos.HistoryEvent

func (*Backend_Expecter) CancelActivityTask added in v0.8.0 

func (_e *Backend_Expecter) CancelActivityTask(_a0 interface{}, _a1 interface{}, _a2 interface{}) *Backend_CancelActivityTask_Call

CancelActivityTask is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 api.InstanceID
  • _a2 int32

func (*Backend_Expecter) CancelWorkflowTask added in v0.12.0 

func (_e *Backend_Expecter) CancelWorkflowTask(_a0 interface{}, _a1 interface{}) *Backend_CancelWorkflowTask_Call

CancelWorkflowTask is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 api.InstanceID

func (*Backend_Expecter) CompleteActivityTask added in v0.8.0 

func (_e *Backend_Expecter) CompleteActivityTask(_a0 interface{}, _a1 interface{}) *Backend_CompleteActivityTask_Call

CompleteActivityTask is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *protos.ActivityResponse

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) CompleteWorkflowTask added in v0.12.0 

func (_e *Backend_Expecter) CompleteWorkflowTask(_a0 interface{}, _a1 interface{}) *Backend_CompleteWorkflowTask_Call

CompleteWorkflowTask is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *protos.WorkflowResponse

func (*Backend_Expecter) CompleteWorkflowWorkItem added in v0.12.0 

func (_e *Backend_Expecter) CompleteWorkflowWorkItem(_a0 interface{}, _a1 interface{}) *Backend_CompleteWorkflowWorkItem_Call

CompleteWorkflowWorkItem is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *backend.WorkflowWorkItem

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) CreateWorkflowInstance added in v0.12.0 

func (_e *Backend_Expecter) CreateWorkflowInstance(_a0 interface{}, _a1 interface{}) *Backend_CreateWorkflowInstance_Call

CreateWorkflowInstance is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *protos.HistoryEvent

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) GetInstanceHistory added in v0.11.0 

func (_e *Backend_Expecter) GetInstanceHistory(ctx interface{}, req interface{}) *Backend_GetInstanceHistory_Call

GetInstanceHistory is a helper method to define mock.On call

  • ctx context.Context
  • req *protos.GetInstanceHistoryRequest

func (*Backend_Expecter) GetWorkflowMetadata added in v0.12.0 

func (_e *Backend_Expecter) GetWorkflowMetadata(_a0 interface{}, _a1 interface{}) *Backend_GetWorkflowMetadata_Call

GetWorkflowMetadata is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 api.InstanceID

func (*Backend_Expecter) GetWorkflowRuntimeState added in v0.12.0 

func (_e *Backend_Expecter) GetWorkflowRuntimeState(_a0 interface{}, _a1 interface{}) *Backend_GetWorkflowRuntimeState_Call

GetWorkflowRuntimeState is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *backend.WorkflowWorkItem

func (*Backend_Expecter) ListInstanceIDs added in v0.11.0 

func (_e *Backend_Expecter) ListInstanceIDs(ctx interface{}, req interface{}) *Backend_ListInstanceIDs_Call

ListInstanceIDs is a helper method to define mock.On call

  • ctx context.Context
  • req *protos.ListInstanceIDsRequest

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) NextWorkflowWorkItem added in v0.12.0 

func (_e *Backend_Expecter) NextWorkflowWorkItem(_a0 interface{}) *Backend_NextWorkflowWorkItem_Call

NextWorkflowWorkItem is a helper method to define mock.On call

  • _a0 context.Context

func (*Backend_Expecter) PurgeWorkflowState added in v0.12.0 

func (_e *Backend_Expecter) PurgeWorkflowState(ctx interface{}, id interface{}, router interface{}, force interface{}) *Backend_PurgeWorkflowState_Call

PurgeWorkflowState is a helper method to define mock.On call

  • ctx context.Context
  • id api.InstanceID
  • router *protos.TaskRouter
  • force bool

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) WaitForActivityCompletion added in v0.8.0 

func (_e *Backend_Expecter) WaitForActivityCompletion(_a0 interface{}) *Backend_WaitForActivityCompletion_Call

WaitForActivityCompletion is a helper method to define mock.On call

  • _a0 *protos.ActivityRequest

func (*Backend_Expecter) WaitForWorkflowTaskCompletion added in v0.12.0 

func (_e *Backend_Expecter) WaitForWorkflowTaskCompletion(_a0 interface{}) *Backend_WaitForWorkflowTaskCompletion_Call

WaitForWorkflowTaskCompletion is a helper method to define mock.On call

  • _a0 *protos.WorkflowRequest

func (*Backend_Expecter) WatchWorkflowRuntimeStatus added in v0.12.0 

func (_e *Backend_Expecter) WatchWorkflowRuntimeStatus(ctx interface{}, id interface{}, condition interface{}) *Backend_WatchWorkflowRuntimeStatus_Call

WatchWorkflowRuntimeStatus is a helper method to define mock.On call

  • ctx context.Context
  • id api.InstanceID
  • condition func(*protos.WorkflowMetadata) bool

type Backend_GetInstanceHistory_Call added in v0.11.0 

type Backend_GetInstanceHistory_Call struct {
	*mock.Call
}

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

func (*Backend_GetInstanceHistory_Call) Return added in v0.11.0 

func (_c *Backend_GetInstanceHistory_Call) Return(_a0 *protos.GetInstanceHistoryResponse, _a1 error) *Backend_GetInstanceHistory_Call

func (*Backend_GetInstanceHistory_Call) Run added in v0.11.0 

func (_c *Backend_GetInstanceHistory_Call) Run(run func(ctx context.Context, req *protos.GetInstanceHistoryRequest)) *Backend_GetInstanceHistory_Call

func (*Backend_GetInstanceHistory_Call) RunAndReturn added in v0.11.0 

func (_c *Backend_GetInstanceHistory_Call) RunAndReturn(run func(context.Context, *protos.GetInstanceHistoryRequest) (*protos.GetInstanceHistoryResponse, error)) *Backend_GetInstanceHistory_Call

type Backend_GetWorkflowMetadata_Call added in v0.12.0 

type Backend_GetWorkflowMetadata_Call struct {
	*mock.Call
}

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

func (*Backend_GetWorkflowMetadata_Call) Return added in v0.12.0 

func (_c *Backend_GetWorkflowMetadata_Call) Return(_a0 *protos.WorkflowMetadata, _a1 error) *Backend_GetWorkflowMetadata_Call

func (*Backend_GetWorkflowMetadata_Call) Run added in v0.12.0 

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

func (*Backend_GetWorkflowMetadata_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_GetWorkflowMetadata_Call) RunAndReturn(run func(context.Context, api.InstanceID) (*protos.WorkflowMetadata, error)) *Backend_GetWorkflowMetadata_Call

type Backend_GetWorkflowRuntimeState_Call added in v0.12.0 

type Backend_GetWorkflowRuntimeState_Call struct {
	*mock.Call
}

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

func (*Backend_GetWorkflowRuntimeState_Call) Return added in v0.12.0 

func (_c *Backend_GetWorkflowRuntimeState_Call) Return(_a0 *protos.WorkflowRuntimeState, _a1 error) *Backend_GetWorkflowRuntimeState_Call

func (*Backend_GetWorkflowRuntimeState_Call) Run added in v0.12.0 

func (_c *Backend_GetWorkflowRuntimeState_Call) Run(run func(_a0 context.Context, _a1 *backend.WorkflowWorkItem)) *Backend_GetWorkflowRuntimeState_Call

func (*Backend_GetWorkflowRuntimeState_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_GetWorkflowRuntimeState_Call) RunAndReturn(run func(context.Context, *backend.WorkflowWorkItem) (*protos.WorkflowRuntimeState, error)) *Backend_GetWorkflowRuntimeState_Call

type Backend_ListInstanceIDs_Call added in v0.11.0 

type Backend_ListInstanceIDs_Call struct {
	*mock.Call
}

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

func (*Backend_ListInstanceIDs_Call) Return added in v0.11.0 

func (_c *Backend_ListInstanceIDs_Call) Return(_a0 *protos.ListInstanceIDsResponse, _a1 error) *Backend_ListInstanceIDs_Call

func (*Backend_ListInstanceIDs_Call) Run added in v0.11.0 

func (_c *Backend_ListInstanceIDs_Call) Run(run func(ctx context.Context, req *protos.ListInstanceIDsRequest)) *Backend_ListInstanceIDs_Call

func (*Backend_ListInstanceIDs_Call) RunAndReturn added in v0.11.0 

func (_c *Backend_ListInstanceIDs_Call) RunAndReturn(run func(context.Context, *protos.ListInstanceIDsRequest) (*protos.ListInstanceIDsResponse, error)) *Backend_ListInstanceIDs_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_NextWorkflowWorkItem_Call added in v0.12.0 

type Backend_NextWorkflowWorkItem_Call struct {
	*mock.Call
}

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

func (*Backend_NextWorkflowWorkItem_Call) Return added in v0.12.0 

func (_c *Backend_NextWorkflowWorkItem_Call) Return(_a0 *backend.WorkflowWorkItem, _a1 error) *Backend_NextWorkflowWorkItem_Call

func (*Backend_NextWorkflowWorkItem_Call) Run added in v0.12.0 

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

func (*Backend_NextWorkflowWorkItem_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_NextWorkflowWorkItem_Call) RunAndReturn(run func(context.Context) (*backend.WorkflowWorkItem, error)) *Backend_NextWorkflowWorkItem_Call

type Backend_PurgeWorkflowState_Call added in v0.12.0 

type Backend_PurgeWorkflowState_Call struct {
	*mock.Call
}

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

func (*Backend_PurgeWorkflowState_Call) Return added in v0.12.0 

func (_c *Backend_PurgeWorkflowState_Call) Return(_a0 int, _a1 error) *Backend_PurgeWorkflowState_Call

func (*Backend_PurgeWorkflowState_Call) Run added in v0.12.0 

func (_c *Backend_PurgeWorkflowState_Call) Run(run func(ctx context.Context, id api.InstanceID, router *protos.TaskRouter, force bool)) *Backend_PurgeWorkflowState_Call

func (*Backend_PurgeWorkflowState_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_PurgeWorkflowState_Call) RunAndReturn(run func(context.Context, api.InstanceID, *protos.TaskRouter, bool) (int, error)) *Backend_PurgeWorkflowState_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_WaitForActivityCompletion_Call added in v0.8.0 

type Backend_WaitForActivityCompletion_Call struct {
	*mock.Call
}

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

func (*Backend_WaitForActivityCompletion_Call) Return added in v0.8.0 

func (_c *Backend_WaitForActivityCompletion_Call) Return(_a0 func(context.Context) (*protos.ActivityResponse, error)) *Backend_WaitForActivityCompletion_Call

func (*Backend_WaitForActivityCompletion_Call) Run added in v0.8.0 

func (_c *Backend_WaitForActivityCompletion_Call) Run(run func(_a0 *protos.ActivityRequest)) *Backend_WaitForActivityCompletion_Call

func (*Backend_WaitForActivityCompletion_Call) RunAndReturn added in v0.8.0 

func (_c *Backend_WaitForActivityCompletion_Call) RunAndReturn(run func(*protos.ActivityRequest) func(context.Context) (*protos.ActivityResponse, error)) *Backend_WaitForActivityCompletion_Call

type Backend_WaitForWorkflowTaskCompletion_Call added in v0.12.0 

type Backend_WaitForWorkflowTaskCompletion_Call struct {
	*mock.Call
}

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

func (*Backend_WaitForWorkflowTaskCompletion_Call) Return added in v0.12.0 

func (_c *Backend_WaitForWorkflowTaskCompletion_Call) Return(_a0 func(context.Context) (*protos.WorkflowResponse, error)) *Backend_WaitForWorkflowTaskCompletion_Call

func (*Backend_WaitForWorkflowTaskCompletion_Call) Run added in v0.12.0 

func (_c *Backend_WaitForWorkflowTaskCompletion_Call) Run(run func(_a0 *protos.WorkflowRequest)) *Backend_WaitForWorkflowTaskCompletion_Call

func (*Backend_WaitForWorkflowTaskCompletion_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_WaitForWorkflowTaskCompletion_Call) RunAndReturn(run func(*protos.WorkflowRequest) func(context.Context) (*protos.WorkflowResponse, error)) *Backend_WaitForWorkflowTaskCompletion_Call

type Backend_WatchWorkflowRuntimeStatus_Call added in v0.12.0 

type Backend_WatchWorkflowRuntimeStatus_Call struct {
	*mock.Call
}

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

func (*Backend_WatchWorkflowRuntimeStatus_Call) Return added in v0.12.0 

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

func (*Backend_WatchWorkflowRuntimeStatus_Call) Run added in v0.12.0 

func (_c *Backend_WatchWorkflowRuntimeStatus_Call) Run(run func(ctx context.Context, id api.InstanceID, condition func(*protos.WorkflowMetadata) bool)) *Backend_WatchWorkflowRuntimeStatus_Call

func (*Backend_WatchWorkflowRuntimeStatus_Call) RunAndReturn added in v0.12.0 

func (_c *Backend_WatchWorkflowRuntimeStatus_Call) RunAndReturn(run func(context.Context, api.InstanceID, func(*protos.WorkflowMetadata) bool) error) *Backend_WatchWorkflowRuntimeStatus_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) ExecuteWorkflow added in v0.12.0 

func (_m *Executor) ExecuteWorkflow(ctx context.Context, iid api.InstanceID, oldEvents []*protos.HistoryEvent, newEvents []*protos.HistoryEvent, opts backend.ExecuteOptions) (*protos.WorkflowResponse, error)

ExecuteWorkflow provides a mock function with given fields: ctx, iid, oldEvents, newEvents, opts

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_ExecuteWorkflow_Call added in v0.12.0 

type Executor_ExecuteWorkflow_Call struct {
	*mock.Call
}

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

func (*Executor_ExecuteWorkflow_Call) Return added in v0.12.0 

func (_c *Executor_ExecuteWorkflow_Call) Return(_a0 *protos.WorkflowResponse, _a1 error) *Executor_ExecuteWorkflow_Call

func (*Executor_ExecuteWorkflow_Call) Run added in v0.12.0 

func (_c *Executor_ExecuteWorkflow_Call) Run(run func(ctx context.Context, iid api.InstanceID, oldEvents []*protos.HistoryEvent, newEvents []*protos.HistoryEvent, opts backend.ExecuteOptions)) *Executor_ExecuteWorkflow_Call

func (*Executor_ExecuteWorkflow_Call) RunAndReturn added in v0.12.0 

func (_c *Executor_ExecuteWorkflow_Call) RunAndReturn(run func(context.Context, api.InstanceID, []*protos.HistoryEvent, []*protos.HistoryEvent, backend.ExecuteOptions) (*protos.WorkflowResponse, error)) *Executor_ExecuteWorkflow_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) ExecuteWorkflow added in v0.12.0 

func (_e *Executor_Expecter) ExecuteWorkflow(ctx interface{}, iid interface{}, oldEvents interface{}, newEvents interface{}, opts interface{}) *Executor_ExecuteWorkflow_Call

ExecuteWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • iid api.InstanceID
  • oldEvents []*protos.HistoryEvent
  • newEvents []*protos.HistoryEvent
  • opts backend.ExecuteOptions

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.