quota

Jun 17, 2021

Changes in this version

+ const LimiterTypeNone

May 26, 2021

Changes in this version

+ const LimiterTypeInMemory

+ const LimiterTypeRedis

+ type BadConfigError struct

+ func (e *BadConfigError) Error() string

+ type ConfigNotFoundError struct

+ func (e *ConfigNotFoundError) Error() string

+ type NoEarsInstances struct

+ func (e *NoEarsInstances) Error() string

+ type QuotaLimiter struct

+ func NewQuotaLimiter(tid tenant.Id, backendLimiterType string, redisAddr string, initialRqs int, ...) *QuotaLimiter

+ func (r *QuotaLimiter) AdaptiveLimit() int

+ func (r *QuotaLimiter) Limit() int

+ func (r *QuotaLimiter) SetLimit(newLimit int) error

+ func (r *QuotaLimiter) Take(ctx context.Context, unit int) error

+ func (r *QuotaLimiter) Wait(ctx context.Context) error

+ type QuotaManager struct

+ func NewQuotaManager(logger *zerolog.Logger, tenantStorer tenant.TenantStorer, ...) (*QuotaManager, error)

+ func (m *QuotaManager) PublishQuota(ctx context.Context, tid tenant.Id) error

+ func (m *QuotaManager) Start()

+ func (m *QuotaManager) Stop()

+ func (m *QuotaManager) SyncItem(ctx context.Context, tid tenant.Id, itemId string, add bool) error

+ func (m *QuotaManager) TenantLimit(ctx context.Context, tid tenant.Id) int

+ func (m *QuotaManager) Wait(ctx context.Context, tid tenant.Id) error