Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockClusterMetadataStore
- func (m *MockClusterMetadataStore) Close()
- func (m *MockClusterMetadataStore) DeleteClusterMetadata(ctx context.Context, request *persistence.InternalDeleteClusterMetadataRequest) error
- func (m *MockClusterMetadataStore) EXPECT() *MockClusterMetadataStoreMockRecorder
- func (m *MockClusterMetadataStore) GetClusterMembers(ctx context.Context, request *persistence.GetClusterMembersRequest) (*persistence.GetClusterMembersResponse, error)
- func (m *MockClusterMetadataStore) GetClusterMetadata(ctx context.Context, request *persistence.InternalGetClusterMetadataRequest) (*persistence.InternalGetClusterMetadataResponse, error)
- func (m *MockClusterMetadataStore) GetName() string
- func (m *MockClusterMetadataStore) ListClusterMetadata(ctx context.Context, request *persistence.InternalListClusterMetadataRequest) (*persistence.InternalListClusterMetadataResponse, error)
- func (m *MockClusterMetadataStore) PruneClusterMembership(ctx context.Context, request *persistence.PruneClusterMembershipRequest) error
- func (m *MockClusterMetadataStore) SaveClusterMetadata(ctx context.Context, request *persistence.InternalSaveClusterMetadataRequest) (bool, error)
- func (m *MockClusterMetadataStore) UpsertClusterMembership(ctx context.Context, request *persistence.UpsertClusterMembershipRequest) error
- type MockClusterMetadataStoreMockRecorder
- func (mr *MockClusterMetadataStoreMockRecorder) Close() *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) DeleteClusterMetadata(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMembers(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) GetClusterMetadata(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) ListClusterMetadata(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) PruneClusterMembership(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) SaveClusterMetadata(ctx, request interface{}) *gomock.Call
- func (mr *MockClusterMetadataStoreMockRecorder) UpsertClusterMembership(ctx, request interface{}) *gomock.Call
- type MockExecutionStore
- func (m *MockExecutionStore) AddHistoryTasks(ctx context.Context, request *persistence.InternalAddHistoryTasksRequest) error
- func (m *MockExecutionStore) AppendHistoryNodes(ctx context.Context, request *persistence.InternalAppendHistoryNodesRequest) error
- func (m *MockExecutionStore) Close()
- func (m *MockExecutionStore) CompleteHistoryTask(ctx context.Context, request *persistence.CompleteHistoryTaskRequest) error
- func (m *MockExecutionStore) ConflictResolveWorkflowExecution(ctx context.Context, ...) error
- func (m *MockExecutionStore) CreateWorkflowExecution(ctx context.Context, ...) (*persistence.InternalCreateWorkflowExecutionResponse, error)
- func (m *MockExecutionStore) DeleteCurrentWorkflowExecution(ctx context.Context, ...) error
- func (m *MockExecutionStore) DeleteHistoryBranch(ctx context.Context, request *persistence.InternalDeleteHistoryBranchRequest) error
- func (m *MockExecutionStore) DeleteHistoryNodes(ctx context.Context, request *persistence.InternalDeleteHistoryNodesRequest) error
- func (m *MockExecutionStore) DeleteReplicationTaskFromDLQ(ctx context.Context, request *persistence.DeleteReplicationTaskFromDLQRequest) error
- func (m *MockExecutionStore) DeleteWorkflowExecution(ctx context.Context, request *persistence.DeleteWorkflowExecutionRequest) error
- func (m *MockExecutionStore) EXPECT() *MockExecutionStoreMockRecorder
- func (m *MockExecutionStore) ForkHistoryBranch(ctx context.Context, request *persistence.InternalForkHistoryBranchRequest) error
- func (m *MockExecutionStore) GetAllHistoryTreeBranches(ctx context.Context, request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.InternalGetAllHistoryTreeBranchesResponse, error)
- func (m *MockExecutionStore) GetCurrentExecution(ctx context.Context, request *persistence.GetCurrentExecutionRequest) (*persistence.InternalGetCurrentExecutionResponse, error)
- func (m *MockExecutionStore) GetHistoryBranchUtil() persistence.HistoryBranchUtil
- func (m *MockExecutionStore) GetHistoryTasks(ctx context.Context, request *persistence.GetHistoryTasksRequest) (*persistence.InternalGetHistoryTasksResponse, error)
- func (m *MockExecutionStore) GetHistoryTreeContainingBranch(ctx context.Context, ...) (*persistence.InternalGetHistoryTreeContainingBranchResponse, error)
- func (m *MockExecutionStore) GetName() string
- func (m *MockExecutionStore) GetReplicationTasksFromDLQ(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.InternalGetReplicationTasksFromDLQResponse, error)
- func (m *MockExecutionStore) GetWorkflowExecution(ctx context.Context, request *persistence.GetWorkflowExecutionRequest) (*persistence.InternalGetWorkflowExecutionResponse, error)
- func (m *MockExecutionStore) IsReplicationDLQEmpty(ctx context.Context, request *persistence.GetReplicationTasksFromDLQRequest) (bool, error)
- func (m *MockExecutionStore) ListConcreteExecutions(ctx context.Context, request *persistence.ListConcreteExecutionsRequest) (*persistence.InternalListConcreteExecutionsResponse, error)
- func (m *MockExecutionStore) PutReplicationTaskToDLQ(ctx context.Context, request *persistence.PutReplicationTaskToDLQRequest) error
- func (m *MockExecutionStore) RangeCompleteHistoryTasks(ctx context.Context, request *persistence.RangeCompleteHistoryTasksRequest) error
- func (m *MockExecutionStore) RangeDeleteReplicationTaskFromDLQ(ctx context.Context, ...) error
- func (m *MockExecutionStore) ReadHistoryBranch(ctx context.Context, request *persistence.InternalReadHistoryBranchRequest) (*persistence.InternalReadHistoryBranchResponse, error)
- func (m *MockExecutionStore) SetWorkflowExecution(ctx context.Context, request *persistence.InternalSetWorkflowExecutionRequest) error
- func (m *MockExecutionStore) UpdateWorkflowExecution(ctx context.Context, ...) error
- type MockExecutionStoreMockRecorder
- func (mr *MockExecutionStoreMockRecorder) AddHistoryTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) AppendHistoryNodes(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) Close() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CompleteHistoryTask(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ConflictResolveWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) CreateWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteCurrentWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteHistoryBranch(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteHistoryNodes(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteReplicationTaskFromDLQ(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) DeleteWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ForkHistoryBranch(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetAllHistoryTreeBranches(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetCurrentExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetHistoryBranchUtil() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetHistoryTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetHistoryTreeContainingBranch(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetReplicationTasksFromDLQ(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) IsReplicationDLQEmpty(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ListConcreteExecutions(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) PutReplicationTaskToDLQ(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeCompleteHistoryTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) RangeDeleteReplicationTaskFromDLQ(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) ReadHistoryBranch(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockExecutionStoreMockRecorder) UpdateWorkflowExecution(ctx, request interface{}) *gomock.Call
- type MockMetadataStore
- func (m *MockMetadataStore) Close()
- func (m *MockMetadataStore) CreateNamespace(ctx context.Context, request *persistence.InternalCreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)
- func (m *MockMetadataStore) DeleteNamespace(ctx context.Context, request *persistence.DeleteNamespaceRequest) error
- func (m *MockMetadataStore) DeleteNamespaceByName(ctx context.Context, request *persistence.DeleteNamespaceByNameRequest) error
- func (m *MockMetadataStore) EXPECT() *MockMetadataStoreMockRecorder
- func (m *MockMetadataStore) GetMetadata(ctx context.Context) (*persistence.GetMetadataResponse, error)
- func (m *MockMetadataStore) GetName() string
- func (m *MockMetadataStore) GetNamespace(ctx context.Context, request *persistence.GetNamespaceRequest) (*persistence.InternalGetNamespaceResponse, error)
- func (m *MockMetadataStore) ListNamespaces(ctx context.Context, request *persistence.InternalListNamespacesRequest) (*persistence.InternalListNamespacesResponse, error)
- func (m *MockMetadataStore) RenameNamespace(ctx context.Context, request *persistence.InternalRenameNamespaceRequest) error
- func (m *MockMetadataStore) UpdateNamespace(ctx context.Context, request *persistence.InternalUpdateNamespaceRequest) error
- type MockMetadataStoreMockRecorder
- func (mr *MockMetadataStoreMockRecorder) Close() *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) CreateNamespace(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) DeleteNamespace(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) DeleteNamespaceByName(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) GetMetadata(ctx interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) GetNamespace(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) ListNamespaces(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) RenameNamespace(ctx, request interface{}) *gomock.Call
- func (mr *MockMetadataStoreMockRecorder) UpdateNamespace(ctx, request interface{}) *gomock.Call
- type MockQueue
- func (m *MockQueue) Close()
- func (m *MockQueue) DeleteMessageFromDLQ(ctx context.Context, messageID int64) error
- func (m *MockQueue) DeleteMessagesBefore(ctx context.Context, messageID int64) error
- func (m *MockQueue) EXPECT() *MockQueueMockRecorder
- func (m *MockQueue) EnqueueMessage(ctx context.Context, blob *common.DataBlob) error
- func (m *MockQueue) EnqueueMessageToDLQ(ctx context.Context, blob *common.DataBlob) (int64, error)
- func (m *MockQueue) GetAckLevels(ctx context.Context) (*persistence.InternalQueueMetadata, error)
- func (m *MockQueue) GetDLQAckLevels(ctx context.Context) (*persistence.InternalQueueMetadata, error)
- func (m *MockQueue) Init(ctx context.Context, blob *common.DataBlob) error
- func (m *MockQueue) RangeDeleteMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64) error
- func (m *MockQueue) ReadMessages(ctx context.Context, lastMessageID int64, maxCount int) ([]*persistence.QueueMessage, error)
- func (m *MockQueue) ReadMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64, pageSize int, ...) ([]*persistence.QueueMessage, []byte, error)
- func (m *MockQueue) UpdateAckLevel(ctx context.Context, metadata *persistence.InternalQueueMetadata) error
- func (m *MockQueue) UpdateDLQAckLevel(ctx context.Context, metadata *persistence.InternalQueueMetadata) error
- type MockQueueMockRecorder
- func (mr *MockQueueMockRecorder) Close() *gomock.Call
- func (mr *MockQueueMockRecorder) DeleteMessageFromDLQ(ctx, messageID interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) DeleteMessagesBefore(ctx, messageID interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) EnqueueMessage(ctx, blob interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) EnqueueMessageToDLQ(ctx, blob interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) GetAckLevels(ctx interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) GetDLQAckLevels(ctx interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) Init(ctx, blob interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) RangeDeleteMessagesFromDLQ(ctx, firstMessageID, lastMessageID interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) ReadMessages(ctx, lastMessageID, maxCount interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) ReadMessagesFromDLQ(ctx, firstMessageID, lastMessageID, pageSize, pageToken interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) UpdateAckLevel(ctx, metadata interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) UpdateDLQAckLevel(ctx, metadata interface{}) *gomock.Call
- type MockQueueV2
- func (m *MockQueueV2) CreateQueue(ctx context.Context, request *persistence.InternalCreateQueueRequest) (*persistence.InternalCreateQueueResponse, error)
- func (m *MockQueueV2) EXPECT() *MockQueueV2MockRecorder
- func (m *MockQueueV2) EnqueueMessage(ctx context.Context, request *persistence.InternalEnqueueMessageRequest) (*persistence.InternalEnqueueMessageResponse, error)
- func (m *MockQueueV2) ListQueues(ctx context.Context, request *persistence.InternalListQueuesRequest) (*persistence.InternalListQueuesResponse, error)
- func (m *MockQueueV2) RangeDeleteMessages(ctx context.Context, request *persistence.InternalRangeDeleteMessagesRequest) (*persistence.InternalRangeDeleteMessagesResponse, error)
- func (m *MockQueueV2) ReadMessages(ctx context.Context, request *persistence.InternalReadMessagesRequest) (*persistence.InternalReadMessagesResponse, error)
- type MockQueueV2MockRecorder
- func (mr *MockQueueV2MockRecorder) CreateQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockQueueV2MockRecorder) EnqueueMessage(ctx, request interface{}) *gomock.Call
- func (mr *MockQueueV2MockRecorder) ListQueues(ctx, request interface{}) *gomock.Call
- func (mr *MockQueueV2MockRecorder) RangeDeleteMessages(ctx, request interface{}) *gomock.Call
- func (mr *MockQueueV2MockRecorder) ReadMessages(ctx, request interface{}) *gomock.Call
- type MockShardStore
- func (m *MockShardStore) AssertShardOwnership(ctx context.Context, request *persistence.AssertShardOwnershipRequest) error
- func (m *MockShardStore) Close()
- func (m *MockShardStore) EXPECT() *MockShardStoreMockRecorder
- func (m *MockShardStore) GetClusterName() string
- func (m *MockShardStore) GetName() string
- func (m *MockShardStore) GetOrCreateShard(ctx context.Context, request *persistence.InternalGetOrCreateShardRequest) (*persistence.InternalGetOrCreateShardResponse, error)
- func (m *MockShardStore) UpdateShard(ctx context.Context, request *persistence.InternalUpdateShardRequest) error
- type MockShardStoreMockRecorder
- func (mr *MockShardStoreMockRecorder) AssertShardOwnership(ctx, request interface{}) *gomock.Call
- func (mr *MockShardStoreMockRecorder) Close() *gomock.Call
- func (mr *MockShardStoreMockRecorder) GetClusterName() *gomock.Call
- func (mr *MockShardStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockShardStoreMockRecorder) GetOrCreateShard(ctx, request interface{}) *gomock.Call
- func (mr *MockShardStoreMockRecorder) UpdateShard(ctx, request interface{}) *gomock.Call
- type MockTaskStore
- func (m *MockTaskStore) Close()
- func (m *MockTaskStore) CompleteTask(ctx context.Context, request *persistence.CompleteTaskRequest) error
- func (m *MockTaskStore) CompleteTasksLessThan(ctx context.Context, request *persistence.CompleteTasksLessThanRequest) (int, error)
- func (m *MockTaskStore) CountTaskQueuesByBuildId(ctx context.Context, request *persistence.CountTaskQueuesByBuildIdRequest) (int, error)
- func (m *MockTaskStore) CreateTaskQueue(ctx context.Context, request *persistence.InternalCreateTaskQueueRequest) error
- func (m *MockTaskStore) CreateTasks(ctx context.Context, request *persistence.InternalCreateTasksRequest) (*persistence.CreateTasksResponse, error)
- func (m *MockTaskStore) DeleteTaskQueue(ctx context.Context, request *persistence.DeleteTaskQueueRequest) error
- func (m *MockTaskStore) EXPECT() *MockTaskStoreMockRecorder
- func (m *MockTaskStore) GetName() string
- func (m *MockTaskStore) GetTaskQueue(ctx context.Context, request *persistence.InternalGetTaskQueueRequest) (*persistence.InternalGetTaskQueueResponse, error)
- func (m *MockTaskStore) GetTaskQueueUserData(ctx context.Context, request *persistence.GetTaskQueueUserDataRequest) (*persistence.InternalGetTaskQueueUserDataResponse, error)
- func (m *MockTaskStore) GetTaskQueuesByBuildId(ctx context.Context, request *persistence.GetTaskQueuesByBuildIdRequest) ([]string, error)
- func (m *MockTaskStore) GetTasks(ctx context.Context, request *persistence.GetTasksRequest) (*persistence.InternalGetTasksResponse, error)
- func (m *MockTaskStore) ListTaskQueue(ctx context.Context, request *persistence.ListTaskQueueRequest) (*persistence.InternalListTaskQueueResponse, error)
- func (m *MockTaskStore) ListTaskQueueUserDataEntries(ctx context.Context, request *persistence.ListTaskQueueUserDataEntriesRequest) (*persistence.InternalListTaskQueueUserDataEntriesResponse, error)
- func (m *MockTaskStore) UpdateTaskQueue(ctx context.Context, request *persistence.InternalUpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)
- func (m *MockTaskStore) UpdateTaskQueueUserData(ctx context.Context, ...) error
- type MockTaskStoreMockRecorder
- func (mr *MockTaskStoreMockRecorder) Close() *gomock.Call
- func (mr *MockTaskStoreMockRecorder) CompleteTask(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) CompleteTasksLessThan(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) CountTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) CreateTaskQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) CreateTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) DeleteTaskQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) GetName() *gomock.Call
- func (mr *MockTaskStoreMockRecorder) GetTaskQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) GetTaskQueueUserData(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) GetTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) GetTasks(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) ListTaskQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) ListTaskQueueUserDataEntries(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) UpdateTaskQueue(ctx, request interface{}) *gomock.Call
- func (mr *MockTaskStoreMockRecorder) UpdateTaskQueueUserData(ctx, request interface{}) *gomock.Call
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) 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) GetHistoryBranchUtil ¶ added in v1.21.0
func (m *MockExecutionStore) GetHistoryBranchUtil() persistence.HistoryBranchUtil
GetHistoryBranchUtil 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) GetHistoryTreeContainingBranch ¶ added in v1.24.0
func (m *MockExecutionStore) GetHistoryTreeContainingBranch(ctx context.Context, request *persistence.InternalGetHistoryTreeContainingBranchRequest) (*persistence.InternalGetHistoryTreeContainingBranchResponse, error)
GetHistoryTreeContainingBranch 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) 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 ¶
func (m *MockExecutionStore) ListConcreteExecutions(ctx context.Context, request *persistence.ListConcreteExecutionsRequest) (*persistence.InternalListConcreteExecutionsResponse, error)
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
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) 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) 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) GetHistoryTreeContainingBranch ¶ added in v1.24.0
func (mr *MockExecutionStoreMockRecorder) GetHistoryTreeContainingBranch(ctx, request interface{}) *gomock.Call
GetHistoryTreeContainingBranch indicates an expected call of GetHistoryTreeContainingBranch.
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) 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) SetWorkflowExecution ¶ added in v1.16.0
func (mr *MockExecutionStoreMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call
SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
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) 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) DeleteMessageFromDLQ ¶
DeleteMessageFromDLQ mocks base method.
func (*MockQueue) DeleteMessagesBefore ¶
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 ¶
EnqueueMessage mocks base method.
func (*MockQueue) EnqueueMessageToDLQ ¶
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) 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 MockQueueV2 ¶ added in v1.23.0
type MockQueueV2 struct {
// contains filtered or unexported fields
}
MockQueueV2 is a mock of QueueV2 interface.
func NewMockQueueV2 ¶ added in v1.23.0
func NewMockQueueV2(ctrl *gomock.Controller) *MockQueueV2
NewMockQueueV2 creates a new mock instance.
func (*MockQueueV2) CreateQueue ¶ added in v1.23.0
func (m *MockQueueV2) CreateQueue(ctx context.Context, request *persistence.InternalCreateQueueRequest) (*persistence.InternalCreateQueueResponse, error)
CreateQueue mocks base method.
func (*MockQueueV2) EXPECT ¶ added in v1.23.0
func (m *MockQueueV2) EXPECT() *MockQueueV2MockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueV2) EnqueueMessage ¶ added in v1.23.0
func (m *MockQueueV2) EnqueueMessage(ctx context.Context, request *persistence.InternalEnqueueMessageRequest) (*persistence.InternalEnqueueMessageResponse, error)
EnqueueMessage mocks base method.
func (*MockQueueV2) ListQueues ¶ added in v1.23.0
func (m *MockQueueV2) ListQueues(ctx context.Context, request *persistence.InternalListQueuesRequest) (*persistence.InternalListQueuesResponse, error)
ListQueues mocks base method.
func (*MockQueueV2) RangeDeleteMessages ¶ added in v1.23.0
func (m *MockQueueV2) RangeDeleteMessages(ctx context.Context, request *persistence.InternalRangeDeleteMessagesRequest) (*persistence.InternalRangeDeleteMessagesResponse, error)
RangeDeleteMessages mocks base method.
func (*MockQueueV2) ReadMessages ¶ added in v1.23.0
func (m *MockQueueV2) ReadMessages(ctx context.Context, request *persistence.InternalReadMessagesRequest) (*persistence.InternalReadMessagesResponse, error)
ReadMessages mocks base method.
type MockQueueV2MockRecorder ¶ added in v1.23.0
type MockQueueV2MockRecorder struct {
// contains filtered or unexported fields
}
MockQueueV2MockRecorder is the mock recorder for MockQueueV2.
func (*MockQueueV2MockRecorder) CreateQueue ¶ added in v1.23.0
func (mr *MockQueueV2MockRecorder) CreateQueue(ctx, request interface{}) *gomock.Call
CreateQueue indicates an expected call of CreateQueue.
func (*MockQueueV2MockRecorder) EnqueueMessage ¶ added in v1.23.0
func (mr *MockQueueV2MockRecorder) EnqueueMessage(ctx, request interface{}) *gomock.Call
EnqueueMessage indicates an expected call of EnqueueMessage.
func (*MockQueueV2MockRecorder) ListQueues ¶ added in v1.23.0
func (mr *MockQueueV2MockRecorder) ListQueues(ctx, request interface{}) *gomock.Call
ListQueues indicates an expected call of ListQueues.
func (*MockQueueV2MockRecorder) RangeDeleteMessages ¶ added in v1.23.0
func (mr *MockQueueV2MockRecorder) RangeDeleteMessages(ctx, request interface{}) *gomock.Call
RangeDeleteMessages indicates an expected call of RangeDeleteMessages.
func (*MockQueueV2MockRecorder) ReadMessages ¶ added in v1.23.0
func (mr *MockQueueV2MockRecorder) ReadMessages(ctx, request interface{}) *gomock.Call
ReadMessages indicates an expected call of ReadMessages.
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) 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) 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 ¶
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) GetTaskQueue ¶
func (m *MockTaskStore) GetTaskQueue(ctx context.Context, request *persistence.InternalGetTaskQueueRequest) (*persistence.InternalGetTaskQueueResponse, error)
GetTaskQueue mocks base method.
func (*MockTaskStore) GetTaskQueueUserData ¶ added in v1.21.0
func (m *MockTaskStore) GetTaskQueueUserData(ctx context.Context, request *persistence.GetTaskQueueUserDataRequest) (*persistence.InternalGetTaskQueueUserDataResponse, error)
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 ¶
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) ListTaskQueueUserDataEntries ¶ added in v1.21.0
func (m *MockTaskStore) ListTaskQueueUserDataEntries(ctx context.Context, request *persistence.ListTaskQueueUserDataEntriesRequest) (*persistence.InternalListTaskQueueUserDataEntriesResponse, error)
ListTaskQueueUserDataEntries mocks base method.
func (*MockTaskStore) UpdateTaskQueue ¶
func (m *MockTaskStore) UpdateTaskQueue(ctx context.Context, request *persistence.InternalUpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)
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.