hotspot

type ConcurrencyStatSlot struct {
}

type ControlBehavior int8

type MetricType int8

type ParamKind int

type ParamsMetric struct {
	// RuleTimeCounter records the last added token timestamp.
	RuleTimeCounter cache.ConcurrentCounterCache
	// RuleTokenCounter records the number of tokens.
	RuleTokenCounter cache.ConcurrentCounterCache
	// ConcurrencyCounter records the real-time concurrency.
	ConcurrencyCounter cache.ConcurrentCounterCache
}

type Rule struct {
	// ID is the unique id
	ID string `json:"id,omitempty"`
	// Resource is the resource name
	Resource        string          `json:"resource"`
	MetricType      MetricType      `json:"metricType"`
	ControlBehavior ControlBehavior `json:"controlBehavior"`
	// ParamIndex is the index in context arguments slice.
	ParamIndex int     `json:"paramIndex"`
	Threshold  float64 `json:"threshold"`
	// MaxQueueingTimeMs only take effect in both Throttling ControlBehavior and QPS MetricType
	MaxQueueingTimeMs int64 `json:"maxQueueingTimeMs"`
	// BurstCount is the silent count
	// Only take effect in both Reject ControlBehavior and QPS MetricType
	BurstCount int64 `json:"burstCount"`
	// DurationInSec is the time interval in statistic
	// Only take effect in QPS MetricType
	DurationInSec int64 `json:"durationInSec"`
	// ParamsMaxCapacity is the max capacity of cache statistic
	ParamsMaxCapacity int64 `json:"paramsMaxCapacity"`
	// SpecificItems indicates the special threshold for specific value
	SpecificItems []SpecificValue `json:"specificItems"`
}

type Slot struct {
}

type SpecificValue struct {
	ValKind   ParamKind `json:"valKind"`
	ValStr    string    `json:"valStr"`
	Threshold int64     `json:"threshold"`
}

type TrafficControllerGenFunc func(r *Rule, reuseMetric *ParamsMetric) TrafficShapingController

type TrafficShapingController interface {
	PerformChecking(arg interface{}, acquireCount int64) *base.TokenResult

	BoundParamIndex() int

	BoundMetric() *ParamsMetric

	BoundRule() *Rule
}