mock

package
v1.15.1 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 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

DeleteClusterMetadata mocks base method.

func (*MockClusterMetadataStore) EXPECT

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

func (*MockClusterMetadataStore) GetClusterMembers

GetClusterMembers mocks base method.

func (*MockClusterMetadataStore) GetClusterMetadata

GetClusterMetadata mocks base method.

func (*MockClusterMetadataStore) GetName

func (m *MockClusterMetadataStore) GetName() string

GetName mocks base method.

func (*MockClusterMetadataStore) ListClusterMetadata added in v1.14.0

ListClusterMetadata mocks base method.

func (*MockClusterMetadataStore) PruneClusterMembership

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

PruneClusterMembership mocks base method.

func (*MockClusterMetadataStore) SaveClusterMetadata

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

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

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

AddTasks mocks base method.

func (*MockExecutionStore) AppendHistoryNodes added in v1.12.0

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

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

DeleteHistoryBranch mocks base method.

func (*MockExecutionStore) DeleteHistoryNodes added in v1.12.0

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

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

func (*MockExecutionStore) ForkHistoryBranch added in v1.12.0

ForkHistoryBranch mocks base method.

func (*MockExecutionStore) GetAllHistoryTreeBranches added in v1.12.0

GetAllHistoryTreeBranches mocks base method.

func (*MockExecutionStore) GetCurrentExecution

GetCurrentExecution mocks base method.

func (*MockExecutionStore) GetHistoryTree added in v1.12.0

GetHistoryTree mocks base method.

func (*MockExecutionStore) GetName

func (m *MockExecutionStore) GetName() string

GetName mocks base method.

func (*MockExecutionStore) GetReplicationTask

GetReplicationTask mocks base method.

func (*MockExecutionStore) GetReplicationTasks

GetReplicationTasks mocks base method.

func (*MockExecutionStore) GetReplicationTasksFromDLQ

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionStore) GetTimerTask

GetTimerTask mocks base method.

func (*MockExecutionStore) GetTimerTasks added in v1.14.0

GetTimerTasks mocks base method.

func (*MockExecutionStore) GetTransferTask

GetTransferTask mocks base method.

func (*MockExecutionStore) GetTransferTasks

GetTransferTasks mocks base method.

func (*MockExecutionStore) GetVisibilityTask

GetVisibilityTask mocks base method.

func (*MockExecutionStore) GetVisibilityTasks

GetVisibilityTasks mocks base method.

func (*MockExecutionStore) GetWorkflowExecution

GetWorkflowExecution mocks base method.

func (*MockExecutionStore) ListConcreteExecutions

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

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

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

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

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

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

func (*MockMetadataStore) GetMetadata

GetMetadata mocks base method.

func (*MockMetadataStore) GetName

func (m *MockMetadataStore) GetName() string

GetName mocks base method.

func (*MockMetadataStore) GetNamespace

GetNamespace mocks base method.

func (*MockMetadataStore) ListNamespaces

ListNamespaces mocks base method.

func (*MockMetadataStore) UpdateNamespace

UpdateNamespace mocks base method.

type MockMetadataStoreMockRecorder

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

MockMetadataStoreMockRecorder is the mock recorder for MockMetadataStore.

func (*MockMetadataStoreMockRecorder) Close

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

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

GetOrCreateShard mocks base method.

func (*MockShardStore) UpdateShard

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

CreateTasks mocks base method.

func (*MockTaskStore) DeleteTaskQueue

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

DeleteTaskQueue mocks base method.

func (*MockTaskStore) EXPECT

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

func (*MockTaskStore) GetName

func (m *MockTaskStore) GetName() string

GetName mocks base method.

func (*MockTaskStore) GetTaskQueue

GetTaskQueue mocks base method.

func (*MockTaskStore) GetTasks

GetTasks mocks base method.

func (*MockTaskStore) ListTaskQueue

ListTaskQueue mocks base method.

func (*MockTaskStore) UpdateTaskQueue

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL