client

package
v0.19.2 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package client is a generated GoMock package.

Index

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

type BeanImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

func NewBeanFromFactory(
	factory Factory,
) (*BeanImpl, error)

NewBeanFromFactory crate a new store bean using factory

func (*BeanImpl) Close

func (s *BeanImpl) Close()

Close cleanup connections

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

func (m *MockBean) Close()

Close mocks base method

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

Jump to

Keyboard shortcuts

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