iface

Oct 31, 2022

Changes in this version

type Classifier

+ GetRequestCounter func() prometheus.Counter

type ConcurrencyLimiter

+ GetLatencyObserver func(labels map[string]string) prometheus.Observer

+ GetRequestCounter func(labels map[string]string) prometheus.Counter

type RateLimiter

+ GetRequestCounter func() prometheus.Counter

Oct 10, 2022

Changes in this version

+ type ClassificationEngine interface

+ GetClassifier func(classifierID ClassifierID) Classifier

+ RegisterClassifier func(classifier Classifier) error

+ UnregisterClassifier func(classifier Classifier) error

type Classifier

+ GetCounter func() prometheus.Counter

+ type ConcurrencyLimiter interface

+ GetObserver func(labels map[string]string) prometheus.Observer

type Engine

+ GetRateLimiter func(limiterID LimiterID) RateLimiter

type RateLimiter

+ GetCounter func() prometheus.Counter

Oct 3, 2022

Changes in this version

type Engine

+ GetConcurrencyLimiter func(limiterID LimiterID) Limiter

type Limiter

+ GetObserver func(labels map[string]string) prometheus.Observer

Sep 26, 2022

Changes in this version

+ type ResponseMetricsAPI interface

+ DeleteTokenLatencyHistogram func(labels map[string]string) bool

+ GetTokenLatencyHistogram func(labels map[string]string) (prometheus.Observer, error)

Sep 8, 2022

Changes in this version

type Engine

+ GetFluxMeter func(fluxMeterName string) FluxMeter

type FluxMeter

+ GetAttributeKey func() string

Sep 8, 2022

Changes in this version

+ type Classifier interface

+ GetClassifierID func() ClassifierID

+ GetSelector func() *selectorv1.Selector

+ type ClassifierID struct

+ ClassifierIndex int64

+ PolicyHash string

+ PolicyName string

+ func (cID ClassifierID) String() string

type Engine

+ RegisterClassifier func(c Classifier) error

+ UnregisterClassifier func(c Classifier) error

type MultiMatchResult

+ Classifiers []Classifier

Aug 31, 2022

Changes in this version

+ func ComponentID(component Component) string

+ func ComponentIDExpanded(policyName string, componentIndex int64, policyHash string) string

+ type Component interface

+ GetComponentIndex func() int64

+ type Engine interface

+ GetFluxMeterHist func(fluxMeterName, statusCode string, decisionType flowcontrolv1.DecisionType) prometheus.Observer

+ ProcessRequest func(controlPoint selectors.ControlPoint, serviceIDs []services.ServiceID, ...) *flowcontrolv1.CheckResponse

+ RegisterConcurrencyLimiter func(sa Limiter) error

+ RegisterFluxMeter func(fm FluxMeter) error

+ RegisterRateLimiter func(l RateLimiter) error

+ UnregisterConcurrencyLimiter func(sa Limiter) error

+ UnregisterFluxMeter func(fm FluxMeter) error

+ UnregisterRateLimiter func(l RateLimiter) error

+ type FluxMeter interface

+ GetBuckets func() []float64

+ GetFluxMeterID func() FluxMeterID

+ GetFluxMeterName func() string

+ GetHistogram func(flowcontrolv1.DecisionType, string) prometheus.Observer

+ GetSelector func() *selectorv1.Selector

+ type FluxMeterID struct

+ FluxMeterName string

+ func (fmID FluxMeterID) String() string

+ type Limiter interface

+ GetLimiterID func() LimiterID

+ GetPolicyName func() string

+ GetSelector func() *selectorv1.Selector

+ RunLimiter func(labels selectors.Labels) *flowcontrolv1.LimiterDecision

+ type LimiterID struct

+ ComponentIndex int64

+ PolicyHash string

+ PolicyName string

+ func (limiterID LimiterID) String() string

+ type MultiMatchResult struct

+ ConcurrencyLimiters []Limiter

+ FluxMeters []FluxMeter

+ RateLimiters []RateLimiter

+ func (result *MultiMatchResult) PopulateFromMultiMatcher(mm *multimatcher.MultiMatcher[string, MultiMatchResult], ...)

+ type Policy interface

+ GetPolicyHash func() string

+ GetPolicyName func() string

+ type RateLimiter interface

+ TakeN func(labels selectors.Labels, count int) (label string, ok bool, remaining int, current int)