mock

package
v1.12.4 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2021 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) 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() (*persistence.InternalGetClusterMetadataResponse, error)

GetClusterMetadata mocks base method.

func (*MockClusterMetadataStore) GetName 

func (m *MockClusterMetadataStore) GetName() string

GetName 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) 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) GetClusterMembers 

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

GetClusterMembers indicates an expected call of GetClusterMembers.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMetadata 

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

GetClusterMetadata indicates an expected call of GetClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) GetName 

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

GetName indicates an expected call of GetName.

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) 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.AddTasksRequest) 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) 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.GetReplicationTaskResponse, error)

GetReplicationTask mocks base method.

func (*MockExecutionStore) GetReplicationTasks 

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

GetReplicationTasks mocks base method.

func (*MockExecutionStore) GetReplicationTasksFromDLQ 

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

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionStore) GetTimerIndexTasks 

func (m *MockExecutionStore) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

GetTimerIndexTasks mocks base method.

func (*MockExecutionStore) GetTimerTask 

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

GetTimerTask mocks base method.

func (*MockExecutionStore) GetTransferTask 

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

GetTransferTask mocks base method.

func (*MockExecutionStore) GetTransferTasks 

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

GetTransferTasks mocks base method.

func (*MockExecutionStore) GetVisibilityTask 

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

GetVisibilityTask mocks base method.

func (*MockExecutionStore) GetVisibilityTasks 

func (m *MockExecutionStore) GetVisibilityTasks(request *persistence.GetVisibilityTasksRequest) (*persistence.GetVisibilityTasksResponse, 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) 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) 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) GetTimerIndexTasks 

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

GetTimerIndexTasks indicates an expected call of GetTimerIndexTasks.

func (*MockExecutionStoreMockRecorder) GetTimerTask 

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

GetTimerTask indicates an expected call of GetTimerTask.

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

func (m *MockShardStore) CreateShard(request *persistence.InternalCreateShardRequest) error

CreateShard 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) GetShard 

func (m *MockShardStore) GetShard(request *persistence.InternalGetShardRequest) (*persistence.InternalGetShardResponse, error)

GetShard 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) CreateShard 

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

CreateShard indicates an expected call of CreateShard.

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

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

GetShard indicates an expected call of GetShard.

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.