mocks

package
v1.4.1-prerelease25 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2026 License: Apache-2.0 Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockMessagingClient added in v0.3.11 

func NewMockMessagingClient(publisher messaging.Producer, consumer messaging.Consumer) messaging.Client

NewMockMessagingClient generate a dummy implementation of messaging client

Types

type ExecutionManager 

type ExecutionManager struct {
	mock.Mock
}

ExecutionManager is an autogenerated mock type for the ExecutionManager type

func NewExecutionManager added in v1.2.18 

func NewExecutionManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ExecutionManager

NewExecutionManager creates a new instance of ExecutionManager. 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 (*ExecutionManager) Close 

func (_mock *ExecutionManager) Close()

Close provides a mock function for the type ExecutionManager

func (*ExecutionManager) CompleteHistoryTask added in v1.3.0 

func (_mock *ExecutionManager) CompleteHistoryTask(ctx context.Context, request *persistence.CompleteHistoryTaskRequest) error

CompleteHistoryTask provides a mock function for the type ExecutionManager

func (*ExecutionManager) ConflictResolveWorkflowExecution added in v0.7.0 

func (_mock *ExecutionManager) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error)

ConflictResolveWorkflowExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) CreateFailoverMarkerTasks added in v0.14.0 

func (_mock *ExecutionManager) CreateFailoverMarkerTasks(ctx context.Context, request *persistence.CreateFailoverMarkersRequest) error

CreateFailoverMarkerTasks provides a mock function for the type ExecutionManager

func (*ExecutionManager) CreateWorkflowExecution 

func (_mock *ExecutionManager) CreateWorkflowExecution(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) DeleteActiveClusterSelectionPolicy added in v1.3.3 

func (_mock *ExecutionManager) DeleteActiveClusterSelectionPolicy(ctx context.Context, request *persistence.DeleteActiveClusterSelectionPolicyRequest) error

DeleteActiveClusterSelectionPolicy provides a mock function for the type ExecutionManager

func (*ExecutionManager) DeleteCurrentWorkflowExecution added in v0.5.8 

func (_mock *ExecutionManager) DeleteCurrentWorkflowExecution(ctx context.Context, request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) DeleteReplicationTaskFromDLQ added in v0.12.0 

func (_mock *ExecutionManager) DeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest) error

DeleteReplicationTaskFromDLQ provides a mock function for the type ExecutionManager

func (*ExecutionManager) DeleteWorkflowExecution 

func (_mock *ExecutionManager) DeleteWorkflowExecution(ctx context.Context, request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) EXPECT 

func (_m *ExecutionManager) EXPECT() *ExecutionManager_Expecter

func (*ExecutionManager) FetchWorkflowTimerTasksForCleanup 

func (_mock *ExecutionManager) FetchWorkflowTimerTasksForCleanup(ctx context.Context, request *persistence.FetchWorkflowTimerTasksForCleanupRequest) ([]persistence.HistoryTaskKey, error)

FetchWorkflowTimerTasksForCleanup provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetActiveClusterSelectionPolicy added in v1.3.2 

func (_mock *ExecutionManager) GetActiveClusterSelectionPolicy(ctx context.Context, request *persistence.GetActiveClusterSelectionPolicyRequest) (*types.ActiveClusterSelectionPolicy, error)

GetActiveClusterSelectionPolicy provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetCurrentExecution 

func (_mock *ExecutionManager) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

GetCurrentExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetHistoryTasks added in v1.2.18 

func (_mock *ExecutionManager) GetHistoryTasks(ctx context.Context, request *persistence.GetHistoryTasksRequest) (*persistence.GetHistoryTasksResponse, error)

GetHistoryTasks provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetName added in v0.4.0 

func (_mock *ExecutionManager) GetName() string

GetName provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetReplicationDLQSize added in v0.14.0 

func (_mock *ExecutionManager) GetReplicationDLQSize(ctx context.Context, request *persistence.GetReplicationDLQSizeRequest) (*persistence.GetReplicationDLQSizeResponse, error)

GetReplicationDLQSize provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetReplicationTasksFromDLQ added in v0.11.0 

func (_mock *ExecutionManager) GetReplicationTasksFromDLQ(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationDLQTasksResponse, error)

GetReplicationTasksFromDLQ provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetShardID added in v0.5.0 

func (_mock *ExecutionManager) GetShardID() int

GetShardID provides a mock function for the type ExecutionManager

func (*ExecutionManager) GetWorkflowExecution 

func (_mock *ExecutionManager) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

GetWorkflowExecution provides a mock function for the type ExecutionManager

func (*ExecutionManager) IsWorkflowExecutionExists added in v0.14.0 

func (_mock *ExecutionManager) IsWorkflowExecutionExists(ctx context.Context, request *persistence.IsWorkflowExecutionExistsRequest) (*persistence.IsWorkflowExecutionExistsResponse, error)

IsWorkflowExecutionExists provides a mock function for the type ExecutionManager

func (*ExecutionManager) ListConcreteExecutions added in v0.13.0 

func (_mock *ExecutionManager) ListConcreteExecutions(ctx context.Context, request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

ListConcreteExecutions provides a mock function for the type ExecutionManager

func (*ExecutionManager) ListCurrentExecutions added in v0.14.0 

func (_mock *ExecutionManager) ListCurrentExecutions(ctx context.Context, request *persistence.ListCurrentExecutionsRequest) (*persistence.ListCurrentExecutionsResponse, error)

ListCurrentExecutions provides a mock function for the type ExecutionManager

func (*ExecutionManager) PutReplicationTaskToDLQ added in v0.11.0 

func (_mock *ExecutionManager) PutReplicationTaskToDLQ(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ provides a mock function for the type ExecutionManager

func (*ExecutionManager) RangeCompleteHistoryTask added in v1.2.18 

func (_mock *ExecutionManager) RangeCompleteHistoryTask(ctx context.Context, request *persistence.RangeCompleteHistoryTaskRequest) (*persistence.RangeCompleteHistoryTaskResponse, error)

RangeCompleteHistoryTask provides a mock function for the type ExecutionManager

func (*ExecutionManager) RangeDeleteReplicationTaskFromDLQ added in v0.12.0 

func (_mock *ExecutionManager) RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.RangeDeleteReplicationTaskFromDLQRequest) (*persistence.RangeDeleteReplicationTaskFromDLQResponse, error)

RangeDeleteReplicationTaskFromDLQ provides a mock function for the type ExecutionManager

func (*ExecutionManager) UpdateWorkflowExecution 

func (_mock *ExecutionManager) UpdateWorkflowExecution(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)

UpdateWorkflowExecution provides a mock function for the type ExecutionManager

type ExecutionManagerFactory 

type ExecutionManagerFactory struct {
	mock.Mock
}

ExecutionManagerFactory is an autogenerated mock type for the ExecutionManagerFactory type

func (*ExecutionManagerFactory) Close added in v0.3.2 

func (_m *ExecutionManagerFactory) Close()

Close is mock implementation for Close of ExecutionManagerFactory

func (*ExecutionManagerFactory) NewExecutionManager added in v0.4.0 

func (_m *ExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

NewExecutionManager provides a mock function with given fields: shardID

type ExecutionManager_Close_Call 

type ExecutionManager_Close_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_Close_Call) Return 

func (_c *ExecutionManager_Close_Call) Return() *ExecutionManager_Close_Call

func (*ExecutionManager_Close_Call) Run 

func (_c *ExecutionManager_Close_Call) Run(run func()) *ExecutionManager_Close_Call

func (*ExecutionManager_Close_Call) RunAndReturn 

func (_c *ExecutionManager_Close_Call) RunAndReturn(run func()) *ExecutionManager_Close_Call

type ExecutionManager_CompleteHistoryTask_Call 

type ExecutionManager_CompleteHistoryTask_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_CompleteHistoryTask_Call) Return 

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

func (*ExecutionManager_CompleteHistoryTask_Call) Run 

func (_c *ExecutionManager_CompleteHistoryTask_Call) Run(run func(ctx context.Context, request *persistence.CompleteHistoryTaskRequest)) *ExecutionManager_CompleteHistoryTask_Call

func (*ExecutionManager_CompleteHistoryTask_Call) RunAndReturn 

func (_c *ExecutionManager_CompleteHistoryTask_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CompleteHistoryTaskRequest) error) *ExecutionManager_CompleteHistoryTask_Call

type ExecutionManager_ConflictResolveWorkflowExecution_Call 

type ExecutionManager_ConflictResolveWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_ConflictResolveWorkflowExecution_Call) Return 

func (_c *ExecutionManager_ConflictResolveWorkflowExecution_Call) Return(conflictResolveWorkflowExecutionResponse *persistence.ConflictResolveWorkflowExecutionResponse, err error) *ExecutionManager_ConflictResolveWorkflowExecution_Call

func (*ExecutionManager_ConflictResolveWorkflowExecution_Call) Run 

func (_c *ExecutionManager_ConflictResolveWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest)) *ExecutionManager_ConflictResolveWorkflowExecution_Call

func (*ExecutionManager_ConflictResolveWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_ConflictResolveWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ConflictResolveWorkflowExecutionRequest) (*persistence.ConflictResolveWorkflowExecutionResponse, error)) *ExecutionManager_ConflictResolveWorkflowExecution_Call

type ExecutionManager_CreateFailoverMarkerTasks_Call 

type ExecutionManager_CreateFailoverMarkerTasks_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_CreateFailoverMarkerTasks_Call) Return 

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

func (*ExecutionManager_CreateFailoverMarkerTasks_Call) Run 

func (_c *ExecutionManager_CreateFailoverMarkerTasks_Call) Run(run func(ctx context.Context, request *persistence.CreateFailoverMarkersRequest)) *ExecutionManager_CreateFailoverMarkerTasks_Call

func (*ExecutionManager_CreateFailoverMarkerTasks_Call) RunAndReturn 

func (_c *ExecutionManager_CreateFailoverMarkerTasks_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CreateFailoverMarkersRequest) error) *ExecutionManager_CreateFailoverMarkerTasks_Call

type ExecutionManager_CreateWorkflowExecution_Call 

type ExecutionManager_CreateWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_CreateWorkflowExecution_Call) Return 

func (_c *ExecutionManager_CreateWorkflowExecution_Call) Return(createWorkflowExecutionResponse *persistence.CreateWorkflowExecutionResponse, err error) *ExecutionManager_CreateWorkflowExecution_Call

func (*ExecutionManager_CreateWorkflowExecution_Call) Run 

func (_c *ExecutionManager_CreateWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest)) *ExecutionManager_CreateWorkflowExecution_Call

func (*ExecutionManager_CreateWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_CreateWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)) *ExecutionManager_CreateWorkflowExecution_Call

type ExecutionManager_DeleteActiveClusterSelectionPolicy_Call 

type ExecutionManager_DeleteActiveClusterSelectionPolicy_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_DeleteActiveClusterSelectionPolicy_Call) Return 

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

func (*ExecutionManager_DeleteActiveClusterSelectionPolicy_Call) Run 

func (_c *ExecutionManager_DeleteActiveClusterSelectionPolicy_Call) Run(run func(ctx context.Context, request *persistence.DeleteActiveClusterSelectionPolicyRequest)) *ExecutionManager_DeleteActiveClusterSelectionPolicy_Call

func (*ExecutionManager_DeleteActiveClusterSelectionPolicy_Call) RunAndReturn 

func (_c *ExecutionManager_DeleteActiveClusterSelectionPolicy_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteActiveClusterSelectionPolicyRequest) error) *ExecutionManager_DeleteActiveClusterSelectionPolicy_Call

type ExecutionManager_DeleteCurrentWorkflowExecution_Call 

type ExecutionManager_DeleteCurrentWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_DeleteCurrentWorkflowExecution_Call) Return 

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

func (*ExecutionManager_DeleteCurrentWorkflowExecution_Call) Run 

func (_c *ExecutionManager_DeleteCurrentWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.DeleteCurrentWorkflowExecutionRequest)) *ExecutionManager_DeleteCurrentWorkflowExecution_Call

func (*ExecutionManager_DeleteCurrentWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_DeleteCurrentWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteCurrentWorkflowExecutionRequest) error) *ExecutionManager_DeleteCurrentWorkflowExecution_Call

type ExecutionManager_DeleteReplicationTaskFromDLQ_Call 

type ExecutionManager_DeleteReplicationTaskFromDLQ_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_DeleteReplicationTaskFromDLQ_Call) Return 

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

func (*ExecutionManager_DeleteReplicationTaskFromDLQ_Call) Run 

func (_c *ExecutionManager_DeleteReplicationTaskFromDLQ_Call) Run(run func(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest)) *ExecutionManager_DeleteReplicationTaskFromDLQ_Call

func (*ExecutionManager_DeleteReplicationTaskFromDLQ_Call) RunAndReturn 

func (_c *ExecutionManager_DeleteReplicationTaskFromDLQ_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest) error) *ExecutionManager_DeleteReplicationTaskFromDLQ_Call

type ExecutionManager_DeleteWorkflowExecution_Call 

type ExecutionManager_DeleteWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_DeleteWorkflowExecution_Call) Return 

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

func (*ExecutionManager_DeleteWorkflowExecution_Call) Run 

func (_c *ExecutionManager_DeleteWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.DeleteWorkflowExecutionRequest)) *ExecutionManager_DeleteWorkflowExecution_Call

func (*ExecutionManager_DeleteWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_DeleteWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteWorkflowExecutionRequest) error) *ExecutionManager_DeleteWorkflowExecution_Call

type ExecutionManager_Expecter 

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

func (*ExecutionManager_Expecter) Close 

func (_e *ExecutionManager_Expecter) Close() *ExecutionManager_Close_Call

Close is a helper method to define mock.On call

func (*ExecutionManager_Expecter) CompleteHistoryTask 

func (_e *ExecutionManager_Expecter) CompleteHistoryTask(ctx interface{}, request interface{}) *ExecutionManager_CompleteHistoryTask_Call

CompleteHistoryTask is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CompleteHistoryTaskRequest

func (*ExecutionManager_Expecter) ConflictResolveWorkflowExecution 

func (_e *ExecutionManager_Expecter) ConflictResolveWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_ConflictResolveWorkflowExecution_Call

ConflictResolveWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ConflictResolveWorkflowExecutionRequest

func (*ExecutionManager_Expecter) CreateFailoverMarkerTasks 

func (_e *ExecutionManager_Expecter) CreateFailoverMarkerTasks(ctx interface{}, request interface{}) *ExecutionManager_CreateFailoverMarkerTasks_Call

CreateFailoverMarkerTasks is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CreateFailoverMarkersRequest

func (*ExecutionManager_Expecter) CreateWorkflowExecution 

func (_e *ExecutionManager_Expecter) CreateWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_CreateWorkflowExecution_Call

CreateWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CreateWorkflowExecutionRequest

func (*ExecutionManager_Expecter) DeleteActiveClusterSelectionPolicy 

func (_e *ExecutionManager_Expecter) DeleteActiveClusterSelectionPolicy(ctx interface{}, request interface{}) *ExecutionManager_DeleteActiveClusterSelectionPolicy_Call

DeleteActiveClusterSelectionPolicy is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteActiveClusterSelectionPolicyRequest

func (*ExecutionManager_Expecter) DeleteCurrentWorkflowExecution 

func (_e *ExecutionManager_Expecter) DeleteCurrentWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_DeleteCurrentWorkflowExecution_Call

DeleteCurrentWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteCurrentWorkflowExecutionRequest

func (*ExecutionManager_Expecter) DeleteReplicationTaskFromDLQ 

func (_e *ExecutionManager_Expecter) DeleteReplicationTaskFromDLQ(ctx interface{}, request interface{}) *ExecutionManager_DeleteReplicationTaskFromDLQ_Call

DeleteReplicationTaskFromDLQ is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteReplicationTaskFromDLQRequest

func (*ExecutionManager_Expecter) DeleteWorkflowExecution 

func (_e *ExecutionManager_Expecter) DeleteWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_DeleteWorkflowExecution_Call

DeleteWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteWorkflowExecutionRequest

func (*ExecutionManager_Expecter) FetchWorkflowTimerTasksForCleanup 

func (_e *ExecutionManager_Expecter) FetchWorkflowTimerTasksForCleanup(ctx interface{}, request interface{}) *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call

FetchWorkflowTimerTasksForCleanup is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.FetchWorkflowTimerTasksForCleanupRequest

func (*ExecutionManager_Expecter) GetActiveClusterSelectionPolicy 

func (_e *ExecutionManager_Expecter) GetActiveClusterSelectionPolicy(ctx interface{}, request interface{}) *ExecutionManager_GetActiveClusterSelectionPolicy_Call

GetActiveClusterSelectionPolicy is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetActiveClusterSelectionPolicyRequest

func (*ExecutionManager_Expecter) GetCurrentExecution 

func (_e *ExecutionManager_Expecter) GetCurrentExecution(ctx interface{}, request interface{}) *ExecutionManager_GetCurrentExecution_Call

GetCurrentExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetCurrentExecutionRequest

func (*ExecutionManager_Expecter) GetHistoryTasks 

func (_e *ExecutionManager_Expecter) GetHistoryTasks(ctx interface{}, request interface{}) *ExecutionManager_GetHistoryTasks_Call

GetHistoryTasks is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetHistoryTasksRequest

func (*ExecutionManager_Expecter) GetName 

func (_e *ExecutionManager_Expecter) GetName() *ExecutionManager_GetName_Call

GetName is a helper method to define mock.On call

func (*ExecutionManager_Expecter) GetReplicationDLQSize 

func (_e *ExecutionManager_Expecter) GetReplicationDLQSize(ctx interface{}, request interface{}) *ExecutionManager_GetReplicationDLQSize_Call

GetReplicationDLQSize is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetReplicationDLQSizeRequest

func (*ExecutionManager_Expecter) GetReplicationTasksFromDLQ 

func (_e *ExecutionManager_Expecter) GetReplicationTasksFromDLQ(ctx interface{}, request interface{}) *ExecutionManager_GetReplicationTasksFromDLQ_Call

GetReplicationTasksFromDLQ is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetReplicationTasksFromDLQRequest

func (*ExecutionManager_Expecter) GetShardID 

func (_e *ExecutionManager_Expecter) GetShardID() *ExecutionManager_GetShardID_Call

GetShardID is a helper method to define mock.On call

func (*ExecutionManager_Expecter) GetWorkflowExecution 

func (_e *ExecutionManager_Expecter) GetWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_GetWorkflowExecution_Call

GetWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetWorkflowExecutionRequest

func (*ExecutionManager_Expecter) IsWorkflowExecutionExists 

func (_e *ExecutionManager_Expecter) IsWorkflowExecutionExists(ctx interface{}, request interface{}) *ExecutionManager_IsWorkflowExecutionExists_Call

IsWorkflowExecutionExists is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.IsWorkflowExecutionExistsRequest

func (*ExecutionManager_Expecter) ListConcreteExecutions 

func (_e *ExecutionManager_Expecter) ListConcreteExecutions(ctx interface{}, request interface{}) *ExecutionManager_ListConcreteExecutions_Call

ListConcreteExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListConcreteExecutionsRequest

func (*ExecutionManager_Expecter) ListCurrentExecutions 

func (_e *ExecutionManager_Expecter) ListCurrentExecutions(ctx interface{}, request interface{}) *ExecutionManager_ListCurrentExecutions_Call

ListCurrentExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListCurrentExecutionsRequest

func (*ExecutionManager_Expecter) PutReplicationTaskToDLQ 

func (_e *ExecutionManager_Expecter) PutReplicationTaskToDLQ(ctx interface{}, request interface{}) *ExecutionManager_PutReplicationTaskToDLQ_Call

PutReplicationTaskToDLQ is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.PutReplicationTaskToDLQRequest

func (*ExecutionManager_Expecter) RangeCompleteHistoryTask 

func (_e *ExecutionManager_Expecter) RangeCompleteHistoryTask(ctx interface{}, request interface{}) *ExecutionManager_RangeCompleteHistoryTask_Call

RangeCompleteHistoryTask is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.RangeCompleteHistoryTaskRequest

func (*ExecutionManager_Expecter) RangeDeleteReplicationTaskFromDLQ 

func (_e *ExecutionManager_Expecter) RangeDeleteReplicationTaskFromDLQ(ctx interface{}, request interface{}) *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call

RangeDeleteReplicationTaskFromDLQ is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.RangeDeleteReplicationTaskFromDLQRequest

func (*ExecutionManager_Expecter) UpdateWorkflowExecution 

func (_e *ExecutionManager_Expecter) UpdateWorkflowExecution(ctx interface{}, request interface{}) *ExecutionManager_UpdateWorkflowExecution_Call

UpdateWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.UpdateWorkflowExecutionRequest

type ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call 

type ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) Return 

func (_c *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) Return(historyTaskKeys []persistence.HistoryTaskKey, err error) *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call

func (*ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) Run 

func (_c *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) Run(run func(ctx context.Context, request *persistence.FetchWorkflowTimerTasksForCleanupRequest)) *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call

func (*ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) RunAndReturn 

func (_c *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call) RunAndReturn(run func(ctx context.Context, request *persistence.FetchWorkflowTimerTasksForCleanupRequest) ([]persistence.HistoryTaskKey, error)) *ExecutionManager_FetchWorkflowTimerTasksForCleanup_Call

type ExecutionManager_GetActiveClusterSelectionPolicy_Call 

type ExecutionManager_GetActiveClusterSelectionPolicy_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetActiveClusterSelectionPolicy_Call) Return 

func (_c *ExecutionManager_GetActiveClusterSelectionPolicy_Call) Return(activeClusterSelectionPolicy *types.ActiveClusterSelectionPolicy, err error) *ExecutionManager_GetActiveClusterSelectionPolicy_Call

func (*ExecutionManager_GetActiveClusterSelectionPolicy_Call) Run 

func (_c *ExecutionManager_GetActiveClusterSelectionPolicy_Call) Run(run func(ctx context.Context, request *persistence.GetActiveClusterSelectionPolicyRequest)) *ExecutionManager_GetActiveClusterSelectionPolicy_Call

func (*ExecutionManager_GetActiveClusterSelectionPolicy_Call) RunAndReturn 

func (_c *ExecutionManager_GetActiveClusterSelectionPolicy_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetActiveClusterSelectionPolicyRequest) (*types.ActiveClusterSelectionPolicy, error)) *ExecutionManager_GetActiveClusterSelectionPolicy_Call

type ExecutionManager_GetCurrentExecution_Call 

type ExecutionManager_GetCurrentExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetCurrentExecution_Call) Return 

func (_c *ExecutionManager_GetCurrentExecution_Call) Return(getCurrentExecutionResponse *persistence.GetCurrentExecutionResponse, err error) *ExecutionManager_GetCurrentExecution_Call

func (*ExecutionManager_GetCurrentExecution_Call) Run 

func (_c *ExecutionManager_GetCurrentExecution_Call) Run(run func(ctx context.Context, request *persistence.GetCurrentExecutionRequest)) *ExecutionManager_GetCurrentExecution_Call

func (*ExecutionManager_GetCurrentExecution_Call) RunAndReturn 

func (_c *ExecutionManager_GetCurrentExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)) *ExecutionManager_GetCurrentExecution_Call

type ExecutionManager_GetHistoryTasks_Call 

type ExecutionManager_GetHistoryTasks_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetHistoryTasks_Call) Return 

func (_c *ExecutionManager_GetHistoryTasks_Call) Return(getHistoryTasksResponse *persistence.GetHistoryTasksResponse, err error) *ExecutionManager_GetHistoryTasks_Call

func (*ExecutionManager_GetHistoryTasks_Call) Run 

func (_c *ExecutionManager_GetHistoryTasks_Call) Run(run func(ctx context.Context, request *persistence.GetHistoryTasksRequest)) *ExecutionManager_GetHistoryTasks_Call

func (*ExecutionManager_GetHistoryTasks_Call) RunAndReturn 

func (_c *ExecutionManager_GetHistoryTasks_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetHistoryTasksRequest) (*persistence.GetHistoryTasksResponse, error)) *ExecutionManager_GetHistoryTasks_Call

type ExecutionManager_GetName_Call 

type ExecutionManager_GetName_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetName_Call) Return 

func (_c *ExecutionManager_GetName_Call) Return(s string) *ExecutionManager_GetName_Call

func (*ExecutionManager_GetName_Call) Run 

func (_c *ExecutionManager_GetName_Call) Run(run func()) *ExecutionManager_GetName_Call

func (*ExecutionManager_GetName_Call) RunAndReturn 

func (_c *ExecutionManager_GetName_Call) RunAndReturn(run func() string) *ExecutionManager_GetName_Call

type ExecutionManager_GetReplicationDLQSize_Call 

type ExecutionManager_GetReplicationDLQSize_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetReplicationDLQSize_Call) Return 

func (_c *ExecutionManager_GetReplicationDLQSize_Call) Return(getReplicationDLQSizeResponse *persistence.GetReplicationDLQSizeResponse, err error) *ExecutionManager_GetReplicationDLQSize_Call

func (*ExecutionManager_GetReplicationDLQSize_Call) Run 

func (_c *ExecutionManager_GetReplicationDLQSize_Call) Run(run func(ctx context.Context, request *persistence.GetReplicationDLQSizeRequest)) *ExecutionManager_GetReplicationDLQSize_Call

func (*ExecutionManager_GetReplicationDLQSize_Call) RunAndReturn 

func (_c *ExecutionManager_GetReplicationDLQSize_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetReplicationDLQSizeRequest) (*persistence.GetReplicationDLQSizeResponse, error)) *ExecutionManager_GetReplicationDLQSize_Call

type ExecutionManager_GetReplicationTasksFromDLQ_Call 

type ExecutionManager_GetReplicationTasksFromDLQ_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetReplicationTasksFromDLQ_Call) Return 

func (_c *ExecutionManager_GetReplicationTasksFromDLQ_Call) Return(getReplicationDLQTasksResponse *persistence.GetReplicationDLQTasksResponse, err error) *ExecutionManager_GetReplicationTasksFromDLQ_Call

func (*ExecutionManager_GetReplicationTasksFromDLQ_Call) Run 

func (_c *ExecutionManager_GetReplicationTasksFromDLQ_Call) Run(run func(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest)) *ExecutionManager_GetReplicationTasksFromDLQ_Call

func (*ExecutionManager_GetReplicationTasksFromDLQ_Call) RunAndReturn 

func (_c *ExecutionManager_GetReplicationTasksFromDLQ_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationDLQTasksResponse, error)) *ExecutionManager_GetReplicationTasksFromDLQ_Call

type ExecutionManager_GetShardID_Call 

type ExecutionManager_GetShardID_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetShardID_Call) Return 

func (_c *ExecutionManager_GetShardID_Call) Return(n int) *ExecutionManager_GetShardID_Call

func (*ExecutionManager_GetShardID_Call) Run 

func (_c *ExecutionManager_GetShardID_Call) Run(run func()) *ExecutionManager_GetShardID_Call

func (*ExecutionManager_GetShardID_Call) RunAndReturn 

func (_c *ExecutionManager_GetShardID_Call) RunAndReturn(run func() int) *ExecutionManager_GetShardID_Call

type ExecutionManager_GetWorkflowExecution_Call 

type ExecutionManager_GetWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_GetWorkflowExecution_Call) Return 

func (_c *ExecutionManager_GetWorkflowExecution_Call) Return(getWorkflowExecutionResponse *persistence.GetWorkflowExecutionResponse, err error) *ExecutionManager_GetWorkflowExecution_Call

func (*ExecutionManager_GetWorkflowExecution_Call) Run 

func (_c *ExecutionManager_GetWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.GetWorkflowExecutionRequest)) *ExecutionManager_GetWorkflowExecution_Call

func (*ExecutionManager_GetWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_GetWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)) *ExecutionManager_GetWorkflowExecution_Call

type ExecutionManager_IsWorkflowExecutionExists_Call 

type ExecutionManager_IsWorkflowExecutionExists_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_IsWorkflowExecutionExists_Call) Return 

func (_c *ExecutionManager_IsWorkflowExecutionExists_Call) Return(isWorkflowExecutionExistsResponse *persistence.IsWorkflowExecutionExistsResponse, err error) *ExecutionManager_IsWorkflowExecutionExists_Call

func (*ExecutionManager_IsWorkflowExecutionExists_Call) Run 

func (_c *ExecutionManager_IsWorkflowExecutionExists_Call) Run(run func(ctx context.Context, request *persistence.IsWorkflowExecutionExistsRequest)) *ExecutionManager_IsWorkflowExecutionExists_Call

func (*ExecutionManager_IsWorkflowExecutionExists_Call) RunAndReturn 

func (_c *ExecutionManager_IsWorkflowExecutionExists_Call) RunAndReturn(run func(ctx context.Context, request *persistence.IsWorkflowExecutionExistsRequest) (*persistence.IsWorkflowExecutionExistsResponse, error)) *ExecutionManager_IsWorkflowExecutionExists_Call

type ExecutionManager_ListConcreteExecutions_Call 

type ExecutionManager_ListConcreteExecutions_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_ListConcreteExecutions_Call) Return 

func (_c *ExecutionManager_ListConcreteExecutions_Call) Return(listConcreteExecutionsResponse *persistence.ListConcreteExecutionsResponse, err error) *ExecutionManager_ListConcreteExecutions_Call

func (*ExecutionManager_ListConcreteExecutions_Call) Run 

func (_c *ExecutionManager_ListConcreteExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListConcreteExecutionsRequest)) *ExecutionManager_ListConcreteExecutions_Call

func (*ExecutionManager_ListConcreteExecutions_Call) RunAndReturn 

func (_c *ExecutionManager_ListConcreteExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)) *ExecutionManager_ListConcreteExecutions_Call

type ExecutionManager_ListCurrentExecutions_Call 

type ExecutionManager_ListCurrentExecutions_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_ListCurrentExecutions_Call) Return 

func (_c *ExecutionManager_ListCurrentExecutions_Call) Return(listCurrentExecutionsResponse *persistence.ListCurrentExecutionsResponse, err error) *ExecutionManager_ListCurrentExecutions_Call

func (*ExecutionManager_ListCurrentExecutions_Call) Run 

func (_c *ExecutionManager_ListCurrentExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListCurrentExecutionsRequest)) *ExecutionManager_ListCurrentExecutions_Call

func (*ExecutionManager_ListCurrentExecutions_Call) RunAndReturn 

func (_c *ExecutionManager_ListCurrentExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListCurrentExecutionsRequest) (*persistence.ListCurrentExecutionsResponse, error)) *ExecutionManager_ListCurrentExecutions_Call

type ExecutionManager_PutReplicationTaskToDLQ_Call 

type ExecutionManager_PutReplicationTaskToDLQ_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_PutReplicationTaskToDLQ_Call) Return 

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

func (*ExecutionManager_PutReplicationTaskToDLQ_Call) Run 

func (_c *ExecutionManager_PutReplicationTaskToDLQ_Call) Run(run func(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest)) *ExecutionManager_PutReplicationTaskToDLQ_Call

func (*ExecutionManager_PutReplicationTaskToDLQ_Call) RunAndReturn 

func (_c *ExecutionManager_PutReplicationTaskToDLQ_Call) RunAndReturn(run func(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest) error) *ExecutionManager_PutReplicationTaskToDLQ_Call

type ExecutionManager_RangeCompleteHistoryTask_Call 

type ExecutionManager_RangeCompleteHistoryTask_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_RangeCompleteHistoryTask_Call) Return 

func (_c *ExecutionManager_RangeCompleteHistoryTask_Call) Return(rangeCompleteHistoryTaskResponse *persistence.RangeCompleteHistoryTaskResponse, err error) *ExecutionManager_RangeCompleteHistoryTask_Call

func (*ExecutionManager_RangeCompleteHistoryTask_Call) Run 

func (_c *ExecutionManager_RangeCompleteHistoryTask_Call) Run(run func(ctx context.Context, request *persistence.RangeCompleteHistoryTaskRequest)) *ExecutionManager_RangeCompleteHistoryTask_Call

func (*ExecutionManager_RangeCompleteHistoryTask_Call) RunAndReturn 

func (_c *ExecutionManager_RangeCompleteHistoryTask_Call) RunAndReturn(run func(ctx context.Context, request *persistence.RangeCompleteHistoryTaskRequest) (*persistence.RangeCompleteHistoryTaskResponse, error)) *ExecutionManager_RangeCompleteHistoryTask_Call

type ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call 

type ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) Return 

func (_c *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) Return(rangeDeleteReplicationTaskFromDLQResponse *persistence.RangeDeleteReplicationTaskFromDLQResponse, err error) *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call

func (*ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) Run 

func (_c *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) Run(run func(ctx context.Context, request *persistence.RangeDeleteReplicationTaskFromDLQRequest)) *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call

func (*ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) RunAndReturn 

func (_c *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call) RunAndReturn(run func(ctx context.Context, request *persistence.RangeDeleteReplicationTaskFromDLQRequest) (*persistence.RangeDeleteReplicationTaskFromDLQResponse, error)) *ExecutionManager_RangeDeleteReplicationTaskFromDLQ_Call

type ExecutionManager_UpdateWorkflowExecution_Call 

type ExecutionManager_UpdateWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*ExecutionManager_UpdateWorkflowExecution_Call) Return 

func (_c *ExecutionManager_UpdateWorkflowExecution_Call) Return(updateWorkflowExecutionResponse *persistence.UpdateWorkflowExecutionResponse, err error) *ExecutionManager_UpdateWorkflowExecution_Call

func (*ExecutionManager_UpdateWorkflowExecution_Call) Run 

func (_c *ExecutionManager_UpdateWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest)) *ExecutionManager_UpdateWorkflowExecution_Call

func (*ExecutionManager_UpdateWorkflowExecution_Call) RunAndReturn 

func (_c *ExecutionManager_UpdateWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)) *ExecutionManager_UpdateWorkflowExecution_Call

type HistoryV2Manager added in v0.5.0 

type HistoryV2Manager struct {
	mock.Mock
}

HistoryV2Manager is an autogenerated mock type for the HistoryManager type

func NewHistoryV2Manager 

func NewHistoryV2Manager(t interface {
	mock.TestingT
	Cleanup(func())
}) *HistoryV2Manager

NewHistoryV2Manager creates a new instance of HistoryV2Manager. 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 (*HistoryV2Manager) AppendHistoryNodes added in v0.5.0 

func (_mock *HistoryV2Manager) AppendHistoryNodes(ctx context.Context, request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

AppendHistoryNodes provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) Close added in v0.5.0 

func (_mock *HistoryV2Manager) Close()

Close provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) DeleteHistoryBranch added in v0.5.0 

func (_mock *HistoryV2Manager) DeleteHistoryBranch(ctx context.Context, request *persistence.DeleteHistoryBranchRequest) error

DeleteHistoryBranch provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) EXPECT 

func (_m *HistoryV2Manager) EXPECT() *HistoryV2Manager_Expecter

func (*HistoryV2Manager) ForkHistoryBranch added in v0.5.0 

func (_mock *HistoryV2Manager) ForkHistoryBranch(ctx context.Context, request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

ForkHistoryBranch provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) GetAllHistoryTreeBranches added in v0.9.0 

func (_mock *HistoryV2Manager) GetAllHistoryTreeBranches(ctx context.Context, request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

GetAllHistoryTreeBranches provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) GetHistoryTree added in v0.5.0 

func (_mock *HistoryV2Manager) GetHistoryTree(ctx context.Context, request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

GetHistoryTree provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) GetName added in v0.5.0 

func (_mock *HistoryV2Manager) GetName() string

GetName provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) ReadHistoryBranch added in v0.5.0 

func (_mock *HistoryV2Manager) ReadHistoryBranch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

ReadHistoryBranch provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) ReadHistoryBranchByBatch added in v0.5.0 

func (_mock *HistoryV2Manager) ReadHistoryBranchByBatch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

ReadHistoryBranchByBatch provides a mock function for the type HistoryV2Manager

func (*HistoryV2Manager) ReadRawHistoryBranch added in v0.9.0 

func (_mock *HistoryV2Manager) ReadRawHistoryBranch(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

ReadRawHistoryBranch provides a mock function for the type HistoryV2Manager

type HistoryV2Manager_AppendHistoryNodes_Call 

type HistoryV2Manager_AppendHistoryNodes_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_AppendHistoryNodes_Call) Return 

func (_c *HistoryV2Manager_AppendHistoryNodes_Call) Return(appendHistoryNodesResponse *persistence.AppendHistoryNodesResponse, err error) *HistoryV2Manager_AppendHistoryNodes_Call

func (*HistoryV2Manager_AppendHistoryNodes_Call) Run 

func (_c *HistoryV2Manager_AppendHistoryNodes_Call) Run(run func(ctx context.Context, request *persistence.AppendHistoryNodesRequest)) *HistoryV2Manager_AppendHistoryNodes_Call

func (*HistoryV2Manager_AppendHistoryNodes_Call) RunAndReturn 

func (_c *HistoryV2Manager_AppendHistoryNodes_Call) RunAndReturn(run func(ctx context.Context, request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)) *HistoryV2Manager_AppendHistoryNodes_Call

type HistoryV2Manager_Close_Call 

type HistoryV2Manager_Close_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_Close_Call) Return 

func (_c *HistoryV2Manager_Close_Call) Return() *HistoryV2Manager_Close_Call

func (*HistoryV2Manager_Close_Call) Run 

func (_c *HistoryV2Manager_Close_Call) Run(run func()) *HistoryV2Manager_Close_Call

func (*HistoryV2Manager_Close_Call) RunAndReturn 

func (_c *HistoryV2Manager_Close_Call) RunAndReturn(run func()) *HistoryV2Manager_Close_Call

type HistoryV2Manager_DeleteHistoryBranch_Call 

type HistoryV2Manager_DeleteHistoryBranch_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_DeleteHistoryBranch_Call) Return 

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

func (*HistoryV2Manager_DeleteHistoryBranch_Call) Run 

func (_c *HistoryV2Manager_DeleteHistoryBranch_Call) Run(run func(ctx context.Context, request *persistence.DeleteHistoryBranchRequest)) *HistoryV2Manager_DeleteHistoryBranch_Call

func (*HistoryV2Manager_DeleteHistoryBranch_Call) RunAndReturn 

func (_c *HistoryV2Manager_DeleteHistoryBranch_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteHistoryBranchRequest) error) *HistoryV2Manager_DeleteHistoryBranch_Call

type HistoryV2Manager_Expecter 

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

func (*HistoryV2Manager_Expecter) AppendHistoryNodes 

func (_e *HistoryV2Manager_Expecter) AppendHistoryNodes(ctx interface{}, request interface{}) *HistoryV2Manager_AppendHistoryNodes_Call

AppendHistoryNodes is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.AppendHistoryNodesRequest

func (*HistoryV2Manager_Expecter) Close 

func (_e *HistoryV2Manager_Expecter) Close() *HistoryV2Manager_Close_Call

Close is a helper method to define mock.On call

func (*HistoryV2Manager_Expecter) DeleteHistoryBranch 

func (_e *HistoryV2Manager_Expecter) DeleteHistoryBranch(ctx interface{}, request interface{}) *HistoryV2Manager_DeleteHistoryBranch_Call

DeleteHistoryBranch is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteHistoryBranchRequest

func (*HistoryV2Manager_Expecter) ForkHistoryBranch 

func (_e *HistoryV2Manager_Expecter) ForkHistoryBranch(ctx interface{}, request interface{}) *HistoryV2Manager_ForkHistoryBranch_Call

ForkHistoryBranch is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ForkHistoryBranchRequest

func (*HistoryV2Manager_Expecter) GetAllHistoryTreeBranches 

func (_e *HistoryV2Manager_Expecter) GetAllHistoryTreeBranches(ctx interface{}, request interface{}) *HistoryV2Manager_GetAllHistoryTreeBranches_Call

GetAllHistoryTreeBranches is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetAllHistoryTreeBranchesRequest

func (*HistoryV2Manager_Expecter) GetHistoryTree 

func (_e *HistoryV2Manager_Expecter) GetHistoryTree(ctx interface{}, request interface{}) *HistoryV2Manager_GetHistoryTree_Call

GetHistoryTree is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetHistoryTreeRequest

func (*HistoryV2Manager_Expecter) GetName 

func (_e *HistoryV2Manager_Expecter) GetName() *HistoryV2Manager_GetName_Call

GetName is a helper method to define mock.On call

func (*HistoryV2Manager_Expecter) ReadHistoryBranch 

func (_e *HistoryV2Manager_Expecter) ReadHistoryBranch(ctx interface{}, request interface{}) *HistoryV2Manager_ReadHistoryBranch_Call

ReadHistoryBranch is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ReadHistoryBranchRequest

func (*HistoryV2Manager_Expecter) ReadHistoryBranchByBatch 

func (_e *HistoryV2Manager_Expecter) ReadHistoryBranchByBatch(ctx interface{}, request interface{}) *HistoryV2Manager_ReadHistoryBranchByBatch_Call

ReadHistoryBranchByBatch is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ReadHistoryBranchRequest

func (*HistoryV2Manager_Expecter) ReadRawHistoryBranch 

func (_e *HistoryV2Manager_Expecter) ReadRawHistoryBranch(ctx interface{}, request interface{}) *HistoryV2Manager_ReadRawHistoryBranch_Call

ReadRawHistoryBranch is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ReadHistoryBranchRequest

type HistoryV2Manager_ForkHistoryBranch_Call 

type HistoryV2Manager_ForkHistoryBranch_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_ForkHistoryBranch_Call) Return 

func (_c *HistoryV2Manager_ForkHistoryBranch_Call) Return(forkHistoryBranchResponse *persistence.ForkHistoryBranchResponse, err error) *HistoryV2Manager_ForkHistoryBranch_Call

func (*HistoryV2Manager_ForkHistoryBranch_Call) Run 

func (_c *HistoryV2Manager_ForkHistoryBranch_Call) Run(run func(ctx context.Context, request *persistence.ForkHistoryBranchRequest)) *HistoryV2Manager_ForkHistoryBranch_Call

func (*HistoryV2Manager_ForkHistoryBranch_Call) RunAndReturn 

func (_c *HistoryV2Manager_ForkHistoryBranch_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)) *HistoryV2Manager_ForkHistoryBranch_Call

type HistoryV2Manager_GetAllHistoryTreeBranches_Call 

type HistoryV2Manager_GetAllHistoryTreeBranches_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_GetAllHistoryTreeBranches_Call) Return 

func (_c *HistoryV2Manager_GetAllHistoryTreeBranches_Call) Return(getAllHistoryTreeBranchesResponse *persistence.GetAllHistoryTreeBranchesResponse, err error) *HistoryV2Manager_GetAllHistoryTreeBranches_Call

func (*HistoryV2Manager_GetAllHistoryTreeBranches_Call) Run 

func (_c *HistoryV2Manager_GetAllHistoryTreeBranches_Call) Run(run func(ctx context.Context, request *persistence.GetAllHistoryTreeBranchesRequest)) *HistoryV2Manager_GetAllHistoryTreeBranches_Call

func (*HistoryV2Manager_GetAllHistoryTreeBranches_Call) RunAndReturn 

func (_c *HistoryV2Manager_GetAllHistoryTreeBranches_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)) *HistoryV2Manager_GetAllHistoryTreeBranches_Call

type HistoryV2Manager_GetHistoryTree_Call 

type HistoryV2Manager_GetHistoryTree_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_GetHistoryTree_Call) Return 

func (_c *HistoryV2Manager_GetHistoryTree_Call) Return(getHistoryTreeResponse *persistence.GetHistoryTreeResponse, err error) *HistoryV2Manager_GetHistoryTree_Call

func (*HistoryV2Manager_GetHistoryTree_Call) Run 

func (_c *HistoryV2Manager_GetHistoryTree_Call) Run(run func(ctx context.Context, request *persistence.GetHistoryTreeRequest)) *HistoryV2Manager_GetHistoryTree_Call

func (*HistoryV2Manager_GetHistoryTree_Call) RunAndReturn 

func (_c *HistoryV2Manager_GetHistoryTree_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)) *HistoryV2Manager_GetHistoryTree_Call

type HistoryV2Manager_GetName_Call 

type HistoryV2Manager_GetName_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_GetName_Call) Return 

func (_c *HistoryV2Manager_GetName_Call) Return(s string) *HistoryV2Manager_GetName_Call

func (*HistoryV2Manager_GetName_Call) Run 

func (_c *HistoryV2Manager_GetName_Call) Run(run func()) *HistoryV2Manager_GetName_Call

func (*HistoryV2Manager_GetName_Call) RunAndReturn 

func (_c *HistoryV2Manager_GetName_Call) RunAndReturn(run func() string) *HistoryV2Manager_GetName_Call

type HistoryV2Manager_ReadHistoryBranchByBatch_Call 

type HistoryV2Manager_ReadHistoryBranchByBatch_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_ReadHistoryBranchByBatch_Call) Return 

func (_c *HistoryV2Manager_ReadHistoryBranchByBatch_Call) Return(readHistoryBranchByBatchResponse *persistence.ReadHistoryBranchByBatchResponse, err error) *HistoryV2Manager_ReadHistoryBranchByBatch_Call

func (*HistoryV2Manager_ReadHistoryBranchByBatch_Call) Run 

func (_c *HistoryV2Manager_ReadHistoryBranchByBatch_Call) Run(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest)) *HistoryV2Manager_ReadHistoryBranchByBatch_Call

func (*HistoryV2Manager_ReadHistoryBranchByBatch_Call) RunAndReturn 

func (_c *HistoryV2Manager_ReadHistoryBranchByBatch_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)) *HistoryV2Manager_ReadHistoryBranchByBatch_Call

type HistoryV2Manager_ReadHistoryBranch_Call 

type HistoryV2Manager_ReadHistoryBranch_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_ReadHistoryBranch_Call) Return 

func (_c *HistoryV2Manager_ReadHistoryBranch_Call) Return(readHistoryBranchResponse *persistence.ReadHistoryBranchResponse, err error) *HistoryV2Manager_ReadHistoryBranch_Call

func (*HistoryV2Manager_ReadHistoryBranch_Call) Run 

func (_c *HistoryV2Manager_ReadHistoryBranch_Call) Run(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest)) *HistoryV2Manager_ReadHistoryBranch_Call

func (*HistoryV2Manager_ReadHistoryBranch_Call) RunAndReturn 

func (_c *HistoryV2Manager_ReadHistoryBranch_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)) *HistoryV2Manager_ReadHistoryBranch_Call

type HistoryV2Manager_ReadRawHistoryBranch_Call 

type HistoryV2Manager_ReadRawHistoryBranch_Call struct {
	*mock.Call
}

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

func (*HistoryV2Manager_ReadRawHistoryBranch_Call) Return 

func (_c *HistoryV2Manager_ReadRawHistoryBranch_Call) Return(readRawHistoryBranchResponse *persistence.ReadRawHistoryBranchResponse, err error) *HistoryV2Manager_ReadRawHistoryBranch_Call

func (*HistoryV2Manager_ReadRawHistoryBranch_Call) Run 

func (_c *HistoryV2Manager_ReadRawHistoryBranch_Call) Run(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest)) *HistoryV2Manager_ReadRawHistoryBranch_Call

func (*HistoryV2Manager_ReadRawHistoryBranch_Call) RunAndReturn 

func (_c *HistoryV2Manager_ReadRawHistoryBranch_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)) *HistoryV2Manager_ReadRawHistoryBranch_Call

type KafkaProducer added in v0.3.7 

type KafkaProducer struct {
	mock.Mock
}

KafkaProducer is an autogenerated mock type for the KafkaProducer type

func (*KafkaProducer) Close added in v0.3.7 

func (_m *KafkaProducer) Close() error

Close provides a mock function with given fields:

func (*KafkaProducer) Publish added in v0.3.7 

func (_m *KafkaProducer) Publish(ctx context.Context, message interface{}) error

Publish provides a mock function with given fields: ctx, message

type MessagingClient added in v0.3.11 

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

MessagingClient is the mock implementation for Service interface

func (*MessagingClient) NewConsumer added in v0.3.11 

func (c *MessagingClient) NewConsumer(appName, consumerName string) (messaging.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11 

func (c *MessagingClient) NewProducer(appName string) (messaging.Producer, error)

NewProducer generates a dummy implementation of kafka producer

type MetadataManager 

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the DomainManager type

func NewMetadataManager 

func NewMetadataManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MetadataManager

NewMetadataManager creates a new instance of MetadataManager. 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 (*MetadataManager) Close 

func (_mock *MetadataManager) Close()

Close provides a mock function for the type MetadataManager

func (*MetadataManager) CreateDomain 

func (_mock *MetadataManager) CreateDomain(ctx context.Context, request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)

CreateDomain provides a mock function for the type MetadataManager

func (*MetadataManager) DeleteDomain 

func (_mock *MetadataManager) DeleteDomain(ctx context.Context, request *persistence.DeleteDomainRequest) error

DeleteDomain provides a mock function for the type MetadataManager

func (*MetadataManager) DeleteDomainByName 

func (_mock *MetadataManager) DeleteDomainByName(ctx context.Context, request *persistence.DeleteDomainByNameRequest) error

DeleteDomainByName provides a mock function for the type MetadataManager

func (*MetadataManager) EXPECT 

func (_m *MetadataManager) EXPECT() *MetadataManager_Expecter

func (*MetadataManager) GetDomain 

func (_mock *MetadataManager) GetDomain(ctx context.Context, request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)

GetDomain provides a mock function for the type MetadataManager

func (*MetadataManager) GetMetadata added in v0.3.13 

func (_mock *MetadataManager) GetMetadata(ctx context.Context) (*persistence.GetMetadataResponse, error)

GetMetadata provides a mock function for the type MetadataManager

func (*MetadataManager) GetName added in v0.4.0 

func (_mock *MetadataManager) GetName() string

GetName provides a mock function for the type MetadataManager

func (*MetadataManager) ListDomains added in v0.3.14 

func (_mock *MetadataManager) ListDomains(ctx context.Context, request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)

ListDomains provides a mock function for the type MetadataManager

func (*MetadataManager) UpdateDomain 

func (_mock *MetadataManager) UpdateDomain(ctx context.Context, request *persistence.UpdateDomainRequest) error

UpdateDomain provides a mock function for the type MetadataManager

type MetadataManager_Close_Call 

type MetadataManager_Close_Call struct {
	*mock.Call
}

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

func (*MetadataManager_Close_Call) Return 

func (_c *MetadataManager_Close_Call) Return() *MetadataManager_Close_Call

func (*MetadataManager_Close_Call) Run 

func (_c *MetadataManager_Close_Call) Run(run func()) *MetadataManager_Close_Call

func (*MetadataManager_Close_Call) RunAndReturn 

func (_c *MetadataManager_Close_Call) RunAndReturn(run func()) *MetadataManager_Close_Call

type MetadataManager_CreateDomain_Call 

type MetadataManager_CreateDomain_Call struct {
	*mock.Call
}

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

func (*MetadataManager_CreateDomain_Call) Return 

func (_c *MetadataManager_CreateDomain_Call) Return(createDomainResponse *persistence.CreateDomainResponse, err error) *MetadataManager_CreateDomain_Call

func (*MetadataManager_CreateDomain_Call) Run 

func (_c *MetadataManager_CreateDomain_Call) Run(run func(ctx context.Context, request *persistence.CreateDomainRequest)) *MetadataManager_CreateDomain_Call

func (*MetadataManager_CreateDomain_Call) RunAndReturn 

func (_c *MetadataManager_CreateDomain_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)) *MetadataManager_CreateDomain_Call

type MetadataManager_DeleteDomainByName_Call 

type MetadataManager_DeleteDomainByName_Call struct {
	*mock.Call
}

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

func (*MetadataManager_DeleteDomainByName_Call) Return 

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

func (*MetadataManager_DeleteDomainByName_Call) Run 

func (_c *MetadataManager_DeleteDomainByName_Call) Run(run func(ctx context.Context, request *persistence.DeleteDomainByNameRequest)) *MetadataManager_DeleteDomainByName_Call

func (*MetadataManager_DeleteDomainByName_Call) RunAndReturn 

func (_c *MetadataManager_DeleteDomainByName_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteDomainByNameRequest) error) *MetadataManager_DeleteDomainByName_Call

type MetadataManager_DeleteDomain_Call 

type MetadataManager_DeleteDomain_Call struct {
	*mock.Call
}

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

func (*MetadataManager_DeleteDomain_Call) Return 

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

func (*MetadataManager_DeleteDomain_Call) Run 

func (_c *MetadataManager_DeleteDomain_Call) Run(run func(ctx context.Context, request *persistence.DeleteDomainRequest)) *MetadataManager_DeleteDomain_Call

func (*MetadataManager_DeleteDomain_Call) RunAndReturn 

func (_c *MetadataManager_DeleteDomain_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteDomainRequest) error) *MetadataManager_DeleteDomain_Call

type MetadataManager_Expecter 

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

func (*MetadataManager_Expecter) Close 

func (_e *MetadataManager_Expecter) Close() *MetadataManager_Close_Call

Close is a helper method to define mock.On call

func (*MetadataManager_Expecter) CreateDomain 

func (_e *MetadataManager_Expecter) CreateDomain(ctx interface{}, request interface{}) *MetadataManager_CreateDomain_Call

CreateDomain is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CreateDomainRequest

func (*MetadataManager_Expecter) DeleteDomain 

func (_e *MetadataManager_Expecter) DeleteDomain(ctx interface{}, request interface{}) *MetadataManager_DeleteDomain_Call

DeleteDomain is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteDomainRequest

func (*MetadataManager_Expecter) DeleteDomainByName 

func (_e *MetadataManager_Expecter) DeleteDomainByName(ctx interface{}, request interface{}) *MetadataManager_DeleteDomainByName_Call

DeleteDomainByName is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteDomainByNameRequest

func (*MetadataManager_Expecter) GetDomain 

func (_e *MetadataManager_Expecter) GetDomain(ctx interface{}, request interface{}) *MetadataManager_GetDomain_Call

GetDomain is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetDomainRequest

func (*MetadataManager_Expecter) GetMetadata 

func (_e *MetadataManager_Expecter) GetMetadata(ctx interface{}) *MetadataManager_GetMetadata_Call

GetMetadata is a helper method to define mock.On call

  • ctx context.Context

func (*MetadataManager_Expecter) GetName 

func (_e *MetadataManager_Expecter) GetName() *MetadataManager_GetName_Call

GetName is a helper method to define mock.On call

func (*MetadataManager_Expecter) ListDomains 

func (_e *MetadataManager_Expecter) ListDomains(ctx interface{}, request interface{}) *MetadataManager_ListDomains_Call

ListDomains is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListDomainsRequest

func (*MetadataManager_Expecter) UpdateDomain 

func (_e *MetadataManager_Expecter) UpdateDomain(ctx interface{}, request interface{}) *MetadataManager_UpdateDomain_Call

UpdateDomain is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.UpdateDomainRequest

type MetadataManager_GetDomain_Call 

type MetadataManager_GetDomain_Call struct {
	*mock.Call
}

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

func (*MetadataManager_GetDomain_Call) Return 

func (_c *MetadataManager_GetDomain_Call) Return(getDomainResponse *persistence.GetDomainResponse, err error) *MetadataManager_GetDomain_Call

func (*MetadataManager_GetDomain_Call) Run 

func (_c *MetadataManager_GetDomain_Call) Run(run func(ctx context.Context, request *persistence.GetDomainRequest)) *MetadataManager_GetDomain_Call

func (*MetadataManager_GetDomain_Call) RunAndReturn 

func (_c *MetadataManager_GetDomain_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)) *MetadataManager_GetDomain_Call

type MetadataManager_GetMetadata_Call 

type MetadataManager_GetMetadata_Call struct {
	*mock.Call
}

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

func (*MetadataManager_GetMetadata_Call) Return 

func (_c *MetadataManager_GetMetadata_Call) Return(getMetadataResponse *persistence.GetMetadataResponse, err error) *MetadataManager_GetMetadata_Call

func (*MetadataManager_GetMetadata_Call) Run 

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

func (*MetadataManager_GetMetadata_Call) RunAndReturn 

func (_c *MetadataManager_GetMetadata_Call) RunAndReturn(run func(ctx context.Context) (*persistence.GetMetadataResponse, error)) *MetadataManager_GetMetadata_Call

type MetadataManager_GetName_Call 

type MetadataManager_GetName_Call struct {
	*mock.Call
}

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

func (*MetadataManager_GetName_Call) Return 

func (_c *MetadataManager_GetName_Call) Return(s string) *MetadataManager_GetName_Call

func (*MetadataManager_GetName_Call) Run 

func (_c *MetadataManager_GetName_Call) Run(run func()) *MetadataManager_GetName_Call

func (*MetadataManager_GetName_Call) RunAndReturn 

func (_c *MetadataManager_GetName_Call) RunAndReturn(run func() string) *MetadataManager_GetName_Call

type MetadataManager_ListDomains_Call 

type MetadataManager_ListDomains_Call struct {
	*mock.Call
}

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

func (*MetadataManager_ListDomains_Call) Return 

func (_c *MetadataManager_ListDomains_Call) Return(listDomainsResponse *persistence.ListDomainsResponse, err error) *MetadataManager_ListDomains_Call

func (*MetadataManager_ListDomains_Call) Run 

func (_c *MetadataManager_ListDomains_Call) Run(run func(ctx context.Context, request *persistence.ListDomainsRequest)) *MetadataManager_ListDomains_Call

func (*MetadataManager_ListDomains_Call) RunAndReturn 

func (_c *MetadataManager_ListDomains_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)) *MetadataManager_ListDomains_Call

type MetadataManager_UpdateDomain_Call 

type MetadataManager_UpdateDomain_Call struct {
	*mock.Call
}

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

func (*MetadataManager_UpdateDomain_Call) Return 

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

func (*MetadataManager_UpdateDomain_Call) Run 

func (_c *MetadataManager_UpdateDomain_Call) Run(run func(ctx context.Context, request *persistence.UpdateDomainRequest)) *MetadataManager_UpdateDomain_Call

func (*MetadataManager_UpdateDomain_Call) RunAndReturn 

func (_c *MetadataManager_UpdateDomain_Call) RunAndReturn(run func(ctx context.Context, request *persistence.UpdateDomainRequest) error) *MetadataManager_UpdateDomain_Call

type ShardManager 

type ShardManager struct {
	mock.Mock
}

ShardManager is an autogenerated mock type for the ShardManager type

func NewShardManager 

func NewShardManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShardManager

NewShardManager creates a new instance of ShardManager. 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 (*ShardManager) Close 

func (_mock *ShardManager) Close()

Close provides a mock function for the type ShardManager

func (*ShardManager) CreateShard 

func (_mock *ShardManager) CreateShard(ctx context.Context, request *persistence.CreateShardRequest) error

CreateShard provides a mock function for the type ShardManager

func (*ShardManager) EXPECT 

func (_m *ShardManager) EXPECT() *ShardManager_Expecter

func (*ShardManager) GetName added in v0.4.0 

func (_mock *ShardManager) GetName() string

GetName provides a mock function for the type ShardManager

func (*ShardManager) GetShard 

func (_mock *ShardManager) GetShard(ctx context.Context, request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

GetShard provides a mock function for the type ShardManager

func (*ShardManager) UpdateShard 

func (_mock *ShardManager) UpdateShard(ctx context.Context, request *persistence.UpdateShardRequest) error

UpdateShard provides a mock function for the type ShardManager

type ShardManager_Close_Call 

type ShardManager_Close_Call struct {
	*mock.Call
}

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

func (*ShardManager_Close_Call) Return 

func (_c *ShardManager_Close_Call) Return() *ShardManager_Close_Call

func (*ShardManager_Close_Call) Run 

func (_c *ShardManager_Close_Call) Run(run func()) *ShardManager_Close_Call

func (*ShardManager_Close_Call) RunAndReturn 

func (_c *ShardManager_Close_Call) RunAndReturn(run func()) *ShardManager_Close_Call

type ShardManager_CreateShard_Call 

type ShardManager_CreateShard_Call struct {
	*mock.Call
}

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

func (*ShardManager_CreateShard_Call) Return 

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

func (*ShardManager_CreateShard_Call) Run 

func (_c *ShardManager_CreateShard_Call) Run(run func(ctx context.Context, request *persistence.CreateShardRequest)) *ShardManager_CreateShard_Call

func (*ShardManager_CreateShard_Call) RunAndReturn 

func (_c *ShardManager_CreateShard_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CreateShardRequest) error) *ShardManager_CreateShard_Call

type ShardManager_Expecter 

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

func (*ShardManager_Expecter) Close 

func (_e *ShardManager_Expecter) Close() *ShardManager_Close_Call

Close is a helper method to define mock.On call

func (*ShardManager_Expecter) CreateShard 

func (_e *ShardManager_Expecter) CreateShard(ctx interface{}, request interface{}) *ShardManager_CreateShard_Call

CreateShard is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CreateShardRequest

func (*ShardManager_Expecter) GetName 

func (_e *ShardManager_Expecter) GetName() *ShardManager_GetName_Call

GetName is a helper method to define mock.On call

func (*ShardManager_Expecter) GetShard 

func (_e *ShardManager_Expecter) GetShard(ctx interface{}, request interface{}) *ShardManager_GetShard_Call

GetShard is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetShardRequest

func (*ShardManager_Expecter) UpdateShard 

func (_e *ShardManager_Expecter) UpdateShard(ctx interface{}, request interface{}) *ShardManager_UpdateShard_Call

UpdateShard is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.UpdateShardRequest

type ShardManager_GetName_Call 

type ShardManager_GetName_Call struct {
	*mock.Call
}

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

func (*ShardManager_GetName_Call) Return 

func (_c *ShardManager_GetName_Call) Return(s string) *ShardManager_GetName_Call

func (*ShardManager_GetName_Call) Run 

func (_c *ShardManager_GetName_Call) Run(run func()) *ShardManager_GetName_Call

func (*ShardManager_GetName_Call) RunAndReturn 

func (_c *ShardManager_GetName_Call) RunAndReturn(run func() string) *ShardManager_GetName_Call

type ShardManager_GetShard_Call 

type ShardManager_GetShard_Call struct {
	*mock.Call
}

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

func (*ShardManager_GetShard_Call) Return 

func (_c *ShardManager_GetShard_Call) Return(getShardResponse *persistence.GetShardResponse, err error) *ShardManager_GetShard_Call

func (*ShardManager_GetShard_Call) Run 

func (_c *ShardManager_GetShard_Call) Run(run func(ctx context.Context, request *persistence.GetShardRequest)) *ShardManager_GetShard_Call

func (*ShardManager_GetShard_Call) RunAndReturn 

func (_c *ShardManager_GetShard_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)) *ShardManager_GetShard_Call

type ShardManager_UpdateShard_Call 

type ShardManager_UpdateShard_Call struct {
	*mock.Call
}

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

func (*ShardManager_UpdateShard_Call) Return 

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

func (*ShardManager_UpdateShard_Call) Run 

func (_c *ShardManager_UpdateShard_Call) Run(run func(ctx context.Context, request *persistence.UpdateShardRequest)) *ShardManager_UpdateShard_Call

func (*ShardManager_UpdateShard_Call) RunAndReturn 

func (_c *ShardManager_UpdateShard_Call) RunAndReturn(run func(ctx context.Context, request *persistence.UpdateShardRequest) error) *ShardManager_UpdateShard_Call

type TaskManager 

type TaskManager struct {
	mock.Mock
}

TaskManager is an autogenerated mock type for the TaskManager type

func NewTaskManager added in v1.2.6 

func NewTaskManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskManager

NewTaskManager creates a new instance of TaskManager. 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 (*TaskManager) Close 

func (_mock *TaskManager) Close()

Close provides a mock function for the type TaskManager

func (*TaskManager) CompleteTask 

func (_mock *TaskManager) CompleteTask(ctx context.Context, request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function for the type TaskManager

func (*TaskManager) CompleteTasksLessThan added in v0.5.7 

func (_mock *TaskManager) CompleteTasksLessThan(ctx context.Context, request *persistence.CompleteTasksLessThanRequest) (*persistence.CompleteTasksLessThanResponse, error)

CompleteTasksLessThan provides a mock function for the type TaskManager

func (*TaskManager) CreateTasks 

func (_mock *TaskManager) CreateTasks(ctx context.Context, request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

CreateTasks provides a mock function for the type TaskManager

func (*TaskManager) DeleteTaskList added in v0.5.7 

func (_mock *TaskManager) DeleteTaskList(ctx context.Context, request *persistence.DeleteTaskListRequest) error

DeleteTaskList provides a mock function for the type TaskManager

func (*TaskManager) EXPECT 

func (_m *TaskManager) EXPECT() *TaskManager_Expecter

func (*TaskManager) GetName added in v0.4.0 

func (_mock *TaskManager) GetName() string

GetName provides a mock function for the type TaskManager

func (*TaskManager) GetOrphanTasks added in v0.21.0 

func (_mock *TaskManager) GetOrphanTasks(ctx context.Context, request *persistence.GetOrphanTasksRequest) (*persistence.GetOrphanTasksResponse, error)

GetOrphanTasks provides a mock function for the type TaskManager

func (*TaskManager) GetTaskList added in v1.2.15 

func (_mock *TaskManager) GetTaskList(ctx context.Context, request *persistence.GetTaskListRequest) (*persistence.GetTaskListResponse, error)

GetTaskList provides a mock function for the type TaskManager

func (*TaskManager) GetTaskListSize added in v1.2.6 

func (_mock *TaskManager) GetTaskListSize(ctx context.Context, request *persistence.GetTaskListSizeRequest) (*persistence.GetTaskListSizeResponse, error)

GetTaskListSize provides a mock function for the type TaskManager

func (*TaskManager) GetTasks 

func (_mock *TaskManager) GetTasks(ctx context.Context, request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

GetTasks provides a mock function for the type TaskManager

func (*TaskManager) LeaseTaskList 

func (_mock *TaskManager) LeaseTaskList(ctx context.Context, request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)

LeaseTaskList provides a mock function for the type TaskManager

func (*TaskManager) ListTaskList added in v0.5.7 

func (_mock *TaskManager) ListTaskList(ctx context.Context, request *persistence.ListTaskListRequest) (*persistence.ListTaskListResponse, error)

ListTaskList provides a mock function for the type TaskManager

func (*TaskManager) UpdateTaskList 

func (_mock *TaskManager) UpdateTaskList(ctx context.Context, request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)

UpdateTaskList provides a mock function for the type TaskManager

type TaskManager_Close_Call 

type TaskManager_Close_Call struct {
	*mock.Call
}

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

func (*TaskManager_Close_Call) Return 

func (_c *TaskManager_Close_Call) Return() *TaskManager_Close_Call

func (*TaskManager_Close_Call) Run 

func (_c *TaskManager_Close_Call) Run(run func()) *TaskManager_Close_Call

func (*TaskManager_Close_Call) RunAndReturn 

func (_c *TaskManager_Close_Call) RunAndReturn(run func()) *TaskManager_Close_Call

type TaskManager_CompleteTask_Call 

type TaskManager_CompleteTask_Call struct {
	*mock.Call
}

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

func (*TaskManager_CompleteTask_Call) Return 

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

func (*TaskManager_CompleteTask_Call) Run 

func (_c *TaskManager_CompleteTask_Call) Run(run func(ctx context.Context, request *persistence.CompleteTaskRequest)) *TaskManager_CompleteTask_Call

func (*TaskManager_CompleteTask_Call) RunAndReturn 

func (_c *TaskManager_CompleteTask_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CompleteTaskRequest) error) *TaskManager_CompleteTask_Call

type TaskManager_CompleteTasksLessThan_Call 

type TaskManager_CompleteTasksLessThan_Call struct {
	*mock.Call
}

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

func (*TaskManager_CompleteTasksLessThan_Call) Return 

func (_c *TaskManager_CompleteTasksLessThan_Call) Return(completeTasksLessThanResponse *persistence.CompleteTasksLessThanResponse, err error) *TaskManager_CompleteTasksLessThan_Call

func (*TaskManager_CompleteTasksLessThan_Call) Run 

func (_c *TaskManager_CompleteTasksLessThan_Call) Run(run func(ctx context.Context, request *persistence.CompleteTasksLessThanRequest)) *TaskManager_CompleteTasksLessThan_Call

func (*TaskManager_CompleteTasksLessThan_Call) RunAndReturn 

func (_c *TaskManager_CompleteTasksLessThan_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CompleteTasksLessThanRequest) (*persistence.CompleteTasksLessThanResponse, error)) *TaskManager_CompleteTasksLessThan_Call

type TaskManager_CreateTasks_Call 

type TaskManager_CreateTasks_Call struct {
	*mock.Call
}

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

func (*TaskManager_CreateTasks_Call) Return 

func (_c *TaskManager_CreateTasks_Call) Return(createTasksResponse *persistence.CreateTasksResponse, err error) *TaskManager_CreateTasks_Call

func (*TaskManager_CreateTasks_Call) Run 

func (_c *TaskManager_CreateTasks_Call) Run(run func(ctx context.Context, request *persistence.CreateTasksRequest)) *TaskManager_CreateTasks_Call

func (*TaskManager_CreateTasks_Call) RunAndReturn 

func (_c *TaskManager_CreateTasks_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)) *TaskManager_CreateTasks_Call

type TaskManager_DeleteTaskList_Call 

type TaskManager_DeleteTaskList_Call struct {
	*mock.Call
}

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

func (*TaskManager_DeleteTaskList_Call) Return 

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

func (*TaskManager_DeleteTaskList_Call) Run 

func (_c *TaskManager_DeleteTaskList_Call) Run(run func(ctx context.Context, request *persistence.DeleteTaskListRequest)) *TaskManager_DeleteTaskList_Call

func (*TaskManager_DeleteTaskList_Call) RunAndReturn 

func (_c *TaskManager_DeleteTaskList_Call) RunAndReturn(run func(ctx context.Context, request *persistence.DeleteTaskListRequest) error) *TaskManager_DeleteTaskList_Call

type TaskManager_Expecter 

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

func (*TaskManager_Expecter) Close 

func (_e *TaskManager_Expecter) Close() *TaskManager_Close_Call

Close is a helper method to define mock.On call

func (*TaskManager_Expecter) CompleteTask 

func (_e *TaskManager_Expecter) CompleteTask(ctx interface{}, request interface{}) *TaskManager_CompleteTask_Call

CompleteTask is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CompleteTaskRequest

func (*TaskManager_Expecter) CompleteTasksLessThan 

func (_e *TaskManager_Expecter) CompleteTasksLessThan(ctx interface{}, request interface{}) *TaskManager_CompleteTasksLessThan_Call

CompleteTasksLessThan is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CompleteTasksLessThanRequest

func (*TaskManager_Expecter) CreateTasks 

func (_e *TaskManager_Expecter) CreateTasks(ctx interface{}, request interface{}) *TaskManager_CreateTasks_Call

CreateTasks is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CreateTasksRequest

func (*TaskManager_Expecter) DeleteTaskList 

func (_e *TaskManager_Expecter) DeleteTaskList(ctx interface{}, request interface{}) *TaskManager_DeleteTaskList_Call

DeleteTaskList is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.DeleteTaskListRequest

func (*TaskManager_Expecter) GetName 

func (_e *TaskManager_Expecter) GetName() *TaskManager_GetName_Call

GetName is a helper method to define mock.On call

func (*TaskManager_Expecter) GetOrphanTasks 

func (_e *TaskManager_Expecter) GetOrphanTasks(ctx interface{}, request interface{}) *TaskManager_GetOrphanTasks_Call

GetOrphanTasks is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetOrphanTasksRequest

func (*TaskManager_Expecter) GetTaskList 

func (_e *TaskManager_Expecter) GetTaskList(ctx interface{}, request interface{}) *TaskManager_GetTaskList_Call

GetTaskList is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetTaskListRequest

func (*TaskManager_Expecter) GetTaskListSize 

func (_e *TaskManager_Expecter) GetTaskListSize(ctx interface{}, request interface{}) *TaskManager_GetTaskListSize_Call

GetTaskListSize is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetTaskListSizeRequest

func (*TaskManager_Expecter) GetTasks 

func (_e *TaskManager_Expecter) GetTasks(ctx interface{}, request interface{}) *TaskManager_GetTasks_Call

GetTasks is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetTasksRequest

func (*TaskManager_Expecter) LeaseTaskList 

func (_e *TaskManager_Expecter) LeaseTaskList(ctx interface{}, request interface{}) *TaskManager_LeaseTaskList_Call

LeaseTaskList is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.LeaseTaskListRequest

func (*TaskManager_Expecter) ListTaskList 

func (_e *TaskManager_Expecter) ListTaskList(ctx interface{}, request interface{}) *TaskManager_ListTaskList_Call

ListTaskList is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListTaskListRequest

func (*TaskManager_Expecter) UpdateTaskList 

func (_e *TaskManager_Expecter) UpdateTaskList(ctx interface{}, request interface{}) *TaskManager_UpdateTaskList_Call

UpdateTaskList is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.UpdateTaskListRequest

type TaskManager_GetName_Call 

type TaskManager_GetName_Call struct {
	*mock.Call
}

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

func (*TaskManager_GetName_Call) Return 

func (_c *TaskManager_GetName_Call) Return(s string) *TaskManager_GetName_Call

func (*TaskManager_GetName_Call) Run 

func (_c *TaskManager_GetName_Call) Run(run func()) *TaskManager_GetName_Call

func (*TaskManager_GetName_Call) RunAndReturn 

func (_c *TaskManager_GetName_Call) RunAndReturn(run func() string) *TaskManager_GetName_Call

type TaskManager_GetOrphanTasks_Call 

type TaskManager_GetOrphanTasks_Call struct {
	*mock.Call
}

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

func (*TaskManager_GetOrphanTasks_Call) Return 

func (_c *TaskManager_GetOrphanTasks_Call) Return(getOrphanTasksResponse *persistence.GetOrphanTasksResponse, err error) *TaskManager_GetOrphanTasks_Call

func (*TaskManager_GetOrphanTasks_Call) Run 

func (_c *TaskManager_GetOrphanTasks_Call) Run(run func(ctx context.Context, request *persistence.GetOrphanTasksRequest)) *TaskManager_GetOrphanTasks_Call

func (*TaskManager_GetOrphanTasks_Call) RunAndReturn 

func (_c *TaskManager_GetOrphanTasks_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetOrphanTasksRequest) (*persistence.GetOrphanTasksResponse, error)) *TaskManager_GetOrphanTasks_Call

type TaskManager_GetTaskListSize_Call 

type TaskManager_GetTaskListSize_Call struct {
	*mock.Call
}

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

func (*TaskManager_GetTaskListSize_Call) Return 

func (_c *TaskManager_GetTaskListSize_Call) Return(getTaskListSizeResponse *persistence.GetTaskListSizeResponse, err error) *TaskManager_GetTaskListSize_Call

func (*TaskManager_GetTaskListSize_Call) Run 

func (_c *TaskManager_GetTaskListSize_Call) Run(run func(ctx context.Context, request *persistence.GetTaskListSizeRequest)) *TaskManager_GetTaskListSize_Call

func (*TaskManager_GetTaskListSize_Call) RunAndReturn 

func (_c *TaskManager_GetTaskListSize_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetTaskListSizeRequest) (*persistence.GetTaskListSizeResponse, error)) *TaskManager_GetTaskListSize_Call

type TaskManager_GetTaskList_Call 

type TaskManager_GetTaskList_Call struct {
	*mock.Call
}

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

func (*TaskManager_GetTaskList_Call) Return 

func (_c *TaskManager_GetTaskList_Call) Return(getTaskListResponse *persistence.GetTaskListResponse, err error) *TaskManager_GetTaskList_Call

func (*TaskManager_GetTaskList_Call) Run 

func (_c *TaskManager_GetTaskList_Call) Run(run func(ctx context.Context, request *persistence.GetTaskListRequest)) *TaskManager_GetTaskList_Call

func (*TaskManager_GetTaskList_Call) RunAndReturn 

func (_c *TaskManager_GetTaskList_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetTaskListRequest) (*persistence.GetTaskListResponse, error)) *TaskManager_GetTaskList_Call

type TaskManager_GetTasks_Call 

type TaskManager_GetTasks_Call struct {
	*mock.Call
}

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

func (*TaskManager_GetTasks_Call) Return 

func (_c *TaskManager_GetTasks_Call) Return(getTasksResponse *persistence.GetTasksResponse, err error) *TaskManager_GetTasks_Call

func (*TaskManager_GetTasks_Call) Run 

func (_c *TaskManager_GetTasks_Call) Run(run func(ctx context.Context, request *persistence.GetTasksRequest)) *TaskManager_GetTasks_Call

func (*TaskManager_GetTasks_Call) RunAndReturn 

func (_c *TaskManager_GetTasks_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)) *TaskManager_GetTasks_Call

type TaskManager_LeaseTaskList_Call 

type TaskManager_LeaseTaskList_Call struct {
	*mock.Call
}

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

func (*TaskManager_LeaseTaskList_Call) Return 

func (_c *TaskManager_LeaseTaskList_Call) Return(leaseTaskListResponse *persistence.LeaseTaskListResponse, err error) *TaskManager_LeaseTaskList_Call

func (*TaskManager_LeaseTaskList_Call) Run 

func (_c *TaskManager_LeaseTaskList_Call) Run(run func(ctx context.Context, request *persistence.LeaseTaskListRequest)) *TaskManager_LeaseTaskList_Call

func (*TaskManager_LeaseTaskList_Call) RunAndReturn 

func (_c *TaskManager_LeaseTaskList_Call) RunAndReturn(run func(ctx context.Context, request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)) *TaskManager_LeaseTaskList_Call

type TaskManager_ListTaskList_Call 

type TaskManager_ListTaskList_Call struct {
	*mock.Call
}

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

func (*TaskManager_ListTaskList_Call) Return 

func (_c *TaskManager_ListTaskList_Call) Return(listTaskListResponse *persistence.ListTaskListResponse, err error) *TaskManager_ListTaskList_Call

func (*TaskManager_ListTaskList_Call) Run 

func (_c *TaskManager_ListTaskList_Call) Run(run func(ctx context.Context, request *persistence.ListTaskListRequest)) *TaskManager_ListTaskList_Call

func (*TaskManager_ListTaskList_Call) RunAndReturn 

func (_c *TaskManager_ListTaskList_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListTaskListRequest) (*persistence.ListTaskListResponse, error)) *TaskManager_ListTaskList_Call

type TaskManager_UpdateTaskList_Call 

type TaskManager_UpdateTaskList_Call struct {
	*mock.Call
}

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

func (*TaskManager_UpdateTaskList_Call) Return 

func (_c *TaskManager_UpdateTaskList_Call) Return(updateTaskListResponse *persistence.UpdateTaskListResponse, err error) *TaskManager_UpdateTaskList_Call

func (*TaskManager_UpdateTaskList_Call) Run 

func (_c *TaskManager_UpdateTaskList_Call) Run(run func(ctx context.Context, request *persistence.UpdateTaskListRequest)) *TaskManager_UpdateTaskList_Call

func (*TaskManager_UpdateTaskList_Call) RunAndReturn 

func (_c *TaskManager_UpdateTaskList_Call) RunAndReturn(run func(ctx context.Context, request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)) *TaskManager_UpdateTaskList_Call

type VisibilityManager 

type VisibilityManager struct {
	mock.Mock
}

VisibilityManager is an autogenerated mock type for the VisibilityManager type

func NewVisibilityManager added in v1.2.11 

func NewVisibilityManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *VisibilityManager

NewVisibilityManager creates a new instance of VisibilityManager. 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 (*VisibilityManager) Close 

func (_mock *VisibilityManager) Close()

Close provides a mock function for the type VisibilityManager

func (*VisibilityManager) CountWorkflowExecutions added in v0.5.8 

func (_mock *VisibilityManager) CountWorkflowExecutions(ctx context.Context, request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions provides a mock function for the type VisibilityManager

func (*VisibilityManager) DeleteUninitializedWorkflowExecution added in v1.0.0 

func (_mock *VisibilityManager) DeleteUninitializedWorkflowExecution(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

DeleteUninitializedWorkflowExecution provides a mock function for the type VisibilityManager

func (*VisibilityManager) DeleteWorkflowExecution added in v0.5.7 

func (_mock *VisibilityManager) DeleteWorkflowExecution(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function for the type VisibilityManager

func (*VisibilityManager) EXPECT 

func (_m *VisibilityManager) EXPECT() *VisibilityManager_Expecter

func (*VisibilityManager) GetClosedWorkflowExecution 

func (_mock *VisibilityManager) GetClosedWorkflowExecution(ctx context.Context, request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)

GetClosedWorkflowExecution provides a mock function for the type VisibilityManager

func (*VisibilityManager) GetName added in v0.4.0 

func (_mock *VisibilityManager) GetName() string

GetName provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListClosedWorkflowExecutions 

func (_mock *VisibilityManager) ListClosedWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus 

func (_mock *VisibilityManager) ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListClosedWorkflowExecutionsByType 

func (_mock *VisibilityManager) ListClosedWorkflowExecutionsByType(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

func (_mock *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListOpenWorkflowExecutions 

func (_mock *VisibilityManager) ListOpenWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListOpenWorkflowExecutionsByType 

func (_mock *VisibilityManager) ListOpenWorkflowExecutionsByType(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

func (_mock *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID provides a mock function for the type VisibilityManager

func (*VisibilityManager) ListWorkflowExecutions added in v0.5.7 

func (_mock *VisibilityManager) ListWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions provides a mock function for the type VisibilityManager

func (*VisibilityManager) RecordWorkflowExecutionClosed 

func (_mock *VisibilityManager) RecordWorkflowExecutionClosed(ctx context.Context, request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed provides a mock function for the type VisibilityManager

func (*VisibilityManager) RecordWorkflowExecutionStarted 

func (_mock *VisibilityManager) RecordWorkflowExecutionStarted(ctx context.Context, request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted provides a mock function for the type VisibilityManager

func (*VisibilityManager) RecordWorkflowExecutionUninitialized added in v0.25.0 

func (_mock *VisibilityManager) RecordWorkflowExecutionUninitialized(ctx context.Context, request *persistence.RecordWorkflowExecutionUninitializedRequest) error

RecordWorkflowExecutionUninitialized provides a mock function for the type VisibilityManager

func (*VisibilityManager) ScanWorkflowExecutions added in v0.5.8 

func (_mock *VisibilityManager) ScanWorkflowExecutions(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions provides a mock function for the type VisibilityManager

func (*VisibilityManager) UpsertWorkflowExecution added in v0.6.0 

func (_mock *VisibilityManager) UpsertWorkflowExecution(ctx context.Context, request *persistence.UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution provides a mock function for the type VisibilityManager

type VisibilityManager_Close_Call 

type VisibilityManager_Close_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_Close_Call) Return 

func (_c *VisibilityManager_Close_Call) Return() *VisibilityManager_Close_Call

func (*VisibilityManager_Close_Call) Run 

func (_c *VisibilityManager_Close_Call) Run(run func()) *VisibilityManager_Close_Call

func (*VisibilityManager_Close_Call) RunAndReturn 

func (_c *VisibilityManager_Close_Call) RunAndReturn(run func()) *VisibilityManager_Close_Call

type VisibilityManager_CountWorkflowExecutions_Call 

type VisibilityManager_CountWorkflowExecutions_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_CountWorkflowExecutions_Call) Return 

func (_c *VisibilityManager_CountWorkflowExecutions_Call) Return(countWorkflowExecutionsResponse *persistence.CountWorkflowExecutionsResponse, err error) *VisibilityManager_CountWorkflowExecutions_Call

func (*VisibilityManager_CountWorkflowExecutions_Call) Run 

func (_c *VisibilityManager_CountWorkflowExecutions_Call) Run(run func(ctx context.Context, request *persistence.CountWorkflowExecutionsRequest)) *VisibilityManager_CountWorkflowExecutions_Call

func (*VisibilityManager_CountWorkflowExecutions_Call) RunAndReturn 

func (_c *VisibilityManager_CountWorkflowExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)) *VisibilityManager_CountWorkflowExecutions_Call

type VisibilityManager_DeleteUninitializedWorkflowExecution_Call 

type VisibilityManager_DeleteUninitializedWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_DeleteUninitializedWorkflowExecution_Call) Return 

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

func (*VisibilityManager_DeleteUninitializedWorkflowExecution_Call) Run 

func (_c *VisibilityManager_DeleteUninitializedWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest)) *VisibilityManager_DeleteUninitializedWorkflowExecution_Call

func (*VisibilityManager_DeleteUninitializedWorkflowExecution_Call) RunAndReturn 

func (_c *VisibilityManager_DeleteUninitializedWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error) *VisibilityManager_DeleteUninitializedWorkflowExecution_Call

type VisibilityManager_DeleteWorkflowExecution_Call 

type VisibilityManager_DeleteWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_DeleteWorkflowExecution_Call) Return 

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

func (*VisibilityManager_DeleteWorkflowExecution_Call) Run 

func (_c *VisibilityManager_DeleteWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest)) *VisibilityManager_DeleteWorkflowExecution_Call

func (*VisibilityManager_DeleteWorkflowExecution_Call) RunAndReturn 

func (_c *VisibilityManager_DeleteWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.VisibilityDeleteWorkflowExecutionRequest) error) *VisibilityManager_DeleteWorkflowExecution_Call

type VisibilityManager_Expecter 

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

func (*VisibilityManager_Expecter) Close 

func (_e *VisibilityManager_Expecter) Close() *VisibilityManager_Close_Call

Close is a helper method to define mock.On call

func (*VisibilityManager_Expecter) CountWorkflowExecutions 

func (_e *VisibilityManager_Expecter) CountWorkflowExecutions(ctx interface{}, request interface{}) *VisibilityManager_CountWorkflowExecutions_Call

CountWorkflowExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.CountWorkflowExecutionsRequest

func (*VisibilityManager_Expecter) DeleteUninitializedWorkflowExecution 

func (_e *VisibilityManager_Expecter) DeleteUninitializedWorkflowExecution(ctx interface{}, request interface{}) *VisibilityManager_DeleteUninitializedWorkflowExecution_Call

DeleteUninitializedWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.VisibilityDeleteWorkflowExecutionRequest

func (*VisibilityManager_Expecter) DeleteWorkflowExecution 

func (_e *VisibilityManager_Expecter) DeleteWorkflowExecution(ctx interface{}, request interface{}) *VisibilityManager_DeleteWorkflowExecution_Call

DeleteWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.VisibilityDeleteWorkflowExecutionRequest

func (*VisibilityManager_Expecter) GetClosedWorkflowExecution 

func (_e *VisibilityManager_Expecter) GetClosedWorkflowExecution(ctx interface{}, request interface{}) *VisibilityManager_GetClosedWorkflowExecution_Call

GetClosedWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.GetClosedWorkflowExecutionRequest

func (*VisibilityManager_Expecter) GetName 

func (_e *VisibilityManager_Expecter) GetName() *VisibilityManager_GetName_Call

GetName is a helper method to define mock.On call

func (*VisibilityManager_Expecter) ListClosedWorkflowExecutions 

func (_e *VisibilityManager_Expecter) ListClosedWorkflowExecutions(ctx interface{}, request interface{}) *VisibilityManager_ListClosedWorkflowExecutions_Call

ListClosedWorkflowExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsRequest

func (*VisibilityManager_Expecter) ListClosedWorkflowExecutionsByStatus 

func (_e *VisibilityManager_Expecter) ListClosedWorkflowExecutionsByStatus(ctx interface{}, request interface{}) *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call

ListClosedWorkflowExecutionsByStatus is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListClosedWorkflowExecutionsByStatusRequest

func (*VisibilityManager_Expecter) ListClosedWorkflowExecutionsByType 

func (_e *VisibilityManager_Expecter) ListClosedWorkflowExecutionsByType(ctx interface{}, request interface{}) *VisibilityManager_ListClosedWorkflowExecutionsByType_Call

ListClosedWorkflowExecutionsByType is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByTypeRequest

func (*VisibilityManager_Expecter) ListClosedWorkflowExecutionsByWorkflowID 

func (_e *VisibilityManager_Expecter) ListClosedWorkflowExecutionsByWorkflowID(ctx interface{}, request interface{}) *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call

ListClosedWorkflowExecutionsByWorkflowID is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByWorkflowIDRequest

func (*VisibilityManager_Expecter) ListOpenWorkflowExecutions 

func (_e *VisibilityManager_Expecter) ListOpenWorkflowExecutions(ctx interface{}, request interface{}) *VisibilityManager_ListOpenWorkflowExecutions_Call

ListOpenWorkflowExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsRequest

func (*VisibilityManager_Expecter) ListOpenWorkflowExecutionsByType 

func (_e *VisibilityManager_Expecter) ListOpenWorkflowExecutionsByType(ctx interface{}, request interface{}) *VisibilityManager_ListOpenWorkflowExecutionsByType_Call

ListOpenWorkflowExecutionsByType is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByTypeRequest

func (*VisibilityManager_Expecter) ListOpenWorkflowExecutionsByWorkflowID 

func (_e *VisibilityManager_Expecter) ListOpenWorkflowExecutionsByWorkflowID(ctx interface{}, request interface{}) *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call

ListOpenWorkflowExecutionsByWorkflowID is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByWorkflowIDRequest

func (*VisibilityManager_Expecter) ListWorkflowExecutions 

func (_e *VisibilityManager_Expecter) ListWorkflowExecutions(ctx interface{}, request interface{}) *VisibilityManager_ListWorkflowExecutions_Call

ListWorkflowExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByQueryRequest

func (*VisibilityManager_Expecter) RecordWorkflowExecutionClosed 

func (_e *VisibilityManager_Expecter) RecordWorkflowExecutionClosed(ctx interface{}, request interface{}) *VisibilityManager_RecordWorkflowExecutionClosed_Call

RecordWorkflowExecutionClosed is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.RecordWorkflowExecutionClosedRequest

func (*VisibilityManager_Expecter) RecordWorkflowExecutionStarted 

func (_e *VisibilityManager_Expecter) RecordWorkflowExecutionStarted(ctx interface{}, request interface{}) *VisibilityManager_RecordWorkflowExecutionStarted_Call

RecordWorkflowExecutionStarted is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.RecordWorkflowExecutionStartedRequest

func (*VisibilityManager_Expecter) RecordWorkflowExecutionUninitialized 

func (_e *VisibilityManager_Expecter) RecordWorkflowExecutionUninitialized(ctx interface{}, request interface{}) *VisibilityManager_RecordWorkflowExecutionUninitialized_Call

RecordWorkflowExecutionUninitialized is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.RecordWorkflowExecutionUninitializedRequest

func (*VisibilityManager_Expecter) ScanWorkflowExecutions 

func (_e *VisibilityManager_Expecter) ScanWorkflowExecutions(ctx interface{}, request interface{}) *VisibilityManager_ScanWorkflowExecutions_Call

ScanWorkflowExecutions is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.ListWorkflowExecutionsByQueryRequest

func (*VisibilityManager_Expecter) UpsertWorkflowExecution 

func (_e *VisibilityManager_Expecter) UpsertWorkflowExecution(ctx interface{}, request interface{}) *VisibilityManager_UpsertWorkflowExecution_Call

UpsertWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *persistence.UpsertWorkflowExecutionRequest

type VisibilityManager_GetClosedWorkflowExecution_Call 

type VisibilityManager_GetClosedWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_GetClosedWorkflowExecution_Call) Return 

func (_c *VisibilityManager_GetClosedWorkflowExecution_Call) Return(getClosedWorkflowExecutionResponse *persistence.GetClosedWorkflowExecutionResponse, err error) *VisibilityManager_GetClosedWorkflowExecution_Call

func (*VisibilityManager_GetClosedWorkflowExecution_Call) Run 

func (_c *VisibilityManager_GetClosedWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.GetClosedWorkflowExecutionRequest)) *VisibilityManager_GetClosedWorkflowExecution_Call

func (*VisibilityManager_GetClosedWorkflowExecution_Call) RunAndReturn 

func (_c *VisibilityManager_GetClosedWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)) *VisibilityManager_GetClosedWorkflowExecution_Call

type VisibilityManager_GetName_Call 

type VisibilityManager_GetName_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_GetName_Call) Return 

func (_c *VisibilityManager_GetName_Call) Return(s string) *VisibilityManager_GetName_Call

func (*VisibilityManager_GetName_Call) Run 

func (_c *VisibilityManager_GetName_Call) Run(run func()) *VisibilityManager_GetName_Call

func (*VisibilityManager_GetName_Call) RunAndReturn 

func (_c *VisibilityManager_GetName_Call) RunAndReturn(run func() string) *VisibilityManager_GetName_Call

type VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call 

type VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) Return 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) Run 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) Run(run func(ctx context.Context, request *persistence.ListClosedWorkflowExecutionsByStatusRequest)) *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) RunAndReturn 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListClosedWorkflowExecutionsByStatus_Call

type VisibilityManager_ListClosedWorkflowExecutionsByType_Call 

type VisibilityManager_ListClosedWorkflowExecutionsByType_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListClosedWorkflowExecutionsByType_Call) Return 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByType_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListClosedWorkflowExecutionsByType_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByType_Call) Run 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByType_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest)) *VisibilityManager_ListClosedWorkflowExecutionsByType_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByType_Call) RunAndReturn 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByType_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListClosedWorkflowExecutionsByType_Call

type VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call 

type VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) Return 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) Run 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest)) *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call

func (*VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) RunAndReturn 

func (_c *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListClosedWorkflowExecutionsByWorkflowID_Call

type VisibilityManager_ListClosedWorkflowExecutions_Call 

type VisibilityManager_ListClosedWorkflowExecutions_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListClosedWorkflowExecutions_Call) Return 

func (_c *VisibilityManager_ListClosedWorkflowExecutions_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListClosedWorkflowExecutions_Call

func (*VisibilityManager_ListClosedWorkflowExecutions_Call) Run 

func (_c *VisibilityManager_ListClosedWorkflowExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest)) *VisibilityManager_ListClosedWorkflowExecutions_Call

func (*VisibilityManager_ListClosedWorkflowExecutions_Call) RunAndReturn 

func (_c *VisibilityManager_ListClosedWorkflowExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListClosedWorkflowExecutions_Call

type VisibilityManager_ListOpenWorkflowExecutionsByType_Call 

type VisibilityManager_ListOpenWorkflowExecutionsByType_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListOpenWorkflowExecutionsByType_Call) Return 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByType_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListOpenWorkflowExecutionsByType_Call

func (*VisibilityManager_ListOpenWorkflowExecutionsByType_Call) Run 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByType_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest)) *VisibilityManager_ListOpenWorkflowExecutionsByType_Call

func (*VisibilityManager_ListOpenWorkflowExecutionsByType_Call) RunAndReturn 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByType_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListOpenWorkflowExecutionsByType_Call

type VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call 

type VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) Return 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call

func (*VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) Run 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest)) *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call

func (*VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) RunAndReturn 

func (_c *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListOpenWorkflowExecutionsByWorkflowID_Call

type VisibilityManager_ListOpenWorkflowExecutions_Call 

type VisibilityManager_ListOpenWorkflowExecutions_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListOpenWorkflowExecutions_Call) Return 

func (_c *VisibilityManager_ListOpenWorkflowExecutions_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListOpenWorkflowExecutions_Call

func (*VisibilityManager_ListOpenWorkflowExecutions_Call) Run 

func (_c *VisibilityManager_ListOpenWorkflowExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest)) *VisibilityManager_ListOpenWorkflowExecutions_Call

func (*VisibilityManager_ListOpenWorkflowExecutions_Call) RunAndReturn 

func (_c *VisibilityManager_ListOpenWorkflowExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListOpenWorkflowExecutions_Call

type VisibilityManager_ListWorkflowExecutions_Call 

type VisibilityManager_ListWorkflowExecutions_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ListWorkflowExecutions_Call) Return 

func (_c *VisibilityManager_ListWorkflowExecutions_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ListWorkflowExecutions_Call

func (*VisibilityManager_ListWorkflowExecutions_Call) Run 

func (_c *VisibilityManager_ListWorkflowExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest)) *VisibilityManager_ListWorkflowExecutions_Call

func (*VisibilityManager_ListWorkflowExecutions_Call) RunAndReturn 

func (_c *VisibilityManager_ListWorkflowExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ListWorkflowExecutions_Call

type VisibilityManager_RecordWorkflowExecutionClosed_Call 

type VisibilityManager_RecordWorkflowExecutionClosed_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_RecordWorkflowExecutionClosed_Call) Return 

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

func (*VisibilityManager_RecordWorkflowExecutionClosed_Call) Run 

func (_c *VisibilityManager_RecordWorkflowExecutionClosed_Call) Run(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionClosedRequest)) *VisibilityManager_RecordWorkflowExecutionClosed_Call

func (*VisibilityManager_RecordWorkflowExecutionClosed_Call) RunAndReturn 

func (_c *VisibilityManager_RecordWorkflowExecutionClosed_Call) RunAndReturn(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionClosedRequest) error) *VisibilityManager_RecordWorkflowExecutionClosed_Call

type VisibilityManager_RecordWorkflowExecutionStarted_Call 

type VisibilityManager_RecordWorkflowExecutionStarted_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_RecordWorkflowExecutionStarted_Call) Return 

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

func (*VisibilityManager_RecordWorkflowExecutionStarted_Call) Run 

func (_c *VisibilityManager_RecordWorkflowExecutionStarted_Call) Run(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionStartedRequest)) *VisibilityManager_RecordWorkflowExecutionStarted_Call

func (*VisibilityManager_RecordWorkflowExecutionStarted_Call) RunAndReturn 

func (_c *VisibilityManager_RecordWorkflowExecutionStarted_Call) RunAndReturn(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionStartedRequest) error) *VisibilityManager_RecordWorkflowExecutionStarted_Call

type VisibilityManager_RecordWorkflowExecutionUninitialized_Call 

type VisibilityManager_RecordWorkflowExecutionUninitialized_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_RecordWorkflowExecutionUninitialized_Call) Return 

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

func (*VisibilityManager_RecordWorkflowExecutionUninitialized_Call) Run 

func (_c *VisibilityManager_RecordWorkflowExecutionUninitialized_Call) Run(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionUninitializedRequest)) *VisibilityManager_RecordWorkflowExecutionUninitialized_Call

func (*VisibilityManager_RecordWorkflowExecutionUninitialized_Call) RunAndReturn 

func (_c *VisibilityManager_RecordWorkflowExecutionUninitialized_Call) RunAndReturn(run func(ctx context.Context, request *persistence.RecordWorkflowExecutionUninitializedRequest) error) *VisibilityManager_RecordWorkflowExecutionUninitialized_Call

type VisibilityManager_ScanWorkflowExecutions_Call 

type VisibilityManager_ScanWorkflowExecutions_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_ScanWorkflowExecutions_Call) Return 

func (_c *VisibilityManager_ScanWorkflowExecutions_Call) Return(listWorkflowExecutionsResponse *persistence.ListWorkflowExecutionsResponse, err error) *VisibilityManager_ScanWorkflowExecutions_Call

func (*VisibilityManager_ScanWorkflowExecutions_Call) Run 

func (_c *VisibilityManager_ScanWorkflowExecutions_Call) Run(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest)) *VisibilityManager_ScanWorkflowExecutions_Call

func (*VisibilityManager_ScanWorkflowExecutions_Call) RunAndReturn 

func (_c *VisibilityManager_ScanWorkflowExecutions_Call) RunAndReturn(run func(ctx context.Context, request *persistence.ListWorkflowExecutionsByQueryRequest) (*persistence.ListWorkflowExecutionsResponse, error)) *VisibilityManager_ScanWorkflowExecutions_Call

type VisibilityManager_UpsertWorkflowExecution_Call 

type VisibilityManager_UpsertWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*VisibilityManager_UpsertWorkflowExecution_Call) Return 

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

func (*VisibilityManager_UpsertWorkflowExecution_Call) Run 

func (_c *VisibilityManager_UpsertWorkflowExecution_Call) Run(run func(ctx context.Context, request *persistence.UpsertWorkflowExecutionRequest)) *VisibilityManager_UpsertWorkflowExecution_Call

func (*VisibilityManager_UpsertWorkflowExecution_Call) RunAndReturn 

func (_c *VisibilityManager_UpsertWorkflowExecution_Call) RunAndReturn(run func(ctx context.Context, request *persistence.UpsertWorkflowExecutionRequest) error) *VisibilityManager_UpsertWorkflowExecution_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

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