quota

Documentation

Index

• Constants
• type BadConfigError
  • func (e *BadConfigError) Error() string
• type ConfigNotFoundError
  • func (e *ConfigNotFoundError) Error() string
• type NoEarsInstances
  • func (e *NoEarsInstances) Error() string
• type QuotaLimiter
  • 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
  • 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

Constants

const LimiterTypeInMemory = "inmemory"

const LimiterTypeNone = "none"

const LimiterTypeRedis = "redis"

Types

type BadConfigError

type BadConfigError struct {
	// contains filtered or unexported fields
}

func (*BadConfigError) Error

func (e *BadConfigError) Error() string

type ConfigNotFoundError

type ConfigNotFoundError struct {
	// contains filtered or unexported fields
}

func (*ConfigNotFoundError) Error

func (e *ConfigNotFoundError) Error() string

type NoEarsInstances

type NoEarsInstances struct {
}

func (*NoEarsInstances) Error

func (e *NoEarsInstances) Error() string

type QuotaLimiter

type QuotaLimiter struct {
	// contains filtered or unexported fields
}

Quota limiter implements an additional Wait function

func NewQuotaLimiter

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

func (*QuotaLimiter) AdaptiveLimit

func (r *QuotaLimiter) AdaptiveLimit() int

func (*QuotaLimiter) Limit

func (r *QuotaLimiter) Limit() int

func (*QuotaLimiter) SetLimit

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

func (*QuotaLimiter) Take

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

func (*QuotaLimiter) Wait

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

type QuotaManager

type QuotaManager struct {
	// contains filtered or unexported fields
}

func NewQuotaManager

func NewQuotaManager(logger *zerolog.Logger, tenantStorer tenant.TenantStorer, syncer syncer.DeltaSyncer, config config.Config) (*QuotaManager, error)

func (*QuotaManager) PublishQuota

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

PublishQuota publishes tenant quota to ratelimiters in all nodes so they can sync to the new quota

func (*QuotaManager) Start

func (m *QuotaManager) Start()

func (*QuotaManager) Stop

func (m *QuotaManager) Stop()

func (*QuotaManager) SyncItem

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

func (*QuotaManager) TenantLimit

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

func (*QuotaManager) Wait

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

Wait until rate limiter allows it to go through or context cancellation