quota

Documentation

Index

• Variables
• func Allow(ctx context.Context, namespace string, reqSize int) error
• func Init(t *metadata.TenantManager, tx *transaction.Manager, c *config.QuotaConfig)
• type Manager
• type State
  • func GetState(namespace string) *State

Variables

var (
	ErrRateExceeded        = api.Errorf(api.Code_RESOURCE_EXHAUSTED, "request rate limit exceeded")
	ErrThroughputExceeded  = api.Errorf(api.Code_RESOURCE_EXHAUSTED, "request throughput limit exceeded")
	ErrStorageSizeExceeded = api.Errorf(api.Code_RESOURCE_EXHAUSTED, "data size limit exceeded")
)

Functions

func Allow

func Allow(ctx context.Context, namespace string, reqSize int) error

Allow checks rate, write throughput and storage size limits for the namespace and returns error if at least one of them is exceeded

func Init

func Init(t *metadata.TenantManager, tx *transaction.Manager, c *config.QuotaConfig)

Types

type Manager

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

type State

type State struct {
	Rate               *rate.Limiter
	WriteThroughput    *rate.Limiter
	ReadThroughput     *rate.Limiter
	Size               atomic.Int64
	SizeUpdateAt       atomic.Int64
	TenantSizeUpdateAt atomic.Int64
	SizeLock           sync.Mutex
	TenantSizeLock     sync.Mutex
}

func GetState

func GetState(namespace string) *State

GetState returns quota state of the given namespace