Documentation ¶
Overview ¶
Package client is a generated GoMock package.
Index ¶
- type Bean
- type BeanImpl
- func (s *BeanImpl) Close()
- func (s *BeanImpl) GetDomainReplicationQueueManager() persistence.QueueManager
- func (s *BeanImpl) GetExecutionManager(shardID int) (persistence.ExecutionManager, error)
- func (s *BeanImpl) GetHistoryManager() persistence.HistoryManager
- func (s *BeanImpl) GetMetadataManager() persistence.MetadataManager
- func (s *BeanImpl) GetShardManager() persistence.ShardManager
- func (s *BeanImpl) GetTaskManager() persistence.TaskManager
- func (s *BeanImpl) GetVisibilityManager() persistence.VisibilityManager
- func (s *BeanImpl) SetDomainReplicationQueueManager(domainReplicationQueueManager persistence.QueueManager)
- func (s *BeanImpl) SetExecutionManager(shardID int, executionManager persistence.ExecutionManager)
- func (s *BeanImpl) SetHistoryManager(historyManager persistence.HistoryManager)
- func (s *BeanImpl) SetMetadataManager(metadataManager persistence.MetadataManager)
- func (s *BeanImpl) SetShardManager(shardManager persistence.ShardManager)
- func (s *BeanImpl) SetTaskManager(taskManager persistence.TaskManager)
- func (s *BeanImpl) SetVisibilityManager(visibilityManager persistence.VisibilityManager)
- type DataStoreFactory
- type Datastore
- type Factory
- type MockBean
- func (m *MockBean) Close()
- func (m *MockBean) EXPECT() *MockBeanMockRecorder
- func (m *MockBean) GetDomainReplicationQueueManager() persistence.QueueManager
- func (m *MockBean) GetExecutionManager(arg0 int) (persistence.ExecutionManager, error)
- func (m *MockBean) GetHistoryManager() persistence.HistoryManager
- func (m *MockBean) GetMetadataManager() persistence.MetadataManager
- func (m *MockBean) GetShardManager() persistence.ShardManager
- func (m *MockBean) GetTaskManager() persistence.TaskManager
- func (m *MockBean) GetVisibilityManager() persistence.VisibilityManager
- func (m *MockBean) SetDomainReplicationQueueManager(arg0 persistence.QueueManager)
- func (m *MockBean) SetExecutionManager(arg0 int, arg1 persistence.ExecutionManager)
- func (m *MockBean) SetHistoryManager(arg0 persistence.HistoryManager)
- func (m *MockBean) SetMetadataManager(arg0 persistence.MetadataManager)
- func (m *MockBean) SetShardManager(arg0 persistence.ShardManager)
- func (m *MockBean) SetTaskManager(arg0 persistence.TaskManager)
- func (m *MockBean) SetVisibilityManager(arg0 persistence.VisibilityManager)
- type MockBeanMockRecorder
- func (mr *MockBeanMockRecorder) Close() *gomock.Call
- func (mr *MockBeanMockRecorder) GetDomainReplicationQueueManager() *gomock.Call
- func (mr *MockBeanMockRecorder) GetExecutionManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) GetHistoryManager() *gomock.Call
- func (mr *MockBeanMockRecorder) GetMetadataManager() *gomock.Call
- func (mr *MockBeanMockRecorder) GetShardManager() *gomock.Call
- func (mr *MockBeanMockRecorder) GetTaskManager() *gomock.Call
- func (mr *MockBeanMockRecorder) GetVisibilityManager() *gomock.Call
- func (mr *MockBeanMockRecorder) SetDomainReplicationQueueManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetExecutionManager(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetHistoryManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetMetadataManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetShardManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetTaskManager(arg0 interface{}) *gomock.Call
- func (mr *MockBeanMockRecorder) SetVisibilityManager(arg0 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bean ¶
type Bean interface { Close() GetMetadataManager() persistence.MetadataManager SetMetadataManager(persistence.MetadataManager) GetTaskManager() persistence.TaskManager SetTaskManager(persistence.TaskManager) GetVisibilityManager() persistence.VisibilityManager SetVisibilityManager(persistence.VisibilityManager) GetDomainReplicationQueueManager() persistence.QueueManager SetDomainReplicationQueueManager(persistence.QueueManager) GetShardManager() persistence.ShardManager SetShardManager(persistence.ShardManager) GetHistoryManager() persistence.HistoryManager SetHistoryManager(persistence.HistoryManager) GetExecutionManager(int) (persistence.ExecutionManager, error) SetExecutionManager(int, persistence.ExecutionManager) }
Bean in an collection of persistence manager
type BeanImpl ¶
BeanImpl stores persistence managers
func NewBean ¶
func NewBean( metadataManager persistence.MetadataManager, taskManager persistence.TaskManager, visibilityManager persistence.VisibilityManager, domainReplicationQueueManager persistence.QueueManager, shardManager persistence.ShardManager, historyManager persistence.HistoryManager, executionManagerFactory persistence.ExecutionManagerFactory, ) *BeanImpl
NewBean create a new store bean
func NewBeanFromFactory ¶
NewBeanFromFactory crate a new store bean using factory
func (*BeanImpl) GetDomainReplicationQueueManager ¶ added in v0.17.0
func (s *BeanImpl) GetDomainReplicationQueueManager() persistence.QueueManager
GetDomainReplicationQueueManager gets domain replication QueueManager
func (*BeanImpl) GetExecutionManager ¶
func (s *BeanImpl) GetExecutionManager( shardID int, ) (persistence.ExecutionManager, error)
GetExecutionManager get ExecutionManager
func (*BeanImpl) GetHistoryManager ¶
func (s *BeanImpl) GetHistoryManager() persistence.HistoryManager
GetHistoryManager get HistoryManager
func (*BeanImpl) GetMetadataManager ¶
func (s *BeanImpl) GetMetadataManager() persistence.MetadataManager
GetMetadataManager get MetadataManager
func (*BeanImpl) GetShardManager ¶
func (s *BeanImpl) GetShardManager() persistence.ShardManager
GetShardManager get ShardManager
func (*BeanImpl) GetTaskManager ¶
func (s *BeanImpl) GetTaskManager() persistence.TaskManager
GetTaskManager get TaskManager
func (*BeanImpl) GetVisibilityManager ¶
func (s *BeanImpl) GetVisibilityManager() persistence.VisibilityManager
GetVisibilityManager get VisibilityManager
func (*BeanImpl) SetDomainReplicationQueueManager ¶ added in v0.17.0
func (s *BeanImpl) SetDomainReplicationQueueManager( domainReplicationQueueManager persistence.QueueManager, )
SetDomainReplicationQueueManager sets domain replication QueueManager
func (*BeanImpl) SetExecutionManager ¶
func (s *BeanImpl) SetExecutionManager( shardID int, executionManager persistence.ExecutionManager, )
SetExecutionManager set ExecutionManager
func (*BeanImpl) SetHistoryManager ¶
func (s *BeanImpl) SetHistoryManager( historyManager persistence.HistoryManager, )
SetHistoryManager set HistoryManager
func (*BeanImpl) SetMetadataManager ¶
func (s *BeanImpl) SetMetadataManager( metadataManager persistence.MetadataManager, )
SetMetadataManager set MetadataManager
func (*BeanImpl) SetShardManager ¶
func (s *BeanImpl) SetShardManager( shardManager persistence.ShardManager, )
SetShardManager set ShardManager
func (*BeanImpl) SetTaskManager ¶
func (s *BeanImpl) SetTaskManager( taskManager persistence.TaskManager, )
SetTaskManager set TaskManager
func (*BeanImpl) SetVisibilityManager ¶
func (s *BeanImpl) SetVisibilityManager( visibilityManager persistence.VisibilityManager, )
SetVisibilityManager set VisibilityManager
type DataStoreFactory ¶
type DataStoreFactory interface { // Close closes the factory Close() // NewTaskStore returns a new task store NewTaskStore() (p.TaskStore, error) // NewShardStore returns a new shard store NewShardStore() (p.ShardStore, error) // NewHistoryV2Store returns a new historyV2 store NewHistoryV2Store() (p.HistoryStore, error) // NewMetadataStore returns a new metadata store NewMetadataStore() (p.MetadataStore, error) // NewExecutionStore returns an execution store for given shardID NewExecutionStore(shardID int) (p.ExecutionStore, error) // NewVisibilityStore returns a new visibility store, // TODO We temporarily using sortByCloseTime to determine whether or not ListClosedWorkflowExecutions should // be ordering by CloseTime. This will be removed when implementing https://github.com/uber/cadence/issues/3621 NewVisibilityStore(sortByCloseTime bool) (p.VisibilityStore, error) NewQueue(queueType p.QueueType) (p.Queue, error) }
DataStoreFactory is a low level interface to be implemented by a datastore Examples of datastores are cassandra, mysql etc
type Datastore ¶
type Datastore struct {
// contains filtered or unexported fields
}
Datastore represents a datastore
type Factory ¶
type Factory interface { // Close the factory Close() // NewTaskManager returns a new task manager NewTaskManager() (p.TaskManager, error) // NewShardManager returns a new shard manager NewShardManager() (p.ShardManager, error) // NewHistoryManager returns a new history manager NewHistoryManager() (p.HistoryManager, error) // NewMetadataManager returns a new metadata manager NewMetadataManager() (p.MetadataManager, error) // NewExecutionManager returns a new execution manager for a given shardID NewExecutionManager(shardID int) (p.ExecutionManager, error) // NewVisibilityManager returns a new visibility manager NewVisibilityManager() (p.VisibilityManager, error) // NewDomainReplicationQueueManager returns a new queue for domain replication NewDomainReplicationQueueManager() (p.QueueManager, error) }
Factory defines the interface for any implementation that can vend persistence layer objects backed by a datastore. The actual datastore is implementation detail hidden behind this interface
func NewFactory ¶
func NewFactory( cfg *config.Persistence, persistenceMaxQPS dynamicconfig.IntPropertyFn, clusterName string, metricsClient metrics.Client, logger log.Logger, ) Factory
NewFactory returns an implementation of factory that vends persistence objects based on specified configuration. This factory takes as input a config.Persistence object which specifies the datastore to be used for a given type of object. This config also contains config for individual datastores themselves.
The objects returned by this factory enforce ratelimit and maxconns according to given configuration. In addition, all objects will emit metrics automatically
type MockBean ¶
type MockBean struct {
// contains filtered or unexported fields
}
MockBean is a mock of Bean interface
func NewMockBean ¶
func NewMockBean(ctrl *gomock.Controller) *MockBean
NewMockBean creates a new mock instance
func (*MockBean) EXPECT ¶
func (m *MockBean) EXPECT() *MockBeanMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBean) GetDomainReplicationQueueManager ¶ added in v0.17.0
func (m *MockBean) GetDomainReplicationQueueManager() persistence.QueueManager
GetDomainReplicationQueueManager mocks base method
func (*MockBean) GetExecutionManager ¶
func (m *MockBean) GetExecutionManager(arg0 int) (persistence.ExecutionManager, error)
GetExecutionManager mocks base method
func (*MockBean) GetHistoryManager ¶
func (m *MockBean) GetHistoryManager() persistence.HistoryManager
GetHistoryManager mocks base method
func (*MockBean) GetMetadataManager ¶
func (m *MockBean) GetMetadataManager() persistence.MetadataManager
GetMetadataManager mocks base method
func (*MockBean) GetShardManager ¶
func (m *MockBean) GetShardManager() persistence.ShardManager
GetShardManager mocks base method
func (*MockBean) GetTaskManager ¶
func (m *MockBean) GetTaskManager() persistence.TaskManager
GetTaskManager mocks base method
func (*MockBean) GetVisibilityManager ¶
func (m *MockBean) GetVisibilityManager() persistence.VisibilityManager
GetVisibilityManager mocks base method
func (*MockBean) SetDomainReplicationQueueManager ¶ added in v0.17.0
func (m *MockBean) SetDomainReplicationQueueManager(arg0 persistence.QueueManager)
SetDomainReplicationQueueManager mocks base method
func (*MockBean) SetExecutionManager ¶
func (m *MockBean) SetExecutionManager(arg0 int, arg1 persistence.ExecutionManager)
SetExecutionManager mocks base method
func (*MockBean) SetHistoryManager ¶
func (m *MockBean) SetHistoryManager(arg0 persistence.HistoryManager)
SetHistoryManager mocks base method
func (*MockBean) SetMetadataManager ¶
func (m *MockBean) SetMetadataManager(arg0 persistence.MetadataManager)
SetMetadataManager mocks base method
func (*MockBean) SetShardManager ¶
func (m *MockBean) SetShardManager(arg0 persistence.ShardManager)
SetShardManager mocks base method
func (*MockBean) SetTaskManager ¶
func (m *MockBean) SetTaskManager(arg0 persistence.TaskManager)
SetTaskManager mocks base method
func (*MockBean) SetVisibilityManager ¶
func (m *MockBean) SetVisibilityManager(arg0 persistence.VisibilityManager)
SetVisibilityManager mocks base method
type MockBeanMockRecorder ¶
type MockBeanMockRecorder struct {
// contains filtered or unexported fields
}
MockBeanMockRecorder is the mock recorder for MockBean
func (*MockBeanMockRecorder) Close ¶
func (mr *MockBeanMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockBeanMockRecorder) GetDomainReplicationQueueManager ¶ added in v0.17.0
func (mr *MockBeanMockRecorder) GetDomainReplicationQueueManager() *gomock.Call
GetDomainReplicationQueueManager indicates an expected call of GetDomainReplicationQueueManager
func (*MockBeanMockRecorder) GetExecutionManager ¶
func (mr *MockBeanMockRecorder) GetExecutionManager(arg0 interface{}) *gomock.Call
GetExecutionManager indicates an expected call of GetExecutionManager
func (*MockBeanMockRecorder) GetHistoryManager ¶
func (mr *MockBeanMockRecorder) GetHistoryManager() *gomock.Call
GetHistoryManager indicates an expected call of GetHistoryManager
func (*MockBeanMockRecorder) GetMetadataManager ¶
func (mr *MockBeanMockRecorder) GetMetadataManager() *gomock.Call
GetMetadataManager indicates an expected call of GetMetadataManager
func (*MockBeanMockRecorder) GetShardManager ¶
func (mr *MockBeanMockRecorder) GetShardManager() *gomock.Call
GetShardManager indicates an expected call of GetShardManager
func (*MockBeanMockRecorder) GetTaskManager ¶
func (mr *MockBeanMockRecorder) GetTaskManager() *gomock.Call
GetTaskManager indicates an expected call of GetTaskManager
func (*MockBeanMockRecorder) GetVisibilityManager ¶
func (mr *MockBeanMockRecorder) GetVisibilityManager() *gomock.Call
GetVisibilityManager indicates an expected call of GetVisibilityManager
func (*MockBeanMockRecorder) SetDomainReplicationQueueManager ¶ added in v0.17.0
func (mr *MockBeanMockRecorder) SetDomainReplicationQueueManager(arg0 interface{}) *gomock.Call
SetDomainReplicationQueueManager indicates an expected call of SetDomainReplicationQueueManager
func (*MockBeanMockRecorder) SetExecutionManager ¶
func (mr *MockBeanMockRecorder) SetExecutionManager(arg0, arg1 interface{}) *gomock.Call
SetExecutionManager indicates an expected call of SetExecutionManager
func (*MockBeanMockRecorder) SetHistoryManager ¶
func (mr *MockBeanMockRecorder) SetHistoryManager(arg0 interface{}) *gomock.Call
SetHistoryManager indicates an expected call of SetHistoryManager
func (*MockBeanMockRecorder) SetMetadataManager ¶
func (mr *MockBeanMockRecorder) SetMetadataManager(arg0 interface{}) *gomock.Call
SetMetadataManager indicates an expected call of SetMetadataManager
func (*MockBeanMockRecorder) SetShardManager ¶
func (mr *MockBeanMockRecorder) SetShardManager(arg0 interface{}) *gomock.Call
SetShardManager indicates an expected call of SetShardManager
func (*MockBeanMockRecorder) SetTaskManager ¶
func (mr *MockBeanMockRecorder) SetTaskManager(arg0 interface{}) *gomock.Call
SetTaskManager indicates an expected call of SetTaskManager
func (*MockBeanMockRecorder) SetVisibilityManager ¶
func (mr *MockBeanMockRecorder) SetVisibilityManager(arg0 interface{}) *gomock.Call
SetVisibilityManager indicates an expected call of SetVisibilityManager