rate_limiter

Sep 27, 2023

Changes in this version

+ const RateLimiterScopeConnection

+ const RateLimiterScopeFunction

+ const RateLimiterScopeTable

+ func FormatStringMap(stringMap map[string]string) string

+ func GetMaxConcurrentRows() int

+ func MergeScopeValues(values []map[string]string) map[string]string

+ func ScopeValuesString(sv map[string]string) string

+ type Definition struct

+ BucketSize int64

+ FillRate rate.Limit

+ MaxConcurrency int64

+ Name string

+ Scope []string

+ Where string

+ func DefinitionFromProto(p *proto.RateLimiterDefinition) (*Definition, error)

+ func (d *Definition) Initialise() error

+ func (d *Definition) SatisfiesFilters(scopeValues map[string]string) bool

+ func (d *Definition) String() string

+ func (d *Definition) ToProto() *proto.RateLimiterDefinition

+ func (d *Definition) Validate() []string

+ type HydrateLimiter struct

+ Name string

+ func (d *HydrateLimiter) String() string

+ type LimiterMap struct

+ func NewLimiterMap() *LimiterMap

+ func (m *LimiterMap) Clear()

+ func (m *LimiterMap) GetOrCreate(def *Definition, scopeValues map[string]string) (*HydrateLimiter, error)

+ type MultiLimiter struct

+ Limiters []*HydrateLimiter

+ ScopeValues map[string]string

+ func EmptyMultiLimiter() *MultiLimiter

+ func NewMultiLimiter(limiters []*HydrateLimiter, scopeValues map[string]string) *MultiLimiter

+ func (m *MultiLimiter) LimiterNames() []string

+ func (m *MultiLimiter) ReleaseSemaphore()

+ func (m *MultiLimiter) String() string

+ func (m *MultiLimiter) TryToAcquireSemaphore() bool

+ func (m *MultiLimiter) Wait(ctx context.Context) time.Duration