flow

Jul 28, 2021

Changes in this version

+ func ClearRulesOfResource(res string) error

+ func LoadRulesOfResource(res string, rules []*Rule) (bool, error)

+ type MemoryAdaptiveTrafficShapingCalculator struct

+ func NewMemoryAdaptiveTrafficShapingCalculator(owner *TrafficShapingController, r *Rule) *MemoryAdaptiveTrafficShapingCalculator

+ func (m *MemoryAdaptiveTrafficShapingCalculator) BoundOwner() *TrafficShapingController

+ func (m *MemoryAdaptiveTrafficShapingCalculator) CalculateAllowedTokens(_ uint32, _ int32) float64

type Rule

+ HighMemUsageThreshold int64

+ LowMemUsageThreshold int64

+ MemHighWaterMarkBytes int64

+ MemLowWaterMarkBytes int64

type TokenCalculateStrategy

+ const MemoryAdaptive

Nov 26, 2020

Changes in this version

+ const BlockMsgQueueing

+ const MillisToNanosOffset

+ const RuleCheckSlotName

+ const RuleCheckSlotOrder

+ const StatSlotName

+ const StatSlotOrder

+ var DefaultSlot = &Slot

+ var DefaultStandaloneStatSlot = &StandaloneStatSlot

type DirectTrafficShapingCalculator

+ func (d *DirectTrafficShapingCalculator) BoundOwner() *TrafficShapingController

+ type RejectTrafficShapingChecker struct

+ func NewRejectTrafficShapingChecker(owner *TrafficShapingController, rule *Rule) *RejectTrafficShapingChecker

+ func (d *RejectTrafficShapingChecker) BoundOwner() *TrafficShapingController

+ func (d *RejectTrafficShapingChecker) DoCheck(resStat base.StatNode, batchCount uint32, threshold float64) *base.TokenResult

type Rule

+ StatIntervalInMs uint32

+ Threshold float64

+ func GetRulesOfResource(res string) []Rule

type Slot

+ func (s *Slot) Name() string

+ func (s *Slot) Order() uint32

+ type StandaloneStatSlot struct

+ func (s *StandaloneStatSlot) Name() string

+ func (s *StandaloneStatSlot) Order() uint32

+ func (s StandaloneStatSlot) OnCompleted(ctx *base.EntryContext)

+ func (s StandaloneStatSlot) OnEntryBlocked(ctx *base.EntryContext, blockError *base.BlockError)

+ func (s StandaloneStatSlot) OnEntryPassed(ctx *base.EntryContext)

type ThrottlingChecker

+ func (c *ThrottlingChecker) BoundOwner() *TrafficShapingController

type TrafficShapingCalculator

+ BoundOwner func() *TrafficShapingController

type TrafficShapingChecker

+ BoundOwner func() *TrafficShapingController

type TrafficShapingController

+ func (t *TrafficShapingController) BoundRule() *Rule

type WarmUpTrafficShapingCalculator

+ func (c *WarmUpTrafficShapingCalculator) BoundOwner() *TrafficShapingController

Sep 9, 2020

Changes in this version

+ func IsValidRule(rule *Rule) error

type ControlBehavior

+ func (s ControlBehavior) String() string

+ type DirectTrafficShapingCalculator struct

+ func NewDirectTrafficShapingCalculator(threshold float64) *DirectTrafficShapingCalculator

+ func (d *DirectTrafficShapingCalculator) CalculateAllowedTokens(base.StatNode, uint32, int32) float64

type MetricType

+ func (s MetricType) String() string

type RelationStrategy

+ const CurrentResource

+ func (s RelationStrategy) String() string

+ type Rule struct

+ ControlBehavior ControlBehavior

+ Count float64

+ ID uint64

+ MaxQueueingTimeMs uint32

+ MetricType MetricType

+ RefResource string

+ RelationStrategy RelationStrategy

+ Resource string

+ TokenCalculateStrategy TokenCalculateStrategy

+ WarmUpColdFactor uint32

+ WarmUpPeriodSec uint32

+ func GetResRules(res string) []Rule

+ func (r *Rule) ResourceName() string

+ func (r *Rule) String() string

+ type Slot struct

+ func (s *Slot) Check(ctx *base.EntryContext) *base.TokenResult

+ type TokenCalculateStrategy int32

+ func (s TokenCalculateStrategy) String() string

Sep 2, 2020

Changes in this version

type FlowRule

+ WarmUpColdFactor uint32

+ type WarmUpTrafficShapingCalculator struct

+ func NewWarmUpTrafficShapingCalculator(rule *FlowRule) *WarmUpTrafficShapingCalculator

+ func (c *WarmUpTrafficShapingCalculator) CalculateAllowedTokens(node base.StatNode, acquireCount uint32, flag int32) float64

Mar 19, 2020

Changes in this version

+ const LimitOriginDefault

+ const LimitOriginOther

+ func ClearRules() error

+ func IsValidFlowRule(rule *FlowRule) error

+ func LoadRules(rules []*FlowRule) (bool, error)

+ func RemoveTrafficShapingGenerator(cb ControlBehavior) error

+ func SetTrafficShapingGenerator(cb ControlBehavior, generator TrafficControllerGenFunc) error

+ type ClusterRuleConfig struct

+ ThresholdType ClusterThresholdMode

+ type ClusterThresholdMode uint32

+ const AvgLocalThreshold

+ const GlobalThreshold

+ type ControlBehavior int32

+ const Reject

+ const Throttling

+ const WarmUp

+ const WarmUpThrottling

+ type DefaultTrafficShapingCalculator struct

+ func NewDefaultTrafficShapingCalculator(threshold float64) *DefaultTrafficShapingCalculator

+ func (d *DefaultTrafficShapingCalculator) CalculateAllowedTokens(base.StatNode, uint32, int32) float64

+ type DefaultTrafficShapingChecker struct

+ func NewDefaultTrafficShapingChecker(metricType MetricType) *DefaultTrafficShapingChecker

+ func (d *DefaultTrafficShapingChecker) DoCheck(node base.StatNode, acquireCount uint32, threshold float64) *base.TokenResult

+ type FlowRule struct

+ ClusterConfig ClusterRuleConfig

+ ClusterMode bool

+ ControlBehavior ControlBehavior

+ Count float64

+ ID uint64

+ LimitOrigin string

+ MaxQueueingTimeMs uint32

+ MetricType MetricType

+ RefResource string

+ RelationStrategy RelationStrategy

+ Resource string

+ WarmUpPeriodSec uint32

+ func GetRules() []*FlowRule

+ func (f *FlowRule) ResourceName() string

+ func (f *FlowRule) String() string

+ type FlowSlot struct

+ func (s *FlowSlot) Check(ctx *base.EntryContext) *base.TokenResult

+ type MetricType int32

+ const Concurrency

+ const QPS

+ type RelationStrategy int32

+ const AssociatedResource

+ const Direct

+ type ThrottlingChecker struct

+ func NewThrottlingChecker(timeoutMs uint32) *ThrottlingChecker

+ func (c *ThrottlingChecker) DoCheck(_ base.StatNode, acquireCount uint32, threshold float64) *base.TokenResult

+ type TrafficControllerGenFunc func(*FlowRule) *TrafficShapingController

+ type TrafficControllerMap map[string][]*TrafficShapingController

+ type TrafficShapingCalculator interface

+ CalculateAllowedTokens func(node base.StatNode, acquireCount uint32, flag int32) float64

+ type TrafficShapingChecker interface

+ DoCheck func(node base.StatNode, acquireCount uint32, threshold float64) *base.TokenResult

+ type TrafficShapingController struct

+ func NewTrafficShapingController(flowCalculator TrafficShapingCalculator, flowChecker TrafficShapingChecker, ...) *TrafficShapingController

+ func (t *TrafficShapingController) FlowCalculator() TrafficShapingCalculator

+ func (t *TrafficShapingController) FlowChecker() TrafficShapingChecker

+ func (t *TrafficShapingController) PerformChecking(node base.StatNode, acquireCount uint32, flag int32) *base.TokenResult

+ func (t *TrafficShapingController) Rule() *FlowRule