ratelimited

Documentation

Index

• Variables
• func NewConfigStoreManager(wrapped persistence.ConfigStoreManager, rateLimiter quotas.Limiter) persistence.ConfigStoreManager
• func NewDomainManager(wrapped persistence.DomainManager, rateLimiter quotas.Limiter) persistence.DomainManager
• func NewExecutionManager(wrapped persistence.ExecutionManager, rateLimiter quotas.Limiter) persistence.ExecutionManager
• func NewHistoryManager(wrapped persistence.HistoryManager, rateLimiter quotas.Limiter) persistence.HistoryManager
• func NewQueueManager(wrapped persistence.QueueManager, rateLimiter quotas.Limiter) persistence.QueueManager
• func NewShardManager(wrapped persistence.ShardManager, rateLimiter quotas.Limiter) persistence.ShardManager
• func NewTaskManager(wrapped persistence.TaskManager, rateLimiter quotas.Limiter) persistence.TaskManager
• func NewVisibilityManager(wrapped persistence.VisibilityManager, rateLimiter quotas.Limiter) persistence.VisibilityManager

Variables

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.