mock

package
v1.19.0 Latest Latest
Warning

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

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

func (m *MockClusterMetadataStore) DeleteClusterMetadata(ctx context.Context, request *persistence.InternalDeleteClusterMetadataRequest) error

DeleteClusterMetadata mocks base method.

func (*MockClusterMetadataStore) EXPECT 

func (m *MockClusterMetadataStore) EXPECT() *MockClusterMetadataStoreMockRecorder

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

func (*MockClusterMetadataStore) GetClusterMembers 

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

GetClusterMembers mocks base method.

func (*MockClusterMetadataStore) GetClusterMetadata 

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

GetClusterMetadata mocks base method.

func (*MockClusterMetadataStore) GetName 

func (m *MockClusterMetadataStore) GetName() string

GetName mocks base method.

func (*MockClusterMetadataStore) ListClusterMetadata added in v1.14.0 

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

ListClusterMetadata mocks base method.

func (*MockClusterMetadataStore) PruneClusterMembership 

func (m *MockClusterMetadataStore) PruneClusterMembership(ctx context.Context, request *persistence.PruneClusterMembershipRequest) error

PruneClusterMembership mocks base method.

func (*MockClusterMetadataStore) SaveClusterMetadata 

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

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 

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

Close indicates an expected call of Close.

func (*MockClusterMetadataStoreMockRecorder) DeleteClusterMetadata added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) DeleteClusterMetadata(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 

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

GetName indicates an expected call of GetName.

func (*MockClusterMetadataStoreMockRecorder) ListClusterMetadata added in v1.14.0 

func (mr *MockClusterMetadataStoreMockRecorder) ListClusterMetadata(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 

func (m *MockExecutionStore) AddHistoryTasks(ctx context.Context, request *persistence.InternalAddHistoryTasksRequest) error

AddHistoryTasks mocks base method.

func (*MockExecutionStore) AppendHistoryNodes added in v1.12.0 

func (m *MockExecutionStore) AppendHistoryNodes(ctx context.Context, request *persistence.InternalAppendHistoryNodesRequest) error

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 

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

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 

func (m *MockExecutionStore) DeleteHistoryBranch(ctx context.Context, request *persistence.InternalDeleteHistoryBranchRequest) error

DeleteHistoryBranch mocks base method.

func (*MockExecutionStore) DeleteHistoryNodes added in v1.12.0 

func (m *MockExecutionStore) DeleteHistoryNodes(ctx context.Context, request *persistence.InternalDeleteHistoryNodesRequest) error

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 

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(ctx context.Context, request *persistence.InternalForkHistoryBranchRequest) error

ForkHistoryBranch mocks base method.

func (*MockExecutionStore) GetAllHistoryTreeBranches added in v1.12.0 

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

GetAllHistoryTreeBranches mocks base method.

func (*MockExecutionStore) GetCurrentExecution 

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

GetCurrentExecution mocks base method.

func (*MockExecutionStore) GetHistoryTask added in v1.16.0 

func (m *MockExecutionStore) GetHistoryTask(ctx context.Context, request *persistence.GetHistoryTaskRequest) (*persistence.InternalGetHistoryTaskResponse, error)

GetHistoryTask mocks base method.

func (*MockExecutionStore) GetHistoryTasks added in v1.16.0 

func (m *MockExecutionStore) GetHistoryTasks(ctx context.Context, request *persistence.GetHistoryTasksRequest) (*persistence.InternalGetHistoryTasksResponse, error)

GetHistoryTasks mocks base method.

func (*MockExecutionStore) GetHistoryTree added in v1.12.0 

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

GetHistoryTree mocks base method.

func (*MockExecutionStore) GetName 

func (m *MockExecutionStore) GetName() string

GetName mocks base method.

func (*MockExecutionStore) GetReplicationTasksFromDLQ 

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

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionStore) GetWorkflowExecution 

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

GetWorkflowExecution mocks base method.

func (*MockExecutionStore) ListConcreteExecutions 

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

ListConcreteExecutions mocks base method.

func (*MockExecutionStore) NewHistoryBranch added in v1.17.3 

func (m *MockExecutionStore) NewHistoryBranch(ctx context.Context, request *persistence.NewHistoryBranchRequest) (*persistence.NewHistoryBranchResponse, error)

NewHistoryBranch mocks base method.

func (*MockExecutionStore) ParseHistoryBranchInfo added in v1.17.3 

func (m *MockExecutionStore) ParseHistoryBranchInfo(ctx context.Context, request *persistence.ParseHistoryBranchInfoRequest) (*persistence.ParseHistoryBranchInfoResponse, error)

ParseHistoryBranchInfo 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 

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

ReadHistoryBranch mocks base method.

func (*MockExecutionStore) SetWorkflowExecution added in v1.16.0 

func (m *MockExecutionStore) SetWorkflowExecution(ctx context.Context, request *persistence.InternalSetWorkflowExecutionRequest) error

SetWorkflowExecution mocks base method.

func (*MockExecutionStore) UpdateHistoryBranchInfo added in v1.17.3 

func (m *MockExecutionStore) UpdateHistoryBranchInfo(ctx context.Context, request *persistence.UpdateHistoryBranchInfoRequest) (*persistence.UpdateHistoryBranchInfoResponse, error)

UpdateHistoryBranchInfo mocks base method.

func (*MockExecutionStore) UpdateWorkflowExecution 

func (m *MockExecutionStore) UpdateWorkflowExecution(ctx context.Context, 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) 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 

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

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

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

GetHistoryTask indicates an expected call of GetHistoryTask.

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 

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

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

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

ListConcreteExecutions indicates an expected call of ListConcreteExecutions.

func (*MockExecutionStoreMockRecorder) NewHistoryBranch added in v1.17.3 

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

NewHistoryBranch indicates an expected call of NewHistoryBranch.

func (*MockExecutionStoreMockRecorder) ParseHistoryBranchInfo added in v1.17.3 

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

ParseHistoryBranchInfo indicates an expected call of ParseHistoryBranchInfo.

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

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

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockExecutionStoreMockRecorder) UpdateHistoryBranchInfo added in v1.17.3 

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

UpdateHistoryBranchInfo indicates an expected call of UpdateHistoryBranchInfo.

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 

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

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 

func (m *MockMetadataStore) EXPECT() *MockMetadataStoreMockRecorder

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

func (*MockMetadataStore) GetMetadata 

func (m *MockMetadataStore) GetMetadata(ctx context.Context) (*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(ctx context.Context, request *persistence.GetNamespaceRequest) (*persistence.InternalGetNamespaceResponse, error)

GetNamespace mocks base method.

func (*MockMetadataStore) ListNamespaces 

func (m *MockMetadataStore) ListNamespaces(ctx context.Context, request *persistence.InternalListNamespacesRequest) (*persistence.InternalListNamespacesResponse, error)

ListNamespaces mocks base method.

func (*MockMetadataStore) RenameNamespace added in v1.16.0 

func (m *MockMetadataStore) RenameNamespace(ctx context.Context, request *persistence.InternalRenameNamespaceRequest) error

RenameNamespace mocks base method.

func (*MockMetadataStore) UpdateNamespace 

func (m *MockMetadataStore) UpdateNamespace(ctx context.Context, 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(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 

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

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 

func (m *MockShardStore) EXPECT() *MockShardStoreMockRecorder

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

func (*MockShardStore) GetClusterName 

func (m *MockShardStore) GetClusterName() string

GetClusterName mocks base method.

func (*MockShardStore) GetName 

func (m *MockShardStore) GetName() string

GetName mocks base method.

func (*MockShardStore) GetOrCreateShard added in v1.14.0 

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

GetOrCreateShard mocks base method.

func (*MockShardStore) UpdateShard 

func (m *MockShardStore) UpdateShard(ctx context.Context, 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) 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) CreateTaskQueue 

func (m *MockTaskStore) CreateTaskQueue(ctx context.Context, request *persistence.InternalCreateTaskQueueRequest) error

CreateTaskQueue mocks base method.

func (*MockTaskStore) CreateTasks 

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

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 

func (m *MockTaskStore) EXPECT() *MockTaskStoreMockRecorder

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 

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

GetTaskQueue mocks base method.

func (*MockTaskStore) GetTasks 

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

GetTasks mocks base method.

func (*MockTaskStore) ListTaskQueue 

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

ListTaskQueue mocks base method.

func (*MockTaskStore) UpdateTaskQueue 

func (m *MockTaskStore) UpdateTaskQueue(ctx context.Context, 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(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) 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) 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) UpdateTaskQueue 

func (mr *MockTaskStoreMockRecorder) UpdateTaskQueue(ctx, 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.