Documentation ¶
Index ¶
- func NewConfigStoreManager(wrapped persistence.ConfigStoreManager, metricClient metrics.Client, ...) persistence.ConfigStoreManager
- func NewDomainManager(wrapped persistence.DomainManager, metricClient metrics.Client, ...) persistence.DomainManager
- func NewExecutionManager(wrapped persistence.ExecutionManager, metricClient metrics.Client, ...) persistence.ExecutionManager
- func NewHistoryManager(wrapped persistence.HistoryManager, metricClient metrics.Client, ...) persistence.HistoryManager
- func NewQueueManager(wrapped persistence.QueueManager, metricClient metrics.Client, ...) persistence.QueueManager
- func NewShardManager(wrapped persistence.ShardManager, metricClient metrics.Client, ...) persistence.ShardManager
- func NewTaskManager(wrapped persistence.TaskManager, metricClient metrics.Client, ...) persistence.TaskManager
- func NewVisibilityManager(wrapped persistence.VisibilityManager, metricClient metrics.Client, ...) persistence.VisibilityManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConfigStoreManager ¶
func NewConfigStoreManager( wrapped persistence.ConfigStoreManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.ConfigStoreManager
NewConfigStoreManager creates a new instance of ConfigStoreManager with ratelimiter.
func NewDomainManager ¶
func NewDomainManager( wrapped persistence.DomainManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.DomainManager
NewDomainManager creates a new instance of DomainManager with ratelimiter.
func NewExecutionManager ¶
func NewExecutionManager( wrapped persistence.ExecutionManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, sampleLoggingRate dynamicconfig.IntPropertyFn, enableShardIDMetrics dynamicconfig.BoolPropertyFn, ) persistence.ExecutionManager
NewExecutionManager creates a new instance of ExecutionManager with ratelimiter.
func NewHistoryManager ¶
func NewHistoryManager( wrapped persistence.HistoryManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.HistoryManager
NewHistoryManager creates a new instance of HistoryManager with ratelimiter.
func NewQueueManager ¶
func NewQueueManager( wrapped persistence.QueueManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.QueueManager
NewQueueManager creates a new instance of QueueManager with ratelimiter.
func NewShardManager ¶
func NewShardManager( wrapped persistence.ShardManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.ShardManager
NewShardManager creates a new instance of ShardManager with ratelimiter.
func NewTaskManager ¶
func NewTaskManager( wrapped persistence.TaskManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.TaskManager
NewTaskManager creates a new instance of TaskManager with ratelimiter.
func NewVisibilityManager ¶
func NewVisibilityManager( wrapped persistence.VisibilityManager, metricClient metrics.Client, logger log.Logger, cfg *config.Persistence, ) persistence.VisibilityManager
NewVisibilityManager creates a new instance of VisibilityManager with ratelimiter.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.