circuitbreaker

Dec 14, 2021

Changes in this version

type Rule

+ ProbeNum uint64

Jul 28, 2021

Changes in this version

+ func ClearRulesOfResource(res string) error

+ func IsValidRule(r *Rule) error

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

type Rule

+ StatSlidingWindowBucketCount uint32

Nov 26, 2020

Changes in this version

+ const RuleCheckSlotName

+ const RuleCheckSlotOrder

+ const StatSlotName

+ const StatSlotOrder

+ var DefaultMetricStatSlot = &MetricStatSlot

+ var DefaultSlot = &Slot

type MetricStatSlot

+ func (s *MetricStatSlot) Name() string

+ func (s *MetricStatSlot) Order() uint32

type Rule

+ func GetRules() []Rule

+ func GetRulesOfResource(resource string) []Rule

type Slot

+ func (s *Slot) Name() string

+ func (s *Slot) Order() uint32

Sep 2, 2020

Changes in this version

+ func ClearStateChangeListeners()

+ func IsValid(r *Rule) error

type Rule

+ Id string

+ MaxAllowedRtMs uint64

+ MinRequestAmount uint64

+ Resource string

+ RetryTimeoutMs uint32

+ StatIntervalMs uint32

+ Strategy Strategy

+ Threshold float64

+ func (r *Rule) ResourceName() string

+ func (r *Rule) String() string

Jul 29, 2020

Changes in this version

type Rule

+ func NewRule(resource string, strategy Strategy, opts ...RuleOption) Rule

+ type RuleOption func(opts *RuleOptions)

+ func WithErrorCountThreshold(errorCountThreshold uint64) RuleOption

+ func WithErrorRatioThreshold(errorRatioThreshold float64) RuleOption

+ func WithMaxAllowedRtMs(maxAllowedRtMs uint64) RuleOption

+ func WithMaxSlowRequestRatio(maxSlowRequestRatio float64) RuleOption

+ func WithMinRequestAmount(minRequestAmount uint64) RuleOption

+ func WithRetryTimeoutMs(retryTimeoutMs uint32) RuleOption

+ func WithStatIntervalMs(statIntervalMs uint32) RuleOption

+ type RuleOptions struct

+ type Slot struct

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

Jun 18, 2020

Changes in this version

+ func ClearRules() error

May 22, 2020

Changes in this version

+ func LoadRules(rules []Rule) (bool, error)

+ func NewErrorCountRule(resource string, intervalMs uint32, retryTimeoutMs uint32, ...) *errorCountRule

+ func NewErrorRatioRule(resource string, intervalMs uint32, retryTimeoutMs uint32, ...) *errorRatioRule

+ func NewSlowRtRule(resource string, intervalMs uint32, retryTimeoutMs uint32, ...) *slowRtRule

+ func RegisterStateChangeListeners(listeners ...StateChangeListener)

+ func RemoveCircuitBreakerGenerator(s Strategy) error

+ func SetCircuitBreakerGenerator(s Strategy, generator CircuitBreakerGenFunc) error

+ type CircuitBreaker interface

+ BoundRule func() Rule

+ BoundStat func() interface{}

+ CurrentState func() State

+ OnRequestComplete func(rtt uint64, err error)

+ TryPass func(ctx *base.EntryContext) bool

+ type CircuitBreakerGenFunc func(r Rule, reuseStat interface{}) CircuitBreaker

+ type CircuitBreakerSlot struct

+ func (b *CircuitBreakerSlot) Check(ctx *base.EntryContext) *base.TokenResult

+ type MetricStatSlot struct

+ func (c *MetricStatSlot) OnCompleted(ctx *base.EntryContext)

+ func (c *MetricStatSlot) OnEntryBlocked(_ *base.EntryContext, _ *base.BlockError)

+ func (c *MetricStatSlot) OnEntryPassed(_ *base.EntryContext)

+ type Rule interface

+ BreakerStatIntervalMs func() uint32

+ BreakerStrategy func() Strategy

+ IsApplicable func() error

+ IsEqualsTo func(r Rule) bool

+ IsStatReusable func(r Rule) bool

+ func GetResRules(resource string) []Rule

+ type RuleBase struct

+ Id string

+ MinRequestAmount uint64

+ Resource string

+ RetryTimeoutMs uint32

+ StatIntervalMs uint32

+ Strategy Strategy

+ func (b *RuleBase) BreakerStatIntervalMs() uint32

+ func (b *RuleBase) BreakerStrategy() Strategy

+ func (b *RuleBase) IsApplicable() error

+ func (b *RuleBase) IsStatReusable(r Rule) bool

+ func (b *RuleBase) ResourceName() string

+ func (b *RuleBase) String() string

+ type State int32

+ const Closed

+ const HalfOpen

+ const Open

+ func (s *State) String() string

+ type StateChangeListener interface

+ OnTransformToClosed func(prev State, rule Rule)

+ OnTransformToHalfOpen func(prev State, rule Rule)

+ OnTransformToOpen func(prev State, rule Rule, snapshot interface{})

+ type Strategy int8

+ const ErrorCount

+ const ErrorRatio

+ const SlowRequestRatio

+ func (s Strategy) String() string