metered

package
v1.2.13 Latest Latest
Warning

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

Go to latest
Published: Sep 4, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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.

Jump to

Keyboard shortcuts

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