mocks

package
v1.6.6 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Code generated by mockery v1.0.0. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockMessagingClient added in v0.3.11 

func NewMockMessagingClient(publisher messaging.Producer, consumer messaging.Consumer) messaging.Client

NewMockMessagingClient generate a dummy implementation of messaging client

Types

type ClusterMetadata added in v0.3.11 

type ClusterMetadata struct {
	mock.Mock
}

ClusterMetadata is an autogenerated mock type for the Metadata type

func (*ClusterMetadata) ClusterNameForFailoverVersion added in v0.3.11 

func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

ClusterNameForFailoverVersion provides a mock function with given fields:

func (*ClusterMetadata) GetAllClusterInfo added in v0.5.8 

func (_m *ClusterMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

GetAllClusterInfo provides a mock function with given fields:

func (*ClusterMetadata) GetCurrentClusterName added in v0.3.11 

func (_m *ClusterMetadata) GetCurrentClusterName() string

GetCurrentClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetDeploymentGroup added in v0.5.0 

func (_m *ClusterMetadata) GetDeploymentGroup() string

GetDeploymentGroup provides a mock function with given fields:

func (*ClusterMetadata) GetMasterClusterName added in v0.3.11 

func (_m *ClusterMetadata) GetMasterClusterName() string

GetMasterClusterName provides a mock function with given fields:

func (*ClusterMetadata) GetNextFailoverVersion added in v0.3.11 

func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 string, _a1 int64) int64

GetNextFailoverVersion provides a mock function with given fields: _a0, _a1

func (*ClusterMetadata) IsGlobalNamespaceEnabled added in v0.27.0 

func (_m *ClusterMetadata) IsGlobalNamespaceEnabled() bool

IsGlobalNamespaceEnabled provides a mock function with given fields:

func (*ClusterMetadata) IsMasterCluster added in v0.3.11 

func (_m *ClusterMetadata) IsMasterCluster() bool

IsMasterCluster provides a mock function with given fields:

func (*ClusterMetadata) IsVersionFromSameCluster added in v0.3.14 

func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool

IsVersionFromSameCluster provides a mock function with given fields: _a0, _a1

type ExecutionManager 

type ExecutionManager struct {
	mock.Mock
}

ExecutionManager mock implementation

func (*ExecutionManager) AddTasks added in v1.5.0 

func (_m *ExecutionManager) AddTasks(request *persistence.AddTasksRequest) error

AddTasks provides a mock function with given fields: request

func (*ExecutionManager) Close 

func (_m *ExecutionManager) Close()

Close provides a mock function with given fields:

func (*ExecutionManager) CompleteReplicationTask added in v0.3.11 

func (_m *ExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTimerTask 

func (_m *ExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteTransferTask 

func (_m *ExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) CompleteVisibilityTask added in v1.5.0 

func (_m *ExecutionManager) CompleteVisibilityTask(request *persistence.CompleteVisibilityTaskRequest) error

CompleteVisibilityTask provides a mock function with given fields: request

func (*ExecutionManager) ConflictResolveWorkflowExecution added in v0.7.0 

func (_m *ExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

ConflictResolveWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) CreateWorkflowExecution 

func (_m *ExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteCurrentWorkflowExecution added in v0.5.8 

func (_m *ExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) DeleteReplicationTaskFromDLQ added in v0.27.0 

func (_m *ExecutionManager) DeleteReplicationTaskFromDLQ(
	request *persistence.DeleteReplicationTaskFromDLQRequest,
) error

DeleteReplicationTaskFromDLQ provides a mock function with given fields: request

func (*ExecutionManager) DeleteWorkflowExecution 

func (_m *ExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) GetCurrentExecution 

func (_m *ExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

GetCurrentExecution provides a mock function with given fields: request

func (*ExecutionManager) GetName added in v0.4.0 

func (_m *ExecutionManager) GetName() string

GetName provides a mock function with given fields:

func (*ExecutionManager) GetReplicationTask added in v0.27.0 

func (_m *ExecutionManager) GetReplicationTask(request *persistence.GetReplicationTaskRequest) (*persistence.GetReplicationTaskResponse, error)

GetReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) GetReplicationTasks added in v0.3.11 

func (_m *ExecutionManager) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)

GetReplicationTasks provides a mock function with given fields: request

func (*ExecutionManager) GetReplicationTasksFromDLQ added in v0.27.0 

func (_m *ExecutionManager) GetReplicationTasksFromDLQ(request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationTasksFromDLQResponse, error)

GetReplicationTasksFromDLQ provides a mock function with given fields: request

func (*ExecutionManager) GetShardID added in v0.5.0 

func (_m *ExecutionManager) GetShardID() int32

GetShardID provides a mock function with given fields:

func (*ExecutionManager) GetTimerIndexTasks 

func (_m *ExecutionManager) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

GetTimerIndexTasks provides a mock function with given fields: request

func (*ExecutionManager) GetTimerTask added in v0.27.0 

func (_m *ExecutionManager) GetTimerTask(request *persistence.GetTimerTaskRequest) (*persistence.GetTimerTaskResponse, error)

GetTimerTask provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTask added in v0.27.0 

func (_m *ExecutionManager) GetTransferTask(request *persistence.GetTransferTaskRequest) (*persistence.GetTransferTaskResponse, error)

GetTransferTask provides a mock function with given fields: request

func (*ExecutionManager) GetTransferTasks 

func (_m *ExecutionManager) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)

GetTransferTasks provides a mock function with given fields: request

func (*ExecutionManager) GetVisibilityTask added in v1.5.0 

func (_m *ExecutionManager) GetVisibilityTask(request *persistence.GetVisibilityTaskRequest) (*persistence.GetVisibilityTaskResponse, error)

GetVisibilityTask provides a mock function with given fields: request

func (*ExecutionManager) GetVisibilityTasks added in v1.5.0 

func (_m *ExecutionManager) GetVisibilityTasks(request *persistence.GetVisibilityTasksRequest) (*persistence.GetVisibilityTasksResponse, error)

GetVisibilityTasks provides a mock function with given fields: request

func (*ExecutionManager) GetWorkflowExecution 

func (_m *ExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

GetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) ListConcreteExecutions added in v0.27.0 

func (_m *ExecutionManager) ListConcreteExecutions(request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

ListConcreteExecutions provides a mock function with given fields: request

func (*ExecutionManager) PutReplicationTaskToDLQ added in v0.27.0 

func (_m *ExecutionManager) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteReplicationTask added in v0.27.0 

func (_m *ExecutionManager) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

RangeCompleteReplicationTask provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteTimerTask added in v0.4.0 

func (_m *ExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

RangeCompleteTimerTask provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteTransferTask added in v0.4.0 

func (_m *ExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

RangeCompleteTransferTask provides a mock function with given fields: request

func (*ExecutionManager) RangeCompleteVisibilityTask added in v1.5.0 

func (_m *ExecutionManager) RangeCompleteVisibilityTask(request *persistence.RangeCompleteVisibilityTaskRequest) error

RangeCompleteVisibilityTask provides a mock function with given fields: request

func (*ExecutionManager) RangeDeleteReplicationTaskFromDLQ added in v0.27.0 

func (_m *ExecutionManager) RangeDeleteReplicationTaskFromDLQ(
	request *persistence.RangeDeleteReplicationTaskFromDLQRequest,
) error

RangeDeleteReplicationTaskFromDLQ provides a mock function with given fields: request

func (*ExecutionManager) ResetWorkflowExecution added in v0.5.2 

func (_m *ExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

ResetWorkflowExecution provides a mock function with given fields: request

func (*ExecutionManager) UpdateWorkflowExecution 

func (_m *ExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)

UpdateWorkflowExecution provides a mock function with given fields: request

type ExecutionManagerFactory 

type ExecutionManagerFactory struct {
	mock.Mock
}

ExecutionManagerFactory is an autogenerated mock type for the ExecutionManagerFactory type

func (*ExecutionManagerFactory) Close added in v0.3.2 

func (_m *ExecutionManagerFactory) Close()

Close is mock implementation for Close of ExecutionManagerFactory

func (*ExecutionManagerFactory) NewExecutionManager added in v0.4.0 

func (_m *ExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

NewExecutionManager provides a mock function with given fields: shardID

type HistoryV2Manager added in v0.5.0 

type HistoryV2Manager struct {
	mock.Mock
}

HistoryManager mock implementation

func (*HistoryV2Manager) AppendHistoryNodes added in v0.5.0 

func (_m *HistoryV2Manager) AppendHistoryNodes(request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

AppendHistoryNodes provides a mock function with given fields: request

func (*HistoryV2Manager) Close added in v0.5.0 

func (_m *HistoryV2Manager) Close()

Close provides a mock function with given fields:

func (*HistoryV2Manager) CompleteForkBranch added in v0.5.2 

func (_m *HistoryV2Manager) CompleteForkBranch(request *persistence.CompleteForkBranchRequest) error

CompleteForkBranch provides a mock function with given fields: request

func (*HistoryV2Manager) DeleteHistoryBranch added in v0.5.0 

func (_m *HistoryV2Manager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

DeleteHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ForkHistoryBranch added in v0.5.0 

func (_m *HistoryV2Manager) ForkHistoryBranch(request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

ForkHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) GetAllHistoryTreeBranches added in v0.27.0 

func (_m *HistoryV2Manager) GetAllHistoryTreeBranches(request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

func (*HistoryV2Manager) GetHistoryTree added in v0.5.0 

func (_m *HistoryV2Manager) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

GetHistoryTree provides a mock function with given fields: request

func (*HistoryV2Manager) GetName added in v0.5.0 

func (_m *HistoryV2Manager) GetName() string

GetName provides a mock function with given fields:

func (*HistoryV2Manager) ReadHistoryBranch added in v0.5.0 

func (_m *HistoryV2Manager) ReadHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

ReadHistoryBranch provides a mock function with given fields: request

func (*HistoryV2Manager) ReadHistoryBranchByBatch added in v0.5.0 

func (_m *HistoryV2Manager) ReadHistoryBranchByBatch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

ReadHistoryBranchByBatch provides a mock function with given fields: request

func (*HistoryV2Manager) ReadRawHistoryBranch added in v0.27.0 

func (_m *HistoryV2Manager) ReadRawHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

ReadRawHistoryBranch provides a mock function with given fields: request

type KafkaProducer added in v0.3.7 

type KafkaProducer struct {
	mock.Mock
}

KafkaProducer is an autogenerated mock type for the KafkaProducer type

func (*KafkaProducer) Close added in v0.3.7 

func (_m *KafkaProducer) Close() error

Close provides a mock function with given fields:

func (*KafkaProducer) Publish added in v0.3.7 

func (_m *KafkaProducer) Publish(msg interface{}) error

Publish provides a mock function with given fields: msg

type MessagingClient added in v0.3.11 

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

MessagingClient is the mock implementation for Service interface

func (*MessagingClient) NewConsumer added in v0.3.11 

func (c *MessagingClient) NewConsumer(appName, consumerName string, concurrency int) (messaging.Consumer, error)

NewConsumer generates a dummy implementation of kafka consumer

func (*MessagingClient) NewConsumerWithClusterName added in v0.5.2 

func (c *MessagingClient) NewConsumerWithClusterName(currentCluster, sourceCluster, consumerName string, concurrency int) (messaging.Consumer, error)

NewConsumerWithClusterName generates a dummy implementation of kafka consumer

func (*MessagingClient) NewProducer added in v0.3.11 

func (c *MessagingClient) NewProducer(appName string) (messaging.Producer, error)

NewProducer generates a dummy implementation of kafka producer

func (*MessagingClient) NewProducerWithClusterName added in v0.5.0 

func (c *MessagingClient) NewProducerWithClusterName(sourceCluster string) (messaging.Producer, error)

NewProducerWithClusterName generates a dummy implementation of kafka producer

type MetadataManager 

type MetadataManager struct {
	mock.Mock
}

MetadataManager is an autogenerated mock type for the MetadataManager type

func (*MetadataManager) Close 

func (_m *MetadataManager) Close()

Close provides a mock function with given fields:

func (*MetadataManager) CreateNamespace added in v0.27.0 

func (_m *MetadataManager) CreateNamespace(request *persistence.CreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)

CreateNamespace provides a mock function with given fields: request

func (*MetadataManager) DeleteNamespace added in v0.27.0 

func (_m *MetadataManager) DeleteNamespace(request *persistence.DeleteNamespaceRequest) error

DeleteNamespace provides a mock function with given fields: request

func (*MetadataManager) DeleteNamespaceByName added in v0.27.0 

func (_m *MetadataManager) DeleteNamespaceByName(request *persistence.DeleteNamespaceByNameRequest) error

DeleteNamespaceByName provides a mock function with given fields: request

func (*MetadataManager) GetMetadata added in v0.3.13 

func (_m *MetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)

GetMetadata provides a mock function with given fields: request

func (*MetadataManager) GetName added in v0.4.0 

func (_m *MetadataManager) GetName() string

GetName provides a mock function with given fields:

func (*MetadataManager) GetNamespace added in v0.27.0 

func (_m *MetadataManager) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

GetNamespace provides a mock function with given fields: request

func (*MetadataManager) InitializeSystemNamespaces added in v0.27.0 

func (_m *MetadataManager) InitializeSystemNamespaces(currentClusterName string) error

func (*MetadataManager) ListNamespaces added in v0.27.0 

func (_m *MetadataManager) ListNamespaces(request *persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

ListNamespaces provides a mock function with given fields: request

func (*MetadataManager) UpdateNamespace added in v0.27.0 

func (_m *MetadataManager) UpdateNamespace(request *persistence.UpdateNamespaceRequest) error

UpdateNamespace provides a mock function with given fields: request

type MockCloseable added in v0.27.0 

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

MockCloseable is a mock of Closeable interface.

func NewMockCloseable added in v0.27.0 

func NewMockCloseable(ctrl *gomock.Controller) *MockCloseable

NewMockCloseable creates a new mock instance.

func (*MockCloseable) Close added in v0.27.0 

func (m *MockCloseable) Close()

Close mocks base method.

func (*MockCloseable) EXPECT added in v0.27.0 

func (m *MockCloseable) EXPECT() *MockCloseableMockRecorder

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

type MockCloseableMockRecorder added in v0.27.0 

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

MockCloseableMockRecorder is the mock recorder for MockCloseable.

func (*MockCloseableMockRecorder) Close added in v0.27.0 

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

Close indicates an expected call of Close.

type MockClusterMetadataManager added in v0.27.0 

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

MockClusterMetadataManager is a mock of ClusterMetadataManager interface.

func NewMockClusterMetadataManager added in v0.27.0 

func NewMockClusterMetadataManager(ctrl *gomock.Controller) *MockClusterMetadataManager

NewMockClusterMetadataManager creates a new mock instance.

func (*MockClusterMetadataManager) Close added in v0.27.0 

func (m *MockClusterMetadataManager) Close()

Close mocks base method.

func (*MockClusterMetadataManager) EXPECT added in v0.27.0 

func (m *MockClusterMetadataManager) EXPECT() *MockClusterMetadataManagerMockRecorder

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

func (*MockClusterMetadataManager) GetClusterMembers added in v0.27.0 

func (m *MockClusterMetadataManager) GetClusterMembers(request *persistence.GetClusterMembersRequest) (*persistence.GetClusterMembersResponse, error)

GetClusterMembers mocks base method.

func (*MockClusterMetadataManager) GetClusterMetadata added in v1.1.0 

func (m *MockClusterMetadataManager) GetClusterMetadata() (*persistence.GetClusterMetadataResponse, error)

GetClusterMetadata mocks base method.

func (*MockClusterMetadataManager) GetName added in v0.27.0 

func (m *MockClusterMetadataManager) GetName() string

GetName mocks base method.

func (*MockClusterMetadataManager) PruneClusterMembership added in v0.27.0 

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

PruneClusterMembership mocks base method.

func (*MockClusterMetadataManager) SaveClusterMetadata added in v1.1.0 

func (m *MockClusterMetadataManager) SaveClusterMetadata(request *persistence.SaveClusterMetadataRequest) (bool, error)

SaveClusterMetadata mocks base method.

func (*MockClusterMetadataManager) UpsertClusterMembership added in v0.27.0 

func (m *MockClusterMetadataManager) UpsertClusterMembership(request *persistence.UpsertClusterMembershipRequest) error

UpsertClusterMembership mocks base method.

type MockClusterMetadataManagerMockRecorder added in v0.27.0 

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

MockClusterMetadataManagerMockRecorder is the mock recorder for MockClusterMetadataManager.

func (*MockClusterMetadataManagerMockRecorder) Close added in v0.27.0 

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

Close indicates an expected call of Close.

func (*MockClusterMetadataManagerMockRecorder) GetClusterMembers added in v0.27.0 

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

GetClusterMembers indicates an expected call of GetClusterMembers.

func (*MockClusterMetadataManagerMockRecorder) GetClusterMetadata added in v1.1.0 

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

GetClusterMetadata indicates an expected call of GetClusterMetadata.

func (*MockClusterMetadataManagerMockRecorder) GetName added in v0.27.0 

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

GetName indicates an expected call of GetName.

func (*MockClusterMetadataManagerMockRecorder) PruneClusterMembership added in v0.27.0 

func (mr *MockClusterMetadataManagerMockRecorder) PruneClusterMembership(request interface{}) *gomock.Call

PruneClusterMembership indicates an expected call of PruneClusterMembership.

func (*MockClusterMetadataManagerMockRecorder) SaveClusterMetadata added in v1.1.0 

func (mr *MockClusterMetadataManagerMockRecorder) SaveClusterMetadata(request interface{}) *gomock.Call

SaveClusterMetadata indicates an expected call of SaveClusterMetadata.

func (*MockClusterMetadataManagerMockRecorder) UpsertClusterMembership added in v0.27.0 

func (mr *MockClusterMetadataManagerMockRecorder) UpsertClusterMembership(request interface{}) *gomock.Call

UpsertClusterMembership indicates an expected call of UpsertClusterMembership.

type MockExecutionManager added in v1.1.0 

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

MockExecutionManager is a mock of ExecutionManager interface.

func NewMockExecutionManager added in v1.1.0 

func NewMockExecutionManager(ctrl *gomock.Controller) *MockExecutionManager

NewMockExecutionManager creates a new mock instance.

func (*MockExecutionManager) Close added in v1.1.0 

func (m *MockExecutionManager) Close()

Close mocks base method.

func (*MockExecutionManager) CompleteReplicationTask added in v1.1.0 

func (m *MockExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

CompleteReplicationTask mocks base method.

func (*MockExecutionManager) CompleteTimerTask added in v1.1.0 

func (m *MockExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

CompleteTimerTask mocks base method.

func (*MockExecutionManager) CompleteTransferTask added in v1.1.0 

func (m *MockExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

CompleteTransferTask mocks base method.

func (*MockExecutionManager) ConflictResolveWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

ConflictResolveWorkflowExecution mocks base method.

func (*MockExecutionManager) CreateWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecution mocks base method.

func (*MockExecutionManager) DeleteCurrentWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

DeleteCurrentWorkflowExecution mocks base method.

func (*MockExecutionManager) DeleteReplicationTaskFromDLQ added in v1.1.0 

func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(request *persistence.DeleteReplicationTaskFromDLQRequest) error

DeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionManager) DeleteWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution mocks base method.

func (*MockExecutionManager) EXPECT added in v1.1.0 

func (m *MockExecutionManager) EXPECT() *MockExecutionManagerMockRecorder

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

func (*MockExecutionManager) GetCurrentExecution added in v1.1.0 

func (m *MockExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

GetCurrentExecution mocks base method.

func (*MockExecutionManager) GetName added in v1.1.0 

func (m *MockExecutionManager) GetName() string

GetName mocks base method.

func (*MockExecutionManager) GetReplicationTask added in v1.1.0 

func (m *MockExecutionManager) GetReplicationTask(request *persistence.GetReplicationTaskRequest) (*persistence.GetReplicationTaskResponse, error)

GetReplicationTask mocks base method.

func (*MockExecutionManager) GetReplicationTasks added in v1.1.0 

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

GetReplicationTasks mocks base method.

func (*MockExecutionManager) GetReplicationTasksFromDLQ added in v1.1.0 

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

GetReplicationTasksFromDLQ mocks base method.

func (*MockExecutionManager) GetShardID added in v1.1.0 

func (m *MockExecutionManager) GetShardID() int

GetShardID mocks base method.

func (*MockExecutionManager) GetTimerIndexTasks added in v1.1.0 

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

GetTimerIndexTasks mocks base method.

func (*MockExecutionManager) GetTimerTask added in v1.1.0 

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

GetTimerTask mocks base method.

func (*MockExecutionManager) GetTransferTask added in v1.1.0 

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

GetTransferTask mocks base method.

func (*MockExecutionManager) GetTransferTasks added in v1.1.0 

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

GetTransferTasks mocks base method.

func (*MockExecutionManager) GetWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

GetWorkflowExecution mocks base method.

func (*MockExecutionManager) ListConcreteExecutions added in v1.1.0 

func (m *MockExecutionManager) ListConcreteExecutions(request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

ListConcreteExecutions mocks base method.

func (*MockExecutionManager) PutReplicationTaskToDLQ added in v1.1.0 

func (m *MockExecutionManager) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

PutReplicationTaskToDLQ mocks base method.

func (*MockExecutionManager) RangeCompleteReplicationTask added in v1.1.0 

func (m *MockExecutionManager) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

RangeCompleteReplicationTask mocks base method.

func (*MockExecutionManager) RangeCompleteTimerTask added in v1.1.0 

func (m *MockExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

RangeCompleteTimerTask mocks base method.

func (*MockExecutionManager) RangeCompleteTransferTask added in v1.1.0 

func (m *MockExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

RangeCompleteTransferTask mocks base method.

func (*MockExecutionManager) RangeDeleteReplicationTaskFromDLQ added in v1.1.0 

func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

RangeDeleteReplicationTaskFromDLQ mocks base method.

func (*MockExecutionManager) ResetWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

ResetWorkflowExecution mocks base method.

func (*MockExecutionManager) UpdateWorkflowExecution added in v1.1.0 

func (m *MockExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)

UpdateWorkflowExecution mocks base method.

type MockExecutionManagerFactory added in v1.1.0 

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

MockExecutionManagerFactory is a mock of ExecutionManagerFactory interface.

func NewMockExecutionManagerFactory added in v1.1.0 

func NewMockExecutionManagerFactory(ctrl *gomock.Controller) *MockExecutionManagerFactory

NewMockExecutionManagerFactory creates a new mock instance.

func (*MockExecutionManagerFactory) Close added in v1.1.0 

func (m *MockExecutionManagerFactory) Close()

Close mocks base method.

func (*MockExecutionManagerFactory) EXPECT added in v1.1.0 

func (m *MockExecutionManagerFactory) EXPECT() *MockExecutionManagerFactoryMockRecorder

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

func (*MockExecutionManagerFactory) NewExecutionManager added in v1.1.0 

func (m *MockExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

NewExecutionManager mocks base method.

type MockExecutionManagerFactoryMockRecorder added in v1.1.0 

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

MockExecutionManagerFactoryMockRecorder is the mock recorder for MockExecutionManagerFactory.

func (*MockExecutionManagerFactoryMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockExecutionManagerFactoryMockRecorder) NewExecutionManager added in v1.1.0 

func (mr *MockExecutionManagerFactoryMockRecorder) NewExecutionManager(shardID interface{}) *gomock.Call

NewExecutionManager indicates an expected call of NewExecutionManager.

type MockExecutionManagerMockRecorder added in v1.1.0 

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

MockExecutionManagerMockRecorder is the mock recorder for MockExecutionManager.

func (*MockExecutionManagerMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockExecutionManagerMockRecorder) CompleteReplicationTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) CompleteReplicationTask(request interface{}) *gomock.Call

CompleteReplicationTask indicates an expected call of CompleteReplicationTask.

func (*MockExecutionManagerMockRecorder) CompleteTimerTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) CompleteTimerTask(request interface{}) *gomock.Call

CompleteTimerTask indicates an expected call of CompleteTimerTask.

func (*MockExecutionManagerMockRecorder) CompleteTransferTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) CompleteTransferTask(request interface{}) *gomock.Call

CompleteTransferTask indicates an expected call of CompleteTransferTask.

func (*MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution(request interface{}) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockExecutionManagerMockRecorder) CreateWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) CreateWorkflowExecution(request interface{}) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution(request interface{}) *gomock.Call

DeleteCurrentWorkflowExecution indicates an expected call of DeleteCurrentWorkflowExecution.

func (*MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

DeleteReplicationTaskFromDLQ indicates an expected call of DeleteReplicationTaskFromDLQ.

func (*MockExecutionManagerMockRecorder) DeleteWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockExecutionManagerMockRecorder) GetCurrentExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetCurrentExecution(request interface{}) *gomock.Call

GetCurrentExecution indicates an expected call of GetCurrentExecution.

func (*MockExecutionManagerMockRecorder) GetName added in v1.1.0 

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

GetName indicates an expected call of GetName.

func (*MockExecutionManagerMockRecorder) GetReplicationTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetReplicationTask(request interface{}) *gomock.Call

GetReplicationTask indicates an expected call of GetReplicationTask.

func (*MockExecutionManagerMockRecorder) GetReplicationTasks added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetReplicationTasks(request interface{}) *gomock.Call

GetReplicationTasks indicates an expected call of GetReplicationTasks.

func (*MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ(request interface{}) *gomock.Call

GetReplicationTasksFromDLQ indicates an expected call of GetReplicationTasksFromDLQ.

func (*MockExecutionManagerMockRecorder) GetShardID added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetShardID() *gomock.Call

GetShardID indicates an expected call of GetShardID.

func (*MockExecutionManagerMockRecorder) GetTimerIndexTasks added in v1.1.0 

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

GetTimerIndexTasks indicates an expected call of GetTimerIndexTasks.

func (*MockExecutionManagerMockRecorder) GetTimerTask added in v1.1.0 

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

GetTimerTask indicates an expected call of GetTimerTask.

func (*MockExecutionManagerMockRecorder) GetTransferTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetTransferTask(request interface{}) *gomock.Call

GetTransferTask indicates an expected call of GetTransferTask.

func (*MockExecutionManagerMockRecorder) GetTransferTasks added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetTransferTasks(request interface{}) *gomock.Call

GetTransferTasks indicates an expected call of GetTransferTasks.

func (*MockExecutionManagerMockRecorder) GetWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) GetWorkflowExecution(request interface{}) *gomock.Call

GetWorkflowExecution indicates an expected call of GetWorkflowExecution.

func (*MockExecutionManagerMockRecorder) ListConcreteExecutions added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) ListConcreteExecutions(request interface{}) *gomock.Call

ListConcreteExecutions indicates an expected call of ListConcreteExecutions.

func (*MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(request interface{}) *gomock.Call

PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.

func (*MockExecutionManagerMockRecorder) RangeCompleteReplicationTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) RangeCompleteReplicationTask(request interface{}) *gomock.Call

RangeCompleteReplicationTask indicates an expected call of RangeCompleteReplicationTask.

func (*MockExecutionManagerMockRecorder) RangeCompleteTimerTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) RangeCompleteTimerTask(request interface{}) *gomock.Call

RangeCompleteTimerTask indicates an expected call of RangeCompleteTimerTask.

func (*MockExecutionManagerMockRecorder) RangeCompleteTransferTask added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) RangeCompleteTransferTask(request interface{}) *gomock.Call

RangeCompleteTransferTask indicates an expected call of RangeCompleteTransferTask.

func (*MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

RangeDeleteReplicationTaskFromDLQ indicates an expected call of RangeDeleteReplicationTaskFromDLQ.

func (*MockExecutionManagerMockRecorder) ResetWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) ResetWorkflowExecution(request interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockExecutionManagerMockRecorder) UpdateWorkflowExecution added in v1.1.0 

func (mr *MockExecutionManagerMockRecorder) UpdateWorkflowExecution(request interface{}) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

type MockHistoryManager added in v1.1.0 

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

MockHistoryManager is a mock of HistoryManager interface.

func NewMockHistoryManager added in v1.1.0 

func NewMockHistoryManager(ctrl *gomock.Controller) *MockHistoryManager

NewMockHistoryManager creates a new mock instance.

func (*MockHistoryManager) AppendHistoryNodes added in v1.1.0 

func (m *MockHistoryManager) AppendHistoryNodes(request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

AppendHistoryNodes mocks base method.

func (*MockHistoryManager) Close added in v1.1.0 

func (m *MockHistoryManager) Close()

Close mocks base method.

func (*MockHistoryManager) DeleteHistoryBranch added in v1.1.0 

func (m *MockHistoryManager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

DeleteHistoryBranch mocks base method.

func (*MockHistoryManager) EXPECT added in v1.1.0 

func (m *MockHistoryManager) EXPECT() *MockHistoryManagerMockRecorder

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

func (*MockHistoryManager) ForkHistoryBranch added in v1.1.0 

func (m *MockHistoryManager) ForkHistoryBranch(request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

ForkHistoryBranch mocks base method.

func (*MockHistoryManager) GetAllHistoryTreeBranches added in v1.1.0 

func (m *MockHistoryManager) GetAllHistoryTreeBranches(request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

GetAllHistoryTreeBranches mocks base method.

func (*MockHistoryManager) GetHistoryTree added in v1.1.0 

func (m *MockHistoryManager) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

GetHistoryTree mocks base method.

func (*MockHistoryManager) GetName added in v1.1.0 

func (m *MockHistoryManager) GetName() string

GetName mocks base method.

func (*MockHistoryManager) ReadHistoryBranch added in v1.1.0 

func (m *MockHistoryManager) ReadHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

ReadHistoryBranch mocks base method.

func (*MockHistoryManager) ReadHistoryBranchByBatch added in v1.1.0 

func (m *MockHistoryManager) ReadHistoryBranchByBatch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

ReadHistoryBranchByBatch mocks base method.

func (*MockHistoryManager) ReadRawHistoryBranch added in v1.1.0 

func (m *MockHistoryManager) ReadRawHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

ReadRawHistoryBranch mocks base method.

type MockHistoryManagerMockRecorder added in v1.1.0 

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

MockHistoryManagerMockRecorder is the mock recorder for MockHistoryManager.

func (*MockHistoryManagerMockRecorder) AppendHistoryNodes added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) AppendHistoryNodes(request interface{}) *gomock.Call

AppendHistoryNodes indicates an expected call of AppendHistoryNodes.

func (*MockHistoryManagerMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockHistoryManagerMockRecorder) DeleteHistoryBranch added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) DeleteHistoryBranch(request interface{}) *gomock.Call

DeleteHistoryBranch indicates an expected call of DeleteHistoryBranch.

func (*MockHistoryManagerMockRecorder) ForkHistoryBranch added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) ForkHistoryBranch(request interface{}) *gomock.Call

ForkHistoryBranch indicates an expected call of ForkHistoryBranch.

func (*MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches(request interface{}) *gomock.Call

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MockHistoryManagerMockRecorder) GetHistoryTree added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) GetHistoryTree(request interface{}) *gomock.Call

GetHistoryTree indicates an expected call of GetHistoryTree.

func (*MockHistoryManagerMockRecorder) GetName added in v1.1.0 

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

GetName indicates an expected call of GetName.

func (*MockHistoryManagerMockRecorder) ReadHistoryBranch added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranch(request interface{}) *gomock.Call

ReadHistoryBranch indicates an expected call of ReadHistoryBranch.

func (*MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch(request interface{}) *gomock.Call

ReadHistoryBranchByBatch indicates an expected call of ReadHistoryBranchByBatch.

func (*MockHistoryManagerMockRecorder) ReadRawHistoryBranch added in v1.1.0 

func (mr *MockHistoryManagerMockRecorder) ReadRawHistoryBranch(request interface{}) *gomock.Call

ReadRawHistoryBranch indicates an expected call of ReadRawHistoryBranch.

type MockMetadataManager added in v1.1.0 

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

MockMetadataManager is a mock of MetadataManager interface.

func NewMockMetadataManager added in v1.1.0 

func NewMockMetadataManager(ctrl *gomock.Controller) *MockMetadataManager

NewMockMetadataManager creates a new mock instance.

func (*MockMetadataManager) Close added in v1.1.0 

func (m *MockMetadataManager) Close()

Close mocks base method.

func (*MockMetadataManager) CreateNamespace added in v1.1.0 

func (m *MockMetadataManager) CreateNamespace(request *persistence.CreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)

CreateNamespace mocks base method.

func (*MockMetadataManager) DeleteNamespace added in v1.1.0 

func (m *MockMetadataManager) DeleteNamespace(request *persistence.DeleteNamespaceRequest) error

DeleteNamespace mocks base method.

func (*MockMetadataManager) DeleteNamespaceByName added in v1.1.0 

func (m *MockMetadataManager) DeleteNamespaceByName(request *persistence.DeleteNamespaceByNameRequest) error

DeleteNamespaceByName mocks base method.

func (*MockMetadataManager) EXPECT added in v1.1.0 

func (m *MockMetadataManager) EXPECT() *MockMetadataManagerMockRecorder

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

func (*MockMetadataManager) GetMetadata added in v1.1.0 

func (m *MockMetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)

GetMetadata mocks base method.

func (*MockMetadataManager) GetName added in v1.1.0 

func (m *MockMetadataManager) GetName() string

GetName mocks base method.

func (*MockMetadataManager) GetNamespace added in v1.1.0 

func (m *MockMetadataManager) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

GetNamespace mocks base method.

func (*MockMetadataManager) InitializeSystemNamespaces added in v1.1.0 

func (m *MockMetadataManager) InitializeSystemNamespaces(currentClusterName string) error

InitializeSystemNamespaces mocks base method.

func (*MockMetadataManager) ListNamespaces added in v1.1.0 

func (m *MockMetadataManager) ListNamespaces(request *persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

ListNamespaces mocks base method.

func (*MockMetadataManager) UpdateNamespace added in v1.1.0 

func (m *MockMetadataManager) UpdateNamespace(request *persistence.UpdateNamespaceRequest) error

UpdateNamespace mocks base method.

type MockMetadataManagerMockRecorder added in v1.1.0 

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

MockMetadataManagerMockRecorder is the mock recorder for MockMetadataManager.

func (*MockMetadataManagerMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockMetadataManagerMockRecorder) CreateNamespace added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) CreateNamespace(request interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockMetadataManagerMockRecorder) DeleteNamespace added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) DeleteNamespace(request interface{}) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockMetadataManagerMockRecorder) DeleteNamespaceByName added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) DeleteNamespaceByName(request interface{}) *gomock.Call

DeleteNamespaceByName indicates an expected call of DeleteNamespaceByName.

func (*MockMetadataManagerMockRecorder) GetMetadata added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) GetMetadata() *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockMetadataManagerMockRecorder) GetName added in v1.1.0 

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

GetName indicates an expected call of GetName.

func (*MockMetadataManagerMockRecorder) GetNamespace added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) GetNamespace(request interface{}) *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockMetadataManagerMockRecorder) InitializeSystemNamespaces added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) InitializeSystemNamespaces(currentClusterName interface{}) *gomock.Call

InitializeSystemNamespaces indicates an expected call of InitializeSystemNamespaces.

func (*MockMetadataManagerMockRecorder) ListNamespaces added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) ListNamespaces(request interface{}) *gomock.Call

ListNamespaces indicates an expected call of ListNamespaces.

func (*MockMetadataManagerMockRecorder) UpdateNamespace added in v1.1.0 

func (mr *MockMetadataManagerMockRecorder) UpdateNamespace(request interface{}) *gomock.Call

UpdateNamespace indicates an expected call of UpdateNamespace.

type MockShardManager added in v1.1.0 

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

MockShardManager is a mock of ShardManager interface.

func NewMockShardManager added in v1.1.0 

func NewMockShardManager(ctrl *gomock.Controller) *MockShardManager

NewMockShardManager creates a new mock instance.

func (*MockShardManager) Close added in v1.1.0 

func (m *MockShardManager) Close()

Close mocks base method.

func (*MockShardManager) CreateShard added in v1.1.0 

func (m *MockShardManager) CreateShard(request *persistence.CreateShardRequest) error

CreateShard mocks base method.

func (*MockShardManager) EXPECT added in v1.1.0 

func (m *MockShardManager) EXPECT() *MockShardManagerMockRecorder

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

func (*MockShardManager) GetName added in v1.1.0 

func (m *MockShardManager) GetName() string

GetName mocks base method.

func (*MockShardManager) GetShard added in v1.1.0 

func (m *MockShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

GetShard mocks base method.

func (*MockShardManager) UpdateShard added in v1.1.0 

func (m *MockShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

UpdateShard mocks base method.

type MockShardManagerMockRecorder added in v1.1.0 

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

MockShardManagerMockRecorder is the mock recorder for MockShardManager.

func (*MockShardManagerMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockShardManagerMockRecorder) CreateShard added in v1.1.0 

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

CreateShard indicates an expected call of CreateShard.

func (*MockShardManagerMockRecorder) GetName added in v1.1.0 

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

GetName indicates an expected call of GetName.

func (*MockShardManagerMockRecorder) GetShard added in v1.1.0 

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

GetShard indicates an expected call of GetShard.

func (*MockShardManagerMockRecorder) UpdateShard added in v1.1.0 

func (mr *MockShardManagerMockRecorder) UpdateShard(request interface{}) *gomock.Call

UpdateShard indicates an expected call of UpdateShard.

type MockTask added in v1.1.0 

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

MockTask is a mock of Task interface.

func NewMockTask added in v1.1.0 

func NewMockTask(ctrl *gomock.Controller) *MockTask

NewMockTask creates a new mock instance.

func (*MockTask) EXPECT added in v1.1.0 

func (m *MockTask) EXPECT() *MockTaskMockRecorder

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

func (*MockTask) GetTaskID added in v1.1.0 

func (m *MockTask) GetTaskID() int64

GetTaskID mocks base method.

func (*MockTask) GetType added in v1.1.0 

func (m *MockTask) GetType() enums.TaskType

GetType mocks base method.

func (*MockTask) GetVersion added in v1.1.0 

func (m *MockTask) GetVersion() int64

GetVersion mocks base method.

func (*MockTask) GetVisibilityTimestamp added in v1.1.0 

func (m *MockTask) GetVisibilityTimestamp() time.Time

GetVisibilityTimestamp mocks base method.

func (*MockTask) SetTaskID added in v1.1.0 

func (m *MockTask) SetTaskID(id int64)

SetTaskID mocks base method.

func (*MockTask) SetVersion added in v1.1.0 

func (m *MockTask) SetVersion(version int64)

SetVersion mocks base method.

func (*MockTask) SetVisibilityTimestamp added in v1.1.0 

func (m *MockTask) SetVisibilityTimestamp(timestamp time.Time)

SetVisibilityTimestamp mocks base method.

type MockTaskManager added in v1.1.0 

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

MockTaskManager is a mock of TaskManager interface.

func NewMockTaskManager added in v1.1.0 

func NewMockTaskManager(ctrl *gomock.Controller) *MockTaskManager

NewMockTaskManager creates a new mock instance.

func (*MockTaskManager) Close added in v1.1.0 

func (m *MockTaskManager) Close()

Close mocks base method.

func (*MockTaskManager) CompleteTask added in v1.1.0 

func (m *MockTaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

CompleteTask mocks base method.

func (*MockTaskManager) CompleteTasksLessThan added in v1.1.0 

func (m *MockTaskManager) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

CompleteTasksLessThan mocks base method.

func (*MockTaskManager) CreateTasks added in v1.1.0 

func (m *MockTaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

CreateTasks mocks base method.

func (*MockTaskManager) DeleteTaskQueue added in v1.1.0 

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

DeleteTaskQueue mocks base method.

func (*MockTaskManager) EXPECT added in v1.1.0 

func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder

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

func (*MockTaskManager) GetName added in v1.1.0 

func (m *MockTaskManager) GetName() string

GetName mocks base method.

func (*MockTaskManager) GetTasks added in v1.1.0 

func (m *MockTaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

GetTasks mocks base method.

func (*MockTaskManager) LeaseTaskQueue added in v1.1.0 

func (m *MockTaskManager) LeaseTaskQueue(request *persistence.LeaseTaskQueueRequest) (*persistence.LeaseTaskQueueResponse, error)

LeaseTaskQueue mocks base method.

func (*MockTaskManager) ListTaskQueue added in v1.1.0 

func (m *MockTaskManager) ListTaskQueue(request *persistence.ListTaskQueueRequest) (*persistence.ListTaskQueueResponse, error)

ListTaskQueue mocks base method.

func (*MockTaskManager) UpdateTaskQueue added in v1.1.0 

func (m *MockTaskManager) UpdateTaskQueue(request *persistence.UpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)

UpdateTaskQueue mocks base method.

type MockTaskManagerMockRecorder added in v1.1.0 

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

MockTaskManagerMockRecorder is the mock recorder for MockTaskManager.

func (*MockTaskManagerMockRecorder) Close added in v1.1.0 

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

Close indicates an expected call of Close.

func (*MockTaskManagerMockRecorder) CompleteTask added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) CompleteTask(request interface{}) *gomock.Call

CompleteTask indicates an expected call of CompleteTask.

func (*MockTaskManagerMockRecorder) CompleteTasksLessThan added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) CompleteTasksLessThan(request interface{}) *gomock.Call

CompleteTasksLessThan indicates an expected call of CompleteTasksLessThan.

func (*MockTaskManagerMockRecorder) CreateTasks added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) CreateTasks(request interface{}) *gomock.Call

CreateTasks indicates an expected call of CreateTasks.

func (*MockTaskManagerMockRecorder) DeleteTaskQueue added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) DeleteTaskQueue(request interface{}) *gomock.Call

DeleteTaskQueue indicates an expected call of DeleteTaskQueue.

func (*MockTaskManagerMockRecorder) GetName added in v1.1.0 

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

GetName indicates an expected call of GetName.

func (*MockTaskManagerMockRecorder) GetTasks added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) GetTasks(request interface{}) *gomock.Call

GetTasks indicates an expected call of GetTasks.

func (*MockTaskManagerMockRecorder) LeaseTaskQueue added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) LeaseTaskQueue(request interface{}) *gomock.Call

LeaseTaskQueue indicates an expected call of LeaseTaskQueue.

func (*MockTaskManagerMockRecorder) ListTaskQueue added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) ListTaskQueue(request interface{}) *gomock.Call

ListTaskQueue indicates an expected call of ListTaskQueue.

func (*MockTaskManagerMockRecorder) UpdateTaskQueue added in v1.1.0 

func (mr *MockTaskManagerMockRecorder) UpdateTaskQueue(request interface{}) *gomock.Call

UpdateTaskQueue indicates an expected call of UpdateTaskQueue.

type MockTaskMockRecorder added in v1.1.0 

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

MockTaskMockRecorder is the mock recorder for MockTask.

func (*MockTaskMockRecorder) GetTaskID added in v1.1.0 

func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call

GetTaskID indicates an expected call of GetTaskID.

func (*MockTaskMockRecorder) GetType added in v1.1.0 

func (mr *MockTaskMockRecorder) GetType() *gomock.Call

GetType indicates an expected call of GetType.

func (*MockTaskMockRecorder) GetVersion added in v1.1.0 

func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call

GetVersion indicates an expected call of GetVersion.

func (*MockTaskMockRecorder) GetVisibilityTimestamp added in v1.1.0 

func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call

GetVisibilityTimestamp indicates an expected call of GetVisibilityTimestamp.

func (*MockTaskMockRecorder) SetTaskID added in v1.1.0 

func (mr *MockTaskMockRecorder) SetTaskID(id interface{}) *gomock.Call

SetTaskID indicates an expected call of SetTaskID.

func (*MockTaskMockRecorder) SetVersion added in v1.1.0 

func (mr *MockTaskMockRecorder) SetVersion(version interface{}) *gomock.Call

SetVersion indicates an expected call of SetVersion.

func (*MockTaskMockRecorder) SetVisibilityTimestamp added in v1.1.0 

func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(timestamp interface{}) *gomock.Call

SetVisibilityTimestamp indicates an expected call of SetVisibilityTimestamp.

type ShardManager 

type ShardManager struct {
	mock.Mock
}

ShardManager is an autogenerated mock type for the ShardManager type

func (*ShardManager) Close 

func (_m *ShardManager) Close()

Close provides a mock function with given fields:

func (*ShardManager) CreateShard 

func (_m *ShardManager) CreateShard(request *persistence.CreateShardRequest) error

CreateShard provides a mock function with given fields: request

func (*ShardManager) GetName added in v0.4.0 

func (_m *ShardManager) GetName() string

GetName provides a mock function with given fields:

func (*ShardManager) GetShard 

func (_m *ShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

GetShard provides a mock function with given fields: request

func (*ShardManager) UpdateShard 

func (_m *ShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

UpdateShard provides a mock function with given fields: request

type TaskManager 

type TaskManager struct {
	mock.Mock
}

TaskManager is an autogenerated mock type for the TaskManager type

func (*TaskManager) Close 

func (_m *TaskManager) Close()

Close provides a mock function with given fields:

func (*TaskManager) CompleteTask 

func (_m *TaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

CompleteTask provides a mock function with given fields: request

func (*TaskManager) CompleteTasksLessThan added in v0.5.7 

func (_m *TaskManager) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

CompleteTasksLessThan

func (*TaskManager) CreateTasks 

func (_m *TaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

CreateTasks provides a mock function with given fields: request

func (*TaskManager) DeleteTaskQueue added in v0.27.0 

func (_m *TaskManager) DeleteTaskQueue(request *persistence.DeleteTaskQueueRequest) error

func (*TaskManager) GetName added in v0.4.0 

func (_m *TaskManager) GetName() string

GetName provides a mock function with given fields:

func (*TaskManager) GetTasks 

func (_m *TaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

GetTasks provides a mock function with given fields: request

func (*TaskManager) LeaseTaskQueue added in v0.27.0 

func (_m *TaskManager) LeaseTaskQueue(request *persistence.LeaseTaskQueueRequest) (*persistence.LeaseTaskQueueResponse, error)

LeaseTaskQueue provides a mock function with given fields: request

func (*TaskManager) ListTaskQueue added in v0.27.0 

func (_m *TaskManager) ListTaskQueue(request *persistence.ListTaskQueueRequest) (*persistence.ListTaskQueueResponse, error)

func (*TaskManager) UpdateTaskQueue added in v0.27.0 

func (_m *TaskManager) UpdateTaskQueue(request *persistence.UpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)

UpdateTaskQueue provides a mock function with given fields: request

type VisibilityManager 

type VisibilityManager struct {
	mock.Mock
}

VisibilityManager is an autogenerated mock type for the VisibilityManager type

func (*VisibilityManager) Close 

func (_m *VisibilityManager) Close()

Close provides a mock function with given fields:

func (*VisibilityManager) CountWorkflowExecutions added in v0.5.8 

func (_m *VisibilityManager) CountWorkflowExecutions(request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) DeleteWorkflowExecution added in v0.5.7 

func (_m *VisibilityManager) DeleteWorkflowExecution(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) DeleteWorkflowExecutionV2 added in v1.5.0 

func (_m *VisibilityManager) DeleteWorkflowExecutionV2(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) GetClosedWorkflowExecution 

func (_m *VisibilityManager) GetClosedWorkflowExecution(request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)

GetClosedWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) GetName added in v0.4.0 

func (_m *VisibilityManager) GetName() string

GetName provides a mock function with given fields:

func (*VisibilityManager) ListClosedWorkflowExecutions 

func (_m *VisibilityManager) ListClosedWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByStatus 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByStatus(request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByType 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

func (_m *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutions 

func (_m *VisibilityManager) ListOpenWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByType 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType provides a mock function with given fields: request

func (*VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

func (_m *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID provides a mock function with given fields: request

func (*VisibilityManager) ListWorkflowExecutions added in v0.5.7 

func (_m *VisibilityManager) ListWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionClosed 

func (_m *VisibilityManager) RecordWorkflowExecutionClosed(request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionClosedV2 added in v1.5.0 

func (_m *VisibilityManager) RecordWorkflowExecutionClosedV2(request *persistence.RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosedV2 provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionStarted 

func (_m *VisibilityManager) RecordWorkflowExecutionStarted(request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted provides a mock function with given fields: request

func (*VisibilityManager) RecordWorkflowExecutionStartedV2 added in v1.5.0 

func (_m *VisibilityManager) RecordWorkflowExecutionStartedV2(request *persistence.RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStartedV2 provides a mock function with given fields: request

func (*VisibilityManager) ScanWorkflowExecutions added in v0.5.8 

func (_m *VisibilityManager) ScanWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions provides a mock function with given fields: request

func (*VisibilityManager) UpsertWorkflowExecution added in v0.6.0 

func (_m *VisibilityManager) UpsertWorkflowExecution(request *persistence.UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution provides a mock function with given fields: request

func (*VisibilityManager) UpsertWorkflowExecutionV2 added in v1.5.0 

func (_m *VisibilityManager) UpsertWorkflowExecutionV2(request *persistence.UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution provides a mock function with given fields: request

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.