ratelimited

package
v1.2.7-prerelease7 Latest Latest
Warning

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

Go to latest
Published: Feb 8, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrPersistenceLimitExceeded is the error indicating QPS limit reached.
	ErrPersistenceLimitExceeded = &types.ServiceBusyError{Message: "Persistence Max QPS Reached."}
)

Functions

func NewConfigStoreManager

func NewConfigStoreManager(
	wrapped persistence.ConfigStoreManager,
	rateLimiter quotas.Limiter,
) persistence.ConfigStoreManager

NewConfigStoreManager creates a new instance of ConfigStoreManager with ratelimiter.

func NewDomainManager

func NewDomainManager(
	wrapped persistence.DomainManager,
	rateLimiter quotas.Limiter,
) persistence.DomainManager

NewDomainManager creates a new instance of DomainManager with ratelimiter.

func NewExecutionManager

func NewExecutionManager(
	wrapped persistence.ExecutionManager,
	rateLimiter quotas.Limiter,
) persistence.ExecutionManager

NewExecutionManager creates a new instance of ExecutionManager with ratelimiter.

func NewHistoryManager

func NewHistoryManager(
	wrapped persistence.HistoryManager,
	rateLimiter quotas.Limiter,
) persistence.HistoryManager

NewHistoryManager creates a new instance of HistoryManager with ratelimiter.

func NewQueueManager

func NewQueueManager(
	wrapped persistence.QueueManager,
	rateLimiter quotas.Limiter,
) persistence.QueueManager

NewQueueManager creates a new instance of QueueManager with ratelimiter.

func NewShardManager

func NewShardManager(
	wrapped persistence.ShardManager,
	rateLimiter quotas.Limiter,
) persistence.ShardManager

NewShardManager creates a new instance of ShardManager with ratelimiter.

func NewTaskManager

func NewTaskManager(
	wrapped persistence.TaskManager,
	rateLimiter quotas.Limiter,
) persistence.TaskManager

NewTaskManager creates a new instance of TaskManager with ratelimiter.

func NewVisibilityManager

func NewVisibilityManager(
	wrapped persistence.VisibilityManager,
	rateLimiter quotas.Limiter,
) 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