mock

package
v1.14.4 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClusterMetadataStore 

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

MockClusterMetadataStore is a mock of ClusterMetadataStore interface.

func NewMockClusterMetadataStore 

func NewMockClusterMetadataStore(ctrl *gomock.Controller) *MockClusterMetadataStore

NewMockClusterMetadataStore creates a new mock instance.

func (*MockClusterMetadataStore) Close 

func (m *MockClusterMetadataStore) Close()

Close mocks base method.

func (*MockClusterMetadataStore) DeleteClusterMetadata added in v1.14.0 

func (m *MockClusterMetadataStore) DeleteClusterMetadata(request *persistence.InternalDeleteClusterMetadataRequest) error

DeleteClusterMetadata mocks base method.

func (*MockClusterMetadataStore) EXPECT 

func (m *MockClusterMetadataStore) EXPECT() *MockClusterMetadataStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClusterMetadataStore) GetClusterMembers 

func (m *MockClusterMetadataStore) GetClusterMembers(request *persistence.GetClusterMembersRequest) (*persistence.GetClusterMembersResponse, error)

GetClusterMembers mocks base method.

func (*MockClusterMetadataStore) GetClusterMetadata 

func (m *MockClusterMetadataStore) GetClusterMetadata(request *persistence.InternalGetClusterMetadataRequest) (*persistence.InternalGetClusterMetadataResponse, error)

GetClusterMetadata mocks base method.

func (*MockClusterMetadataStore) GetClusterMetadataV1 added in v1.14.0 

func (m *MockClusterMetadataStore) GetClusterMetadataV1() (*persistence.InternalGetClusterMetadataResponse, error)

GetClusterMetadataV1 mocks base method.

func (*MockClusterMetadataStore) GetName 

func (m *MockClusterMetadataStore) GetName() string

GetName mocks base method.

func (*MockClusterMetadataStore) ListClusterMetadata added in v1.14.0 

func (m *MockClusterMetadataStore) ListClusterMetadata(request *persistence.InternalListClusterMetadataRequest) (*persistence.InternalListClusterMetadataResponse, error)

ListClusterMetadata mocks base method.

func (*MockClusterMetadataStore) PruneClusterMembership 

func (m *MockClusterMetadataStore) PruneClusterMembership(request *persistence.PruneClusterMembershipRequest) error

PruneClusterMembership mocks base method.

func (*MockClusterMetadataStore) SaveClusterMetadata 

func (m *MockClusterMetadataStore) SaveClusterMetadata(request *persistence.InternalSaveClusterMetadataRequest) (bool, error)

SaveClusterMetadata mocks base method.

func (*MockClusterMetadataStore) SaveClusterMetadataV1 added in v1.14.0 

func (m *MockClusterMetadataStore) SaveClusterMetadataV1(request *persistence.InternalSaveClusterMetadataRequest) (bool, error)

SaveClusterMetadataV1 mocks base method.

func (*MockClusterMetadataStore) UpsertClusterMembership 

func (m *MockClusterMetadataStore) UpsertClusterMembership(request *persistence.UpsertClusterMembershipRequest) error

UpsertClusterMembership mocks base method.

type MockClusterMetadataStoreMockRecorder 

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

MockClusterMetadataStoreMockRecorder is the mock recorder for MockClusterMetadataStore.

func (*MockClusterMetadataStoreMockRecorder) Close 

func (mr *MockClusterMetadataStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClusterMetadataStoreMockRecorder) DeleteClusterMetadata added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) DeleteClusterMetadata(request interface{}) *gomock.Call

DeleteClusterMetadata indicates an expected call of DeleteClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMembers 

func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMembers(request interface{}) *gomock.Call

GetClusterMembers indicates an expected call of GetClusterMembers.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMetadata 

func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMetadata(request interface{}) *gomock.Call

GetClusterMetadata indicates an expected call of GetClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMetadataV1 added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMetadataV1() *gomock.Call

GetClusterMetadataV1 indicates an expected call of GetClusterMetadataV1.

func (*MockClusterMetadataStoreMockRecorder) GetName 

func (mr *MockClusterMetadataStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockClusterMetadataStoreMockRecorder) ListClusterMetadata added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) ListClusterMetadata(request interface{}) *gomock.Call

ListClusterMetadata indicates an expected call of ListClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) PruneClusterMembership 

func (mr *MockClusterMetadataStoreMockRecorder) PruneClusterMembership(request interface{}) *gomock.Call

PruneClusterMembership indicates an expected call of PruneClusterMembership.

func (*MockClusterMetadataStoreMockRecorder) SaveClusterMetadata 

func (mr *MockClusterMetadataStoreMockRecorder) SaveClusterMetadata(request interface{}) *gomock.Call

SaveClusterMetadata indicates an expected call of SaveClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) SaveClusterMetadataV1 added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) SaveClusterMetadataV1(request interface{}) *gomock.Call

SaveClusterMetadataV1 indicates an expected call of SaveClusterMetadataV1.

func (*MockClusterMetadataStoreMockRecorder) UpsertClusterMembership 

func (mr *MockClusterMetadataStoreMockRecorder) UpsertClusterMembership(request interface{}) *gomock.Call

UpsertClusterMembership indicates an expected call of UpsertClusterMembership.

type MockExecutionStore 

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

MockExecutionStore is a mock of ExecutionStore interface.

func NewMockExecutionStore 

func NewMockExecutionStore(ctrl *gomock.Controller) *MockExecutionStore

NewMockExecutionStore creates a new mock instance.

func (*MockExecutionStore) AddTasks 

func (m *MockExecutionStore) AddTasks(request *persistence.InternalAddTasksRequest) error

AddTasks mocks base method.

func (*MockExecutionStore) AppendHistoryNodes added in v1.12.0 

func (m *MockExecutionStore) AppendHistoryNodes(request *persistence.InternalAppendHistoryNodesRequest) error

AppendHistoryNodes mocks base method.

func (*MockExecutionStore) Close 

func (m *MockExecutionStore) Close()

Close mocks base method.

func (*MockExecutionStore) CompleteReplicationTask 

func (m *MockExecutionStore) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask mocks base method.

func (*MockExecutionStore) CompleteTieredStorageTask added in v1.14.0 

func (m *MockExecutionStore) CompleteTieredStorageTask(request *persistence.CompleteTieredStorageTaskRequest) error

CompleteTieredStorageTask mocks base method.

func (*MockExecutionStore) CompleteTimerTask 

func (m *MockExecutionStore) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask mocks base method.

func (*MockExecutionStore) CompleteTransferTask 

func (m *MockExecutionStore) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask mocks base method.

func (*MockExecutionStore) CompleteVisibilityTask 

func (m *MockExecutionStore) CompleteVisibilityTask(request *persistence.CompleteVisibilityTaskRequest) error

CompleteVisibilityTask mocks base method.

func (*MockExecutionStore) ConflictResolveWorkflowExecution 

func (m *MockExecutionStore) ConflictResolveWorkflowExecution(request *persistence.InternalConflictResolveWorkflowExecutionRequest) error

ConflictResolveWorkflowExecution mocks base method.

func (*MockExecutionStore) CreateWorkflowExecution 

func (m *MockExecutionStore) CreateWorkflowExecution(request *persistence.InternalCreateWorkflowExecutionRequest) (*persistence.InternalCreateWorkflowExecutionResponse, error)

CreateWorkflowExecution mocks base method.

func (*MockExecutionStore) DeleteCurrentWorkflowExecution 

func (m *MockExecutionStore) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution mocks base method.

func (*MockExecutionStore) DeleteHistoryBranch added in v1.12.0 

func (m *MockExecutionStore) DeleteHistoryBranch(request *persistence.InternalDeleteHistoryBranchRequest) error

DeleteHistoryBranch mocks base method.

func (*MockExecutionStore) DeleteHistoryNodes added in v1.12.0 

func (m *MockExecutionStore) DeleteHistoryNodes(request *persistence.InternalDeleteHistoryNodesRequest) error

DeleteHistoryNodes mocks base method.

func (*MockExecutionStore) DeleteReplicationTaskFromDLQ 

func (m *MockExecutionStore) DeleteReplicationTaskFromDLQ(request *persistence.DeleteReplicationTaskFromDLQRequest) error

DeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionStore) DeleteWorkflowExecution 

func (m *MockExecutionStore) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution mocks base method.

func (*MockExecutionStore) EXPECT 

func (m *MockExecutionStore) EXPECT() *MockExecutionStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockExecutionStore) ForkHistoryBranch added in v1.12.0 

func (m *MockExecutionStore) ForkHistoryBranch(request *persistence.InternalForkHistoryBranchRequest) error

ForkHistoryBranch mocks base method.

func (*MockExecutionStore) GetAllHistoryTreeBranches added in v1.12.0 

func (m *MockExecutionStore) GetAllHistoryTreeBranches(request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.InternalGetAllHistoryTreeBranchesResponse, error)

GetAllHistoryTreeBranches mocks base method.

func (*MockExecutionStore) GetCurrentExecution 

func (m *MockExecutionStore) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.InternalGetCurrentExecutionResponse, error)

GetCurrentExecution mocks base method.

func (*MockExecutionStore) GetHistoryTree added in v1.12.0 

func (m *MockExecutionStore) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.InternalGetHistoryTreeResponse, error)

GetHistoryTree mocks base method.

func (*MockExecutionStore) GetName 

func (m *MockExecutionStore) GetName() string

GetName mocks base method.

func (*MockExecutionStore) GetReplicationTask 

func (m *MockExecutionStore) GetReplicationTask(request *persistence.GetReplicationTaskRequest) (*persistence.InternalGetReplicationTaskResponse, error)

GetReplicationTask mocks base method.

func (*MockExecutionStore) GetReplicationTasks 

func (m *MockExecutionStore) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.InternalGetReplicationTasksResponse, error)

GetReplicationTasks mocks base method.

func (*MockExecutionStore) GetReplicationTasksFromDLQ 

func (m *MockExecutionStore) GetReplicationTasksFromDLQ(request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.InternalGetReplicationTasksFromDLQResponse, error)

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionStore) GetTieredStorageTask added in v1.14.0 

func (m *MockExecutionStore) GetTieredStorageTask(request *persistence.GetTieredStorageTaskRequest) (*persistence.InternalGetTieredStorageTaskResponse, error)

GetTieredStorageTask mocks base method.

func (*MockExecutionStore) GetTieredStorageTasks added in v1.14.0 

func (m *MockExecutionStore) GetTieredStorageTasks(request *persistence.GetTieredStorageTasksRequest) (*persistence.InternalGetTieredStorageTasksResponse, error)

GetTieredStorageTasks mocks base method.

func (*MockExecutionStore) GetTimerTask 

func (m *MockExecutionStore) GetTimerTask(request *persistence.GetTimerTaskRequest) (*persistence.InternalGetTimerTaskResponse, error)

GetTimerTask mocks base method.

func (*MockExecutionStore) GetTimerTasks added in v1.14.0 

func (m *MockExecutionStore) GetTimerTasks(request *persistence.GetTimerTasksRequest) (*persistence.InternalGetTimerTasksResponse, error)

GetTimerTasks mocks base method.

func (*MockExecutionStore) GetTransferTask 

func (m *MockExecutionStore) GetTransferTask(request *persistence.GetTransferTaskRequest) (*persistence.InternalGetTransferTaskResponse, error)

GetTransferTask mocks base method.

func (*MockExecutionStore) GetTransferTasks 

func (m *MockExecutionStore) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.InternalGetTransferTasksResponse, error)

GetTransferTasks mocks base method.

func (*MockExecutionStore) GetVisibilityTask 

func (m *MockExecutionStore) GetVisibilityTask(request *persistence.GetVisibilityTaskRequest) (*persistence.InternalGetVisibilityTaskResponse, error)

GetVisibilityTask mocks base method.

func (*MockExecutionStore) GetVisibilityTasks 

func (m *MockExecutionStore) GetVisibilityTasks(request *persistence.GetVisibilityTasksRequest) (*persistence.InternalGetVisibilityTasksResponse, error)

GetVisibilityTasks mocks base method.

func (*MockExecutionStore) GetWorkflowExecution 

func (m *MockExecutionStore) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.InternalGetWorkflowExecutionResponse, error)

GetWorkflowExecution mocks base method.

func (*MockExecutionStore) ListConcreteExecutions 

func (m *MockExecutionStore) ListConcreteExecutions(request *persistence.ListConcreteExecutionsRequest) (*persistence.InternalListConcreteExecutionsResponse, error)

ListConcreteExecutions mocks base method.

func (*MockExecutionStore) PutReplicationTaskToDLQ 

func (m *MockExecutionStore) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ mocks base method.

func (*MockExecutionStore) RangeCompleteReplicationTask 

func (m *MockExecutionStore) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

RangeCompleteReplicationTask mocks base method.

func (*MockExecutionStore) RangeCompleteTieredStorageTask added in v1.14.0 

func (m *MockExecutionStore) RangeCompleteTieredStorageTask(request *persistence.RangeCompleteTieredStorageTaskRequest) error

RangeCompleteTieredStorageTask mocks base method.

func (*MockExecutionStore) RangeCompleteTimerTask 

func (m *MockExecutionStore) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

RangeCompleteTimerTask mocks base method.

func (*MockExecutionStore) RangeCompleteTransferTask 

func (m *MockExecutionStore) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

RangeCompleteTransferTask mocks base method.

func (*MockExecutionStore) RangeCompleteVisibilityTask 

func (m *MockExecutionStore) RangeCompleteVisibilityTask(request *persistence.RangeCompleteVisibilityTaskRequest) error

RangeCompleteVisibilityTask mocks base method.

func (*MockExecutionStore) RangeDeleteReplicationTaskFromDLQ 

func (m *MockExecutionStore) RangeDeleteReplicationTaskFromDLQ(request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

RangeDeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionStore) ReadHistoryBranch added in v1.12.0 

func (m *MockExecutionStore) ReadHistoryBranch(request *persistence.InternalReadHistoryBranchRequest) (*persistence.InternalReadHistoryBranchResponse, error)

ReadHistoryBranch mocks base method.

func (*MockExecutionStore) UpdateWorkflowExecution 

func (m *MockExecutionStore) UpdateWorkflowExecution(request *persistence.InternalUpdateWorkflowExecutionRequest) error

UpdateWorkflowExecution mocks base method.

type MockExecutionStoreMockRecorder 

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

MockExecutionStoreMockRecorder is the mock recorder for MockExecutionStore.

func (*MockExecutionStoreMockRecorder) AddTasks 

func (mr *MockExecutionStoreMockRecorder) AddTasks(request interface{}) *gomock.Call

AddTasks indicates an expected call of AddTasks.

func (*MockExecutionStoreMockRecorder) AppendHistoryNodes added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) AppendHistoryNodes(request interface{}) *gomock.Call

AppendHistoryNodes indicates an expected call of AppendHistoryNodes.

func (*MockExecutionStoreMockRecorder) Close 

func (mr *MockExecutionStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockExecutionStoreMockRecorder) CompleteReplicationTask 

func (mr *MockExecutionStoreMockRecorder) CompleteReplicationTask(request interface{}) *gomock.Call

CompleteReplicationTask indicates an expected call of CompleteReplicationTask.

func (*MockExecutionStoreMockRecorder) CompleteTieredStorageTask added in v1.14.0 

func (mr *MockExecutionStoreMockRecorder) CompleteTieredStorageTask(request interface{}) *gomock.Call

CompleteTieredStorageTask indicates an expected call of CompleteTieredStorageTask.

func (*MockExecutionStoreMockRecorder) CompleteTimerTask 

func (mr *MockExecutionStoreMockRecorder) CompleteTimerTask(request interface{}) *gomock.Call

CompleteTimerTask indicates an expected call of CompleteTimerTask.

func (*MockExecutionStoreMockRecorder) CompleteTransferTask 

func (mr *MockExecutionStoreMockRecorder) CompleteTransferTask(request interface{}) *gomock.Call

CompleteTransferTask indicates an expected call of CompleteTransferTask.

func (*MockExecutionStoreMockRecorder) CompleteVisibilityTask 

func (mr *MockExecutionStoreMockRecorder) CompleteVisibilityTask(request interface{}) *gomock.Call

CompleteVisibilityTask indicates an expected call of CompleteVisibilityTask.

func (*MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution(request interface{}) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockExecutionStoreMockRecorder) CreateWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) CreateWorkflowExecution(request interface{}) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution(request interface{}) *gomock.Call

DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.

func (*MockExecutionStoreMockRecorder) DeleteHistoryBranch added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) DeleteHistoryBranch(request interface{}) *gomock.Call

DeleteHistoryBranch indicates an expected call of DeleteHistoryBranch.

func (*MockExecutionStoreMockRecorder) DeleteHistoryNodes added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) DeleteHistoryNodes(request interface{}) *gomock.Call

DeleteHistoryNodes indicates an expected call of DeleteHistoryNodes.

func (*MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ 

func (mr *MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

DeleteReplicationTaskFromDLQ indicates an expected call of DeleteReplicationTaskFromDLQ.

func (*MockExecutionStoreMockRecorder) DeleteWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockExecutionStoreMockRecorder) ForkHistoryBranch added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) ForkHistoryBranch(request interface{}) *gomock.Call

ForkHistoryBranch indicates an expected call of ForkHistoryBranch.

func (*MockExecutionStoreMockRecorder) GetAllHistoryTreeBranches added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) GetAllHistoryTreeBranches(request interface{}) *gomock.Call

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MockExecutionStoreMockRecorder) GetCurrentExecution 

func (mr *MockExecutionStoreMockRecorder) GetCurrentExecution(request interface{}) *gomock.Call

GetCurrentExecution indicates an expected call of GetCurrentExecution.

func (*MockExecutionStoreMockRecorder) GetHistoryTree added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) GetHistoryTree(request interface{}) *gomock.Call

GetHistoryTree indicates an expected call of GetHistoryTree.

func (*MockExecutionStoreMockRecorder) GetName 

func (mr *MockExecutionStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockExecutionStoreMockRecorder) GetReplicationTask 

func (mr *MockExecutionStoreMockRecorder) GetReplicationTask(request interface{}) *gomock.Call

GetReplicationTask indicates an expected call of GetReplicationTask.

func (*MockExecutionStoreMockRecorder) GetReplicationTasks 

func (mr *MockExecutionStoreMockRecorder) GetReplicationTasks(request interface{}) *gomock.Call

GetReplicationTasks indicates an expected call of GetReplicationTasks.

func (*MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ 

func (mr *MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ(request interface{}) *gomock.Call

GetReplicationTasksFromDLQ indicates an expected call of GetReplicationTasksFromDLQ.

func (*MockExecutionStoreMockRecorder) GetTieredStorageTask added in v1.14.0 

func (mr *MockExecutionStoreMockRecorder) GetTieredStorageTask(request interface{}) *gomock.Call

GetTieredStorageTask indicates an expected call of GetTieredStorageTask.

func (*MockExecutionStoreMockRecorder) GetTieredStorageTasks added in v1.14.0 

func (mr *MockExecutionStoreMockRecorder) GetTieredStorageTasks(request interface{}) *gomock.Call

GetTieredStorageTasks indicates an expected call of GetTieredStorageTasks.

func (*MockExecutionStoreMockRecorder) GetTimerTask 

func (mr *MockExecutionStoreMockRecorder) GetTimerTask(request interface{}) *gomock.Call

GetTimerTask indicates an expected call of GetTimerTask.

func (*MockExecutionStoreMockRecorder) GetTimerTasks added in v1.14.0 

func (mr *MockExecutionStoreMockRecorder) GetTimerTasks(request interface{}) *gomock.Call

GetTimerTasks indicates an expected call of GetTimerTasks.

func (*MockExecutionStoreMockRecorder) GetTransferTask 

func (mr *MockExecutionStoreMockRecorder) GetTransferTask(request interface{}) *gomock.Call

GetTransferTask indicates an expected call of GetTransferTask.

func (*MockExecutionStoreMockRecorder) GetTransferTasks 

func (mr *MockExecutionStoreMockRecorder) GetTransferTasks(request interface{}) *gomock.Call

GetTransferTasks indicates an expected call of GetTransferTasks.

func (*MockExecutionStoreMockRecorder) GetVisibilityTask 

func (mr *MockExecutionStoreMockRecorder) GetVisibilityTask(request interface{}) *gomock.Call

GetVisibilityTask indicates an expected call of GetVisibilityTask.

func (*MockExecutionStoreMockRecorder) GetVisibilityTasks 

func (mr *MockExecutionStoreMockRecorder) GetVisibilityTasks(request interface{}) *gomock.Call

GetVisibilityTasks indicates an expected call of GetVisibilityTasks.

func (*MockExecutionStoreMockRecorder) GetWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) GetWorkflowExecution(request interface{}) *gomock.Call

GetWorkflowExecution indicates an expected call of GetWorkflowExecution.

func (*MockExecutionStoreMockRecorder) ListConcreteExecutions 

func (mr *MockExecutionStoreMockRecorder) ListConcreteExecutions(request interface{}) *gomock.Call

ListConcreteExecutions indicates an expected call of ListConcreteExecutions.

func (*MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ 

func (mr *MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ(request interface{}) *gomock.Call

PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.

func (*MockExecutionStoreMockRecorder) RangeCompleteReplicationTask 

func (mr *MockExecutionStoreMockRecorder) RangeCompleteReplicationTask(request interface{}) *gomock.Call

RangeCompleteReplicationTask indicates an expected call of RangeCompleteReplicationTask.

func (*MockExecutionStoreMockRecorder) RangeCompleteTieredStorageTask added in v1.14.0 

func (mr *MockExecutionStoreMockRecorder) RangeCompleteTieredStorageTask(request interface{}) *gomock.Call

RangeCompleteTieredStorageTask indicates an expected call of RangeCompleteTieredStorageTask.

func (*MockExecutionStoreMockRecorder) RangeCompleteTimerTask 

func (mr *MockExecutionStoreMockRecorder) RangeCompleteTimerTask(request interface{}) *gomock.Call

RangeCompleteTimerTask indicates an expected call of RangeCompleteTimerTask.

func (*MockExecutionStoreMockRecorder) RangeCompleteTransferTask 

func (mr *MockExecutionStoreMockRecorder) RangeCompleteTransferTask(request interface{}) *gomock.Call

RangeCompleteTransferTask indicates an expected call of RangeCompleteTransferTask.

func (*MockExecutionStoreMockRecorder) RangeCompleteVisibilityTask 

func (mr *MockExecutionStoreMockRecorder) RangeCompleteVisibilityTask(request interface{}) *gomock.Call

RangeCompleteVisibilityTask indicates an expected call of RangeCompleteVisibilityTask.

func (*MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ 

func (mr *MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

RangeDeleteReplicationTaskFromDLQ indicates an expected call of RangeDeleteReplicationTaskFromDLQ.

func (*MockExecutionStoreMockRecorder) ReadHistoryBranch added in v1.12.0 

func (mr *MockExecutionStoreMockRecorder) ReadHistoryBranch(request interface{}) *gomock.Call

ReadHistoryBranch indicates an expected call of ReadHistoryBranch.

func (*MockExecutionStoreMockRecorder) UpdateWorkflowExecution 

func (mr *MockExecutionStoreMockRecorder) UpdateWorkflowExecution(request interface{}) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

type MockMetadataStore 

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

MockMetadataStore is a mock of MetadataStore interface.

func NewMockMetadataStore 

func NewMockMetadataStore(ctrl *gomock.Controller) *MockMetadataStore

NewMockMetadataStore creates a new mock instance.

func (*MockMetadataStore) Close 

func (m *MockMetadataStore) Close()

Close mocks base method.

func (*MockMetadataStore) CreateNamespace 

func (m *MockMetadataStore) CreateNamespace(request *persistence.InternalCreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)

CreateNamespace mocks base method.

func (*MockMetadataStore) DeleteNamespace 

func (m *MockMetadataStore) DeleteNamespace(request *persistence.DeleteNamespaceRequest) error

DeleteNamespace mocks base method.

func (*MockMetadataStore) DeleteNamespaceByName 

func (m *MockMetadataStore) DeleteNamespaceByName(request *persistence.DeleteNamespaceByNameRequest) error

DeleteNamespaceByName mocks base method.

func (*MockMetadataStore) EXPECT 

func (m *MockMetadataStore) EXPECT() *MockMetadataStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataStore) GetMetadata 

func (m *MockMetadataStore) GetMetadata() (*persistence.GetMetadataResponse, error)

GetMetadata mocks base method.

func (*MockMetadataStore) GetName 

func (m *MockMetadataStore) GetName() string

GetName mocks base method.

func (*MockMetadataStore) GetNamespace 

func (m *MockMetadataStore) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.InternalGetNamespaceResponse, error)

GetNamespace mocks base method.

func (*MockMetadataStore) ListNamespaces 

func (m *MockMetadataStore) ListNamespaces(request *persistence.ListNamespacesRequest) (*persistence.InternalListNamespacesResponse, error)

ListNamespaces mocks base method.

func (*MockMetadataStore) UpdateNamespace 

func (m *MockMetadataStore) UpdateNamespace(request *persistence.InternalUpdateNamespaceRequest) error

UpdateNamespace mocks base method.

type MockMetadataStoreMockRecorder 

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

MockMetadataStoreMockRecorder is the mock recorder for MockMetadataStore.

func (*MockMetadataStoreMockRecorder) Close 

func (mr *MockMetadataStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMetadataStoreMockRecorder) CreateNamespace 

func (mr *MockMetadataStoreMockRecorder) CreateNamespace(request interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockMetadataStoreMockRecorder) DeleteNamespace 

func (mr *MockMetadataStoreMockRecorder) DeleteNamespace(request interface{}) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockMetadataStoreMockRecorder) DeleteNamespaceByName 

func (mr *MockMetadataStoreMockRecorder) DeleteNamespaceByName(request interface{}) *gomock.Call

DeleteNamespaceByName indicates an expected call of DeleteNamespaceByName.

func (*MockMetadataStoreMockRecorder) GetMetadata 

func (mr *MockMetadataStoreMockRecorder) GetMetadata() *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockMetadataStoreMockRecorder) GetName 

func (mr *MockMetadataStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockMetadataStoreMockRecorder) GetNamespace 

func (mr *MockMetadataStoreMockRecorder) GetNamespace(request interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockMetadataStoreMockRecorder) ListNamespaces 

func (mr *MockMetadataStoreMockRecorder) ListNamespaces(request interface{}) *gomock.Call

ListNamespaces indicates an expected call of ListNamespaces.

func (*MockMetadataStoreMockRecorder) UpdateNamespace 

func (mr *MockMetadataStoreMockRecorder) UpdateNamespace(request interface{}) *gomock.Call

UpdateNamespace indicates an expected call of UpdateNamespace.

type MockQueue 

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

MockQueue is a mock of Queue interface.

func NewMockQueue 

func NewMockQueue(ctrl *gomock.Controller) *MockQueue

NewMockQueue creates a new mock instance.

func (*MockQueue) Close 

func (m *MockQueue) Close()

Close mocks base method.

func (*MockQueue) DeleteMessageFromDLQ 

func (m *MockQueue) DeleteMessageFromDLQ(messageID int64) error

DeleteMessageFromDLQ mocks base method.

func (*MockQueue) DeleteMessagesBefore 

func (m *MockQueue) DeleteMessagesBefore(messageID int64) error

DeleteMessagesBefore mocks base method.

func (*MockQueue) EXPECT 

func (m *MockQueue) EXPECT() *MockQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockQueue) EnqueueMessage 

func (m *MockQueue) EnqueueMessage(blob common.DataBlob) error

EnqueueMessage mocks base method.

func (*MockQueue) EnqueueMessageToDLQ 

func (m *MockQueue) EnqueueMessageToDLQ(blob common.DataBlob) (int64, error)

EnqueueMessageToDLQ mocks base method.

func (*MockQueue) GetAckLevels 

func (m *MockQueue) GetAckLevels() (*persistence.InternalQueueMetadata, error)

GetAckLevels mocks base method.

func (*MockQueue) GetDLQAckLevels 

func (m *MockQueue) GetDLQAckLevels() (*persistence.InternalQueueMetadata, error)

GetDLQAckLevels mocks base method.

func (*MockQueue) Init 

func (m *MockQueue) Init(blob *common.DataBlob) error

Init mocks base method.

func (*MockQueue) RangeDeleteMessagesFromDLQ 

func (m *MockQueue) RangeDeleteMessagesFromDLQ(firstMessageID, lastMessageID int64) error

RangeDeleteMessagesFromDLQ mocks base method.

func (*MockQueue) ReadMessages 

func (m *MockQueue) ReadMessages(lastMessageID int64, maxCount int) ([]*persistence.QueueMessage, error)

ReadMessages mocks base method.

func (*MockQueue) ReadMessagesFromDLQ 

func (m *MockQueue) ReadMessagesFromDLQ(firstMessageID, lastMessageID int64, pageSize int, pageToken []byte) ([]*persistence.QueueMessage, []byte, error)

ReadMessagesFromDLQ mocks base method.

func (*MockQueue) UpdateAckLevel 

func (m *MockQueue) UpdateAckLevel(metadata *persistence.InternalQueueMetadata) error

UpdateAckLevel mocks base method.

func (*MockQueue) UpdateDLQAckLevel 

func (m *MockQueue) UpdateDLQAckLevel(metadata *persistence.InternalQueueMetadata) error

UpdateDLQAckLevel mocks base method.

type MockQueueMockRecorder 

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

MockQueueMockRecorder is the mock recorder for MockQueue.

func (*MockQueueMockRecorder) Close 

func (mr *MockQueueMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockQueueMockRecorder) DeleteMessageFromDLQ 

func (mr *MockQueueMockRecorder) DeleteMessageFromDLQ(messageID interface{}) *gomock.Call

DeleteMessageFromDLQ indicates an expected call of DeleteMessageFromDLQ.

func (*MockQueueMockRecorder) DeleteMessagesBefore 

func (mr *MockQueueMockRecorder) DeleteMessagesBefore(messageID interface{}) *gomock.Call

DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.

func (*MockQueueMockRecorder) EnqueueMessage 

func (mr *MockQueueMockRecorder) EnqueueMessage(blob interface{}) *gomock.Call

EnqueueMessage indicates an expected call of EnqueueMessage.

func (*MockQueueMockRecorder) EnqueueMessageToDLQ 

func (mr *MockQueueMockRecorder) EnqueueMessageToDLQ(blob interface{}) *gomock.Call

EnqueueMessageToDLQ indicates an expected call of EnqueueMessageToDLQ.

func (*MockQueueMockRecorder) GetAckLevels 

func (mr *MockQueueMockRecorder) GetAckLevels() *gomock.Call

GetAckLevels indicates an expected call of GetAckLevels.

func (*MockQueueMockRecorder) GetDLQAckLevels 

func (mr *MockQueueMockRecorder) GetDLQAckLevels() *gomock.Call

GetDLQAckLevels indicates an expected call of GetDLQAckLevels.

func (*MockQueueMockRecorder) Init 

func (mr *MockQueueMockRecorder) Init(blob interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockQueueMockRecorder) RangeDeleteMessagesFromDLQ 

func (mr *MockQueueMockRecorder) RangeDeleteMessagesFromDLQ(firstMessageID, lastMessageID interface{}) *gomock.Call

RangeDeleteMessagesFromDLQ indicates an expected call of RangeDeleteMessagesFromDLQ.

func (*MockQueueMockRecorder) ReadMessages 

func (mr *MockQueueMockRecorder) ReadMessages(lastMessageID, maxCount interface{}) *gomock.Call

ReadMessages indicates an expected call of ReadMessages.

func (*MockQueueMockRecorder) ReadMessagesFromDLQ 

func (mr *MockQueueMockRecorder) ReadMessagesFromDLQ(firstMessageID, lastMessageID, pageSize, pageToken interface{}) *gomock.Call

ReadMessagesFromDLQ indicates an expected call of ReadMessagesFromDLQ.

func (*MockQueueMockRecorder) UpdateAckLevel 

func (mr *MockQueueMockRecorder) UpdateAckLevel(metadata interface{}) *gomock.Call

UpdateAckLevel indicates an expected call of UpdateAckLevel.

func (*MockQueueMockRecorder) UpdateDLQAckLevel 

func (mr *MockQueueMockRecorder) UpdateDLQAckLevel(metadata interface{}) *gomock.Call

UpdateDLQAckLevel indicates an expected call of UpdateDLQAckLevel.

type MockShardStore 

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

MockShardStore is a mock of ShardStore interface.

func NewMockShardStore 

func NewMockShardStore(ctrl *gomock.Controller) *MockShardStore

NewMockShardStore creates a new mock instance.

func (*MockShardStore) Close 

func (m *MockShardStore) Close()

Close mocks base method.

func (*MockShardStore) EXPECT 

func (m *MockShardStore) EXPECT() *MockShardStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockShardStore) GetClusterName 

func (m *MockShardStore) GetClusterName() string

GetClusterName mocks base method.

func (*MockShardStore) GetName 

func (m *MockShardStore) GetName() string

GetName mocks base method.

func (*MockShardStore) GetOrCreateShard added in v1.14.0 

func (m *MockShardStore) GetOrCreateShard(request *persistence.InternalGetOrCreateShardRequest) (*persistence.InternalGetOrCreateShardResponse, error)

GetOrCreateShard mocks base method.

func (*MockShardStore) UpdateShard 

func (m *MockShardStore) UpdateShard(request *persistence.InternalUpdateShardRequest) error

UpdateShard mocks base method.

type MockShardStoreMockRecorder 

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

MockShardStoreMockRecorder is the mock recorder for MockShardStore.

func (*MockShardStoreMockRecorder) Close 

func (mr *MockShardStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockShardStoreMockRecorder) GetClusterName 

func (mr *MockShardStoreMockRecorder) GetClusterName() *gomock.Call

GetClusterName indicates an expected call of GetClusterName.

func (*MockShardStoreMockRecorder) GetName 

func (mr *MockShardStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockShardStoreMockRecorder) GetOrCreateShard added in v1.14.0 

func (mr *MockShardStoreMockRecorder) GetOrCreateShard(request interface{}) *gomock.Call

GetOrCreateShard indicates an expected call of GetOrCreateShard.

func (*MockShardStoreMockRecorder) UpdateShard 

func (mr *MockShardStoreMockRecorder) UpdateShard(request interface{}) *gomock.Call

UpdateShard indicates an expected call of UpdateShard.

type MockTaskStore 

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

MockTaskStore is a mock of TaskStore interface.

func NewMockTaskStore 

func NewMockTaskStore(ctrl *gomock.Controller) *MockTaskStore

NewMockTaskStore creates a new mock instance.

func (*MockTaskStore) Close 

func (m *MockTaskStore) Close()

Close mocks base method.

func (*MockTaskStore) CompleteTask 

func (m *MockTaskStore) CompleteTask(request *persistence.CompleteTaskRequest) error

CompleteTask mocks base method.

func (*MockTaskStore) CompleteTasksLessThan 

func (m *MockTaskStore) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

CompleteTasksLessThan mocks base method.

func (*MockTaskStore) CreateTaskQueue 

func (m *MockTaskStore) CreateTaskQueue(request *persistence.InternalCreateTaskQueueRequest) error

CreateTaskQueue mocks base method.

func (*MockTaskStore) CreateTasks 

func (m *MockTaskStore) CreateTasks(request *persistence.InternalCreateTasksRequest) (*persistence.CreateTasksResponse, error)

CreateTasks mocks base method.

func (*MockTaskStore) DeleteTaskQueue 

func (m *MockTaskStore) DeleteTaskQueue(request *persistence.DeleteTaskQueueRequest) error

DeleteTaskQueue mocks base method.

func (*MockTaskStore) EXPECT 

func (m *MockTaskStore) EXPECT() *MockTaskStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskStore) ExtendLease 

func (m *MockTaskStore) ExtendLease(request *persistence.InternalExtendLeaseRequest) error

ExtendLease mocks base method.

func (*MockTaskStore) GetName 

func (m *MockTaskStore) GetName() string

GetName mocks base method.

func (*MockTaskStore) GetTaskQueue 

func (m *MockTaskStore) GetTaskQueue(request *persistence.InternalGetTaskQueueRequest) (*persistence.InternalGetTaskQueueResponse, error)

GetTaskQueue mocks base method.

func (*MockTaskStore) GetTasks 

func (m *MockTaskStore) GetTasks(request *persistence.GetTasksRequest) (*persistence.InternalGetTasksResponse, error)

GetTasks mocks base method.

func (*MockTaskStore) ListTaskQueue 

func (m *MockTaskStore) ListTaskQueue(request *persistence.ListTaskQueueRequest) (*persistence.InternalListTaskQueueResponse, error)

ListTaskQueue mocks base method.

func (*MockTaskStore) UpdateTaskQueue 

func (m *MockTaskStore) UpdateTaskQueue(request *persistence.InternalUpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)

UpdateTaskQueue mocks base method.

type MockTaskStoreMockRecorder 

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

MockTaskStoreMockRecorder is the mock recorder for MockTaskStore.

func (*MockTaskStoreMockRecorder) Close 

func (mr *MockTaskStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTaskStoreMockRecorder) CompleteTask 

func (mr *MockTaskStoreMockRecorder) CompleteTask(request interface{}) *gomock.Call

CompleteTask indicates an expected call of CompleteTask.

func (*MockTaskStoreMockRecorder) CompleteTasksLessThan 

func (mr *MockTaskStoreMockRecorder) CompleteTasksLessThan(request interface{}) *gomock.Call

CompleteTasksLessThan indicates an expected call of CompleteTasksLessThan.

func (*MockTaskStoreMockRecorder) CreateTaskQueue 

func (mr *MockTaskStoreMockRecorder) CreateTaskQueue(request interface{}) *gomock.Call

CreateTaskQueue indicates an expected call of CreateTaskQueue.

func (*MockTaskStoreMockRecorder) CreateTasks 

func (mr *MockTaskStoreMockRecorder) CreateTasks(request interface{}) *gomock.Call

CreateTasks indicates an expected call of CreateTasks.

func (*MockTaskStoreMockRecorder) DeleteTaskQueue 

func (mr *MockTaskStoreMockRecorder) DeleteTaskQueue(request interface{}) *gomock.Call

DeleteTaskQueue indicates an expected call of DeleteTaskQueue.

func (*MockTaskStoreMockRecorder) ExtendLease 

func (mr *MockTaskStoreMockRecorder) ExtendLease(request interface{}) *gomock.Call

ExtendLease indicates an expected call of ExtendLease.

func (*MockTaskStoreMockRecorder) GetName 

func (mr *MockTaskStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockTaskStoreMockRecorder) GetTaskQueue 

func (mr *MockTaskStoreMockRecorder) GetTaskQueue(request interface{}) *gomock.Call

GetTaskQueue indicates an expected call of GetTaskQueue.

func (*MockTaskStoreMockRecorder) GetTasks 

func (mr *MockTaskStoreMockRecorder) GetTasks(request interface{}) *gomock.Call

GetTasks indicates an expected call of GetTasks.

func (*MockTaskStoreMockRecorder) ListTaskQueue 

func (mr *MockTaskStoreMockRecorder) ListTaskQueue(request interface{}) *gomock.Call

ListTaskQueue indicates an expected call of ListTaskQueue.

func (*MockTaskStoreMockRecorder) UpdateTaskQueue 

func (mr *MockTaskStoreMockRecorder) UpdateTaskQueue(request interface{}) *gomock.Call

UpdateTaskQueue indicates an expected call of UpdateTaskQueue.

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.