metered

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

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.