mock

package
v1.21.0 Latest Latest
Warning

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

Go to latest
Published: Jun 23, 2023 License: MIT Imports: 5 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

PruneClusterMembership mocks base method.

func (*MockClusterMetadataStore) SaveClusterMetadata

SaveClusterMetadata mocks base method.

func (*MockClusterMetadataStore) UpsertClusterMembership

func (m *MockClusterMetadataStore) UpsertClusterMembership(ctx context.Context, 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(ctx, request interface{}) *gomock.Call

DeleteClusterMetadata indicates an expected call of DeleteClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMembers

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

GetClusterMembers indicates an expected call of GetClusterMembers.

func (*MockClusterMetadataStoreMockRecorder) GetClusterMetadata

func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMetadata(ctx, 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(ctx, request interface{}) *gomock.Call

ListClusterMetadata indicates an expected call of ListClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) PruneClusterMembership

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

PruneClusterMembership indicates an expected call of PruneClusterMembership.

func (*MockClusterMetadataStoreMockRecorder) SaveClusterMetadata

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

SaveClusterMetadata indicates an expected call of SaveClusterMetadata.

func (*MockClusterMetadataStoreMockRecorder) UpsertClusterMembership

func (mr *MockClusterMetadataStoreMockRecorder) UpsertClusterMembership(ctx, 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) AddHistoryTasks added in v1.16.0

AddHistoryTasks 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) CompleteHistoryTask added in v1.16.0

func (m *MockExecutionStore) CompleteHistoryTask(ctx context.Context, request *persistence.CompleteHistoryTaskRequest) error

CompleteHistoryTask mocks base method.

func (*MockExecutionStore) ConflictResolveWorkflowExecution

func (m *MockExecutionStore) ConflictResolveWorkflowExecution(ctx context.Context, request *persistence.InternalConflictResolveWorkflowExecutionRequest) error

ConflictResolveWorkflowExecution mocks base method.

func (*MockExecutionStore) CreateWorkflowExecution

CreateWorkflowExecution mocks base method.

func (*MockExecutionStore) DeleteCurrentWorkflowExecution

func (m *MockExecutionStore) DeleteCurrentWorkflowExecution(ctx context.Context, 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(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest) error

DeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionStore) DeleteWorkflowExecution

func (m *MockExecutionStore) DeleteWorkflowExecution(ctx context.Context, 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) GetHistoryBranchUtil added in v1.21.0

func (m *MockExecutionStore) GetHistoryBranchUtil() persistence.HistoryBranchUtil

GetHistoryBranchUtil mocks base method.

func (*MockExecutionStore) GetHistoryTasks added in v1.16.0

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

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionStore) GetWorkflowExecution

GetWorkflowExecution mocks base method.

func (*MockExecutionStore) IsReplicationDLQEmpty added in v1.21.0

func (m *MockExecutionStore) IsReplicationDLQEmpty(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (bool, error)

IsReplicationDLQEmpty mocks base method.

func (*MockExecutionStore) ListConcreteExecutions

ListConcreteExecutions mocks base method.

func (*MockExecutionStore) PutReplicationTaskToDLQ

func (m *MockExecutionStore) PutReplicationTaskToDLQ(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ mocks base method.

func (*MockExecutionStore) RangeCompleteHistoryTasks added in v1.16.0

func (m *MockExecutionStore) RangeCompleteHistoryTasks(ctx context.Context, request *persistence.RangeCompleteHistoryTasksRequest) error

RangeCompleteHistoryTasks mocks base method.

func (*MockExecutionStore) RangeDeleteReplicationTaskFromDLQ

func (m *MockExecutionStore) RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

RangeDeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionStore) ReadHistoryBranch added in v1.12.0

ReadHistoryBranch mocks base method.

func (*MockExecutionStore) RegisterHistoryTaskReader added in v1.21.0

func (m *MockExecutionStore) RegisterHistoryTaskReader(ctx context.Context, request *persistence.RegisterHistoryTaskReaderRequest) error

RegisterHistoryTaskReader mocks base method.

func (*MockExecutionStore) SetWorkflowExecution added in v1.16.0

SetWorkflowExecution mocks base method.

func (*MockExecutionStore) UnregisterHistoryTaskReader added in v1.21.0

func (m *MockExecutionStore) UnregisterHistoryTaskReader(ctx context.Context, request *persistence.UnregisterHistoryTaskReaderRequest)

UnregisterHistoryTaskReader mocks base method.

func (*MockExecutionStore) UpdateHistoryTaskReaderProgress added in v1.21.0

func (m *MockExecutionStore) UpdateHistoryTaskReaderProgress(ctx context.Context, request *persistence.UpdateHistoryTaskReaderProgressRequest)

UpdateHistoryTaskReaderProgress mocks base method.

func (*MockExecutionStore) UpdateWorkflowExecution

UpdateWorkflowExecution mocks base method.

type MockExecutionStoreMockRecorder

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

MockExecutionStoreMockRecorder is the mock recorder for MockExecutionStore.

func (*MockExecutionStoreMockRecorder) AddHistoryTasks added in v1.16.0

func (mr *MockExecutionStoreMockRecorder) AddHistoryTasks(ctx, request interface{}) *gomock.Call

AddHistoryTasks indicates an expected call of AddHistoryTasks.

func (*MockExecutionStoreMockRecorder) AppendHistoryNodes added in v1.12.0

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

AppendHistoryNodes indicates an expected call of AppendHistoryNodes.

func (*MockExecutionStoreMockRecorder) Close

Close indicates an expected call of Close.

func (*MockExecutionStoreMockRecorder) CompleteHistoryTask added in v1.16.0

func (mr *MockExecutionStoreMockRecorder) CompleteHistoryTask(ctx, request interface{}) *gomock.Call

CompleteHistoryTask indicates an expected call of CompleteHistoryTask.

func (*MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution

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

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockExecutionStoreMockRecorder) CreateWorkflowExecution

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

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution

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

DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.

func (*MockExecutionStoreMockRecorder) DeleteHistoryBranch added in v1.12.0

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

DeleteHistoryBranch indicates an expected call of DeleteHistoryBranch.

func (*MockExecutionStoreMockRecorder) DeleteHistoryNodes added in v1.12.0

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

DeleteHistoryNodes indicates an expected call of DeleteHistoryNodes.

func (*MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ

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

DeleteReplicationTaskFromDLQ indicates an expected call of DeleteReplicationTaskFromDLQ.

func (*MockExecutionStoreMockRecorder) DeleteWorkflowExecution

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

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockExecutionStoreMockRecorder) ForkHistoryBranch added in v1.12.0

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

ForkHistoryBranch indicates an expected call of ForkHistoryBranch.

func (*MockExecutionStoreMockRecorder) GetAllHistoryTreeBranches added in v1.12.0

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

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MockExecutionStoreMockRecorder) GetCurrentExecution

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

GetCurrentExecution indicates an expected call of GetCurrentExecution.

func (*MockExecutionStoreMockRecorder) GetHistoryBranchUtil added in v1.21.0

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

GetHistoryBranchUtil indicates an expected call of GetHistoryBranchUtil.

func (*MockExecutionStoreMockRecorder) GetHistoryTasks added in v1.16.0

func (mr *MockExecutionStoreMockRecorder) GetHistoryTasks(ctx, request interface{}) *gomock.Call

GetHistoryTasks indicates an expected call of GetHistoryTasks.

func (*MockExecutionStoreMockRecorder) GetHistoryTree added in v1.12.0

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

GetHistoryTree indicates an expected call of GetHistoryTree.

func (*MockExecutionStoreMockRecorder) GetName

GetName indicates an expected call of GetName.

func (*MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ

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

GetReplicationTasksFromDLQ indicates an expected call of GetReplicationTasksFromDLQ.

func (*MockExecutionStoreMockRecorder) GetWorkflowExecution

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

GetWorkflowExecution indicates an expected call of GetWorkflowExecution.

func (*MockExecutionStoreMockRecorder) IsReplicationDLQEmpty added in v1.21.0

func (mr *MockExecutionStoreMockRecorder) IsReplicationDLQEmpty(ctx, request interface{}) *gomock.Call

IsReplicationDLQEmpty indicates an expected call of IsReplicationDLQEmpty.

func (*MockExecutionStoreMockRecorder) ListConcreteExecutions

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

ListConcreteExecutions indicates an expected call of ListConcreteExecutions.

func (*MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ

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

PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.

func (*MockExecutionStoreMockRecorder) RangeCompleteHistoryTasks added in v1.16.0

func (mr *MockExecutionStoreMockRecorder) RangeCompleteHistoryTasks(ctx, request interface{}) *gomock.Call

RangeCompleteHistoryTasks indicates an expected call of RangeCompleteHistoryTasks.

func (*MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ

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

RangeDeleteReplicationTaskFromDLQ indicates an expected call of RangeDeleteReplicationTaskFromDLQ.

func (*MockExecutionStoreMockRecorder) ReadHistoryBranch added in v1.12.0

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

ReadHistoryBranch indicates an expected call of ReadHistoryBranch.

func (*MockExecutionStoreMockRecorder) RegisterHistoryTaskReader added in v1.21.0

func (mr *MockExecutionStoreMockRecorder) RegisterHistoryTaskReader(ctx, request interface{}) *gomock.Call

RegisterHistoryTaskReader indicates an expected call of RegisterHistoryTaskReader.

func (*MockExecutionStoreMockRecorder) SetWorkflowExecution added in v1.16.0

func (mr *MockExecutionStoreMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockExecutionStoreMockRecorder) UnregisterHistoryTaskReader added in v1.21.0

func (mr *MockExecutionStoreMockRecorder) UnregisterHistoryTaskReader(ctx, request interface{}) *gomock.Call

UnregisterHistoryTaskReader indicates an expected call of UnregisterHistoryTaskReader.

func (*MockExecutionStoreMockRecorder) UpdateHistoryTaskReaderProgress added in v1.21.0

func (mr *MockExecutionStoreMockRecorder) UpdateHistoryTaskReaderProgress(ctx, request interface{}) *gomock.Call

UpdateHistoryTaskReaderProgress indicates an expected call of UpdateHistoryTaskReaderProgress.

func (*MockExecutionStoreMockRecorder) UpdateWorkflowExecution

func (mr *MockExecutionStoreMockRecorder) UpdateWorkflowExecution(ctx, 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(ctx context.Context, request *persistence.DeleteNamespaceRequest) error

DeleteNamespace mocks base method.

func (*MockMetadataStore) DeleteNamespaceByName

func (m *MockMetadataStore) DeleteNamespaceByName(ctx context.Context, 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) RenameNamespace added in v1.16.0

RenameNamespace 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(ctx, request interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockMetadataStoreMockRecorder) DeleteNamespace

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

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockMetadataStoreMockRecorder) DeleteNamespaceByName

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

DeleteNamespaceByName indicates an expected call of DeleteNamespaceByName.

func (*MockMetadataStoreMockRecorder) GetMetadata

func (mr *MockMetadataStoreMockRecorder) GetMetadata(ctx interface{}) *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(ctx, request interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockMetadataStoreMockRecorder) ListNamespaces

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

ListNamespaces indicates an expected call of ListNamespaces.

func (*MockMetadataStoreMockRecorder) RenameNamespace added in v1.16.0

func (mr *MockMetadataStoreMockRecorder) RenameNamespace(ctx, request interface{}) *gomock.Call

RenameNamespace indicates an expected call of RenameNamespace.

func (*MockMetadataStoreMockRecorder) UpdateNamespace

func (mr *MockMetadataStoreMockRecorder) UpdateNamespace(ctx, 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(ctx context.Context, messageID int64) error

DeleteMessageFromDLQ mocks base method.

func (*MockQueue) DeleteMessagesBefore

func (m *MockQueue) DeleteMessagesBefore(ctx context.Context, 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(ctx context.Context, blob common.DataBlob) error

EnqueueMessage mocks base method.

func (*MockQueue) EnqueueMessageToDLQ

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

EnqueueMessageToDLQ mocks base method.

func (*MockQueue) GetAckLevels

GetAckLevels mocks base method.

func (*MockQueue) GetDLQAckLevels

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

GetDLQAckLevels mocks base method.

func (*MockQueue) Init

func (m *MockQueue) Init(ctx context.Context, blob *common.DataBlob) error

Init mocks base method.

func (*MockQueue) RangeDeleteMessagesFromDLQ

func (m *MockQueue) RangeDeleteMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64) error

RangeDeleteMessagesFromDLQ mocks base method.

func (*MockQueue) ReadMessages

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

ReadMessages mocks base method.

func (*MockQueue) ReadMessagesFromDLQ

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

ReadMessagesFromDLQ mocks base method.

func (*MockQueue) UpdateAckLevel

func (m *MockQueue) UpdateAckLevel(ctx context.Context, metadata *persistence.InternalQueueMetadata) error

UpdateAckLevel mocks base method.

func (*MockQueue) UpdateDLQAckLevel

func (m *MockQueue) UpdateDLQAckLevel(ctx context.Context, 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(ctx, messageID interface{}) *gomock.Call

DeleteMessageFromDLQ indicates an expected call of DeleteMessageFromDLQ.

func (*MockQueueMockRecorder) DeleteMessagesBefore

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

DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.

func (*MockQueueMockRecorder) EnqueueMessage

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

EnqueueMessage indicates an expected call of EnqueueMessage.

func (*MockQueueMockRecorder) EnqueueMessageToDLQ

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

EnqueueMessageToDLQ indicates an expected call of EnqueueMessageToDLQ.

func (*MockQueueMockRecorder) GetAckLevels

func (mr *MockQueueMockRecorder) GetAckLevels(ctx interface{}) *gomock.Call

GetAckLevels indicates an expected call of GetAckLevels.

func (*MockQueueMockRecorder) GetDLQAckLevels

func (mr *MockQueueMockRecorder) GetDLQAckLevels(ctx interface{}) *gomock.Call

GetDLQAckLevels indicates an expected call of GetDLQAckLevels.

func (*MockQueueMockRecorder) Init

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

Init indicates an expected call of Init.

func (*MockQueueMockRecorder) RangeDeleteMessagesFromDLQ

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

RangeDeleteMessagesFromDLQ indicates an expected call of RangeDeleteMessagesFromDLQ.

func (*MockQueueMockRecorder) ReadMessages

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

ReadMessages indicates an expected call of ReadMessages.

func (*MockQueueMockRecorder) ReadMessagesFromDLQ

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

ReadMessagesFromDLQ indicates an expected call of ReadMessagesFromDLQ.

func (*MockQueueMockRecorder) UpdateAckLevel

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

UpdateAckLevel indicates an expected call of UpdateAckLevel.

func (*MockQueueMockRecorder) UpdateDLQAckLevel

func (mr *MockQueueMockRecorder) UpdateDLQAckLevel(ctx, 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) AssertShardOwnership added in v1.17.0

func (m *MockShardStore) AssertShardOwnership(ctx context.Context, request *persistence.AssertShardOwnershipRequest) error

AssertShardOwnership mocks base method.

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) AssertShardOwnership added in v1.17.0

func (mr *MockShardStoreMockRecorder) AssertShardOwnership(ctx, request interface{}) *gomock.Call

AssertShardOwnership indicates an expected call of AssertShardOwnership.

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(ctx, request interface{}) *gomock.Call

GetOrCreateShard indicates an expected call of GetOrCreateShard.

func (*MockShardStoreMockRecorder) UpdateShard

func (mr *MockShardStoreMockRecorder) UpdateShard(ctx, 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(ctx context.Context, request *persistence.CompleteTaskRequest) error

CompleteTask mocks base method.

func (*MockTaskStore) CompleteTasksLessThan

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

CompleteTasksLessThan mocks base method.

func (*MockTaskStore) CountTaskQueuesByBuildId added in v1.21.0

func (m *MockTaskStore) CountTaskQueuesByBuildId(ctx context.Context, request *persistence.CountTaskQueuesByBuildIdRequest) (int, error)

CountTaskQueuesByBuildId mocks base method.

func (*MockTaskStore) CreateTaskQueue

CreateTaskQueue mocks base method.

func (*MockTaskStore) CreateTasks

CreateTasks mocks base method.

func (*MockTaskStore) DeleteTaskQueue

func (m *MockTaskStore) DeleteTaskQueue(ctx context.Context, 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) GetTaskQueueUserData added in v1.21.0

GetTaskQueueUserData mocks base method.

func (*MockTaskStore) GetTaskQueuesByBuildId added in v1.21.0

func (m *MockTaskStore) GetTaskQueuesByBuildId(ctx context.Context, request *persistence.GetTaskQueuesByBuildIdRequest) ([]string, error)

GetTaskQueuesByBuildId mocks base method.

func (*MockTaskStore) GetTasks

GetTasks mocks base method.

func (*MockTaskStore) ListTaskQueue

ListTaskQueue mocks base method.

func (*MockTaskStore) ListTaskQueueUserDataEntries added in v1.21.0

ListTaskQueueUserDataEntries mocks base method.

func (*MockTaskStore) UpdateTaskQueue

UpdateTaskQueue mocks base method.

func (*MockTaskStore) UpdateTaskQueueUserData added in v1.21.0

func (m *MockTaskStore) UpdateTaskQueueUserData(ctx context.Context, request *persistence.InternalUpdateTaskQueueUserDataRequest) error

UpdateTaskQueueUserData 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(ctx, request interface{}) *gomock.Call

CompleteTask indicates an expected call of CompleteTask.

func (*MockTaskStoreMockRecorder) CompleteTasksLessThan

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

CompleteTasksLessThan indicates an expected call of CompleteTasksLessThan.

func (*MockTaskStoreMockRecorder) CountTaskQueuesByBuildId added in v1.21.0

func (mr *MockTaskStoreMockRecorder) CountTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call

CountTaskQueuesByBuildId indicates an expected call of CountTaskQueuesByBuildId.

func (*MockTaskStoreMockRecorder) CreateTaskQueue

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

CreateTaskQueue indicates an expected call of CreateTaskQueue.

func (*MockTaskStoreMockRecorder) CreateTasks

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

CreateTasks indicates an expected call of CreateTasks.

func (*MockTaskStoreMockRecorder) DeleteTaskQueue

func (mr *MockTaskStoreMockRecorder) DeleteTaskQueue(ctx, 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(ctx, request interface{}) *gomock.Call

GetTaskQueue indicates an expected call of GetTaskQueue.

func (*MockTaskStoreMockRecorder) GetTaskQueueUserData added in v1.21.0

func (mr *MockTaskStoreMockRecorder) GetTaskQueueUserData(ctx, request interface{}) *gomock.Call

GetTaskQueueUserData indicates an expected call of GetTaskQueueUserData.

func (*MockTaskStoreMockRecorder) GetTaskQueuesByBuildId added in v1.21.0

func (mr *MockTaskStoreMockRecorder) GetTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call

GetTaskQueuesByBuildId indicates an expected call of GetTaskQueuesByBuildId.

func (*MockTaskStoreMockRecorder) GetTasks

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

GetTasks indicates an expected call of GetTasks.

func (*MockTaskStoreMockRecorder) ListTaskQueue

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

ListTaskQueue indicates an expected call of ListTaskQueue.

func (*MockTaskStoreMockRecorder) ListTaskQueueUserDataEntries added in v1.21.0

func (mr *MockTaskStoreMockRecorder) ListTaskQueueUserDataEntries(ctx, request interface{}) *gomock.Call

ListTaskQueueUserDataEntries indicates an expected call of ListTaskQueueUserDataEntries.

func (*MockTaskStoreMockRecorder) UpdateTaskQueue

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

UpdateTaskQueue indicates an expected call of UpdateTaskQueue.

func (*MockTaskStoreMockRecorder) UpdateTaskQueueUserData added in v1.21.0

func (mr *MockTaskStoreMockRecorder) UpdateTaskQueueUserData(ctx, request interface{}) *gomock.Call

UpdateTaskQueueUserData indicates an expected call of UpdateTaskQueueUserData.

Jump to

Keyboard shortcuts

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