alibaba
diff --git a/‎api/slot_chain.go
Copy file name to clipboard
+3-3Lines changed: 3 additions & 3 deletions b/‎api/slot_chain.go
Copy file name to clipboard
+3-3Lines changed: 3 additions & 3 deletions
diff --git a/‎core/circuitbreaker/rule.go
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/‎core/circuitbreaker/rule.go
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎core/circuitbreaker/rule_manager.go
Copy file name to clipboard
+56-42Lines changed: 56 additions & 42 deletions b/‎core/circuitbreaker/rule_manager.go
Copy file name to clipboard
+56-42Lines changed: 56 additions & 42 deletions
diff --git a/‎core/flow/rule.go
Copy file name to clipboard
+12-12Lines changed: 12 additions & 12 deletions b/‎core/flow/rule.go
Copy file name to clipboard
+12-12Lines changed: 12 additions & 12 deletions
diff --git a/‎core/freq_params_traffic/cache/concurrent_cache.go renamed to ‎core/hotspot/cache/concurrent_cache.go
Copy file name to clipboard b/‎core/freq_params_traffic/cache/concurrent_cache.go renamed to ‎core/hotspot/cache/concurrent_cache.go
Copy file name to clipboard
diff --git a/‎core/freq_params_traffic/cache/concurrent_lru.go renamed to ‎core/hotspot/cache/concurrent_lru.go
Copy file name to clipboard b/‎core/freq_params_traffic/cache/concurrent_lru.go renamed to ‎core/hotspot/cache/concurrent_lru.go
Copy file name to clipboard
diff --git a/‎core/freq_params_traffic/cache/concurrent_lru_benchmark_test.go renamed to ‎core/hotspot/cache/concurrent_lru_benchmark_test.go
Copy file name to clipboard b/‎core/freq_params_traffic/cache/concurrent_lru_benchmark_test.go renamed to ‎core/hotspot/cache/concurrent_lru_benchmark_test.go
Copy file name to clipboard
diff --git a/‎core/freq_params_traffic/cache/concurrent_lru_test.go renamed to ‎core/hotspot/cache/concurrent_lru_test.go
Copy file name to clipboard b/‎core/freq_params_traffic/cache/concurrent_lru_test.go renamed to ‎core/hotspot/cache/concurrent_lru_test.go
Copy file name to clipboard
diff --git a/‎core/freq_params_traffic/cache/lru.go renamed to ‎core/hotspot/cache/lru.go
Copy file name to clipboard b/‎core/freq_params_traffic/cache/lru.go renamed to ‎core/hotspot/cache/lru.go
Copy file name to clipboard
diff --git a/‎core/freq_params_traffic/concurrency_stat_slot.go renamed to ‎core/hotspot/concurrency_stat_slot.go
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎core/freq_params_traffic/concurrency_stat_slot.go renamed to ‎core/hotspot/concurrency_stat_slot.go
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
@@ -4,7 +4,7 @@ import (
 	"github.com/alibaba/sentinel-golang/core/base"
 	"github.com/alibaba/sentinel-golang/core/circuitbreaker"
 	"github.com/alibaba/sentinel-golang/core/flow"
-	"github.com/alibaba/sentinel-golang/core/freq_params_traffic"
+	"github.com/alibaba/sentinel-golang/core/hotspot"
 	"github.com/alibaba/sentinel-golang/core/log"
 	"github.com/alibaba/sentinel-golang/core/stat"
 	"github.com/alibaba/sentinel-golang/core/system"
@@ -31,10 +31,10 @@ func BuildDefaultSlotChain() *base.SlotChain {
 	sc.AddRuleCheckSlotLast(&system.SystemAdaptiveSlot{})
 	sc.AddRuleCheckSlotLast(&flow.FlowSlot{})
 	sc.AddRuleCheckSlotLast(&circuitbreaker.CircuitBreakerSlot{})
-	sc.AddRuleCheckSlotLast(&freq_params_traffic.FreqPramsTrafficSlot{})
+	sc.AddRuleCheckSlotLast(&hotspot.FreqPramsTrafficSlot{})
 	sc.AddStatSlotLast(&stat.StatisticSlot{})
 	sc.AddStatSlotLast(&log.LogSlot{})
 	sc.AddStatSlotLast(&circuitbreaker.MetricStatSlot{})
-	sc.AddStatSlotLast(&freq_params_traffic.ConcurrencyStatSlot{})
+	sc.AddStatSlotLast(&hotspot.ConcurrencyStatSlot{})
 	return sc
 }
@@ -83,7 +83,7 @@ func (b *RuleBase) IsStatReusable(r Rule) bool {
 
 func (b *RuleBase) String() string {
 	// fallback string
-	return fmt.Sprintf("RuleBase{id=%s,resource=%s, strategy=%+v, RetryTimeoutMs=%d, MinRequestAmount=%d}",
+	return fmt.Sprintf("{id=%s,resource=%s, strategy=%+v, RetryTimeoutMs=%d, MinRequestAmount=%d}",
 		b.Id, b.Resource, b.Strategy, b.RetryTimeoutMs, b.MinRequestAmount)
 }
 
@@ -140,7 +140,7 @@ func (r *slowRtRule) IsApplicable() error {
 }
 
 func (r *slowRtRule) String() string {
-	return fmt.Sprintf("slowRtRule{RuleBase:%s, MaxAllowedRt=%d, MaxSlowRequestRatio=%f}", r.RuleBase.String(), r.MaxAllowedRt, r.MaxSlowRequestRatio)
+	return fmt.Sprintf("{slowRtRule{RuleBase:%s, MaxAllowedRt=%d, MaxSlowRequestRatio=%f}", r.RuleBase.String(), r.MaxAllowedRt, r.MaxSlowRequestRatio)
 }
 
 // Error ratio circuit breaker rule
@@ -164,7 +164,7 @@ func NewErrorRatioRule(resource string, intervalMs uint32, retryTimeoutMs uint32
 }
 
 func (r *errorRatioRule) String() string {
-	return fmt.Sprintf("errorRatioRule{RuleBase:%s, Threshold=%f}", r.RuleBase.String(), r.Threshold)
+	return fmt.Sprintf("{errorRatioRule{RuleBase:%s, Threshold=%f}", r.RuleBase.String(), r.Threshold)
 }
 
 func (r *errorRatioRule) IsEqualsTo(newRule Rule) bool {
@@ -207,7 +207,7 @@ func NewErrorCountRule(resource string, intervalMs uint32, retryTimeoutMs uint32
 }
 
 func (r *errorCountRule) String() string {
-	return fmt.Sprintf("errorCountRule{RuleBase:%s, Threshold=%d}", r.RuleBase.String(), r.Threshold)
+	return fmt.Sprintf("{errorCountRule{RuleBase:%s, Threshold=%d}", r.RuleBase.String(), r.Threshold)
 }
 
 func (r *errorCountRule) IsEqualsTo(newRule Rule) bool {
 
@@ -1,8 +1,8 @@
 package circuitbreaker
 
 import (
-	"encoding/json"
 	"fmt"
+	"strings"
 	"sync"
 
 	"github.com/alibaba/sentinel-golang/logging"
@@ -82,6 +82,12 @@ func GetResRules(resource string) []Rule {
 	return ret
 }
 
+// ClearRules clear all the previous rules
+func ClearRules() error {
+	_, err := LoadRules(nil)
+	return err
+}
+
 // LoadRules replaces old rules with the given circuit breaking rules.
 //
 // return value:
@@ -106,6 +112,42 @@ func getResBreakers(resource string) []CircuitBreaker {
 	return ret
 }
 
+func calculateReuseIndexFor(r Rule, oldResCbs []CircuitBreaker) (equalIdx, reuseStatIdx int) {
+	// the index of equivalent rule in old circuit breaker slice
+	equalIdx = -1
+	// the index of statistic reusable rule in old circuit breaker slice
+	reuseStatIdx = -1
+
+	for idx, oldTc := range oldResCbs {
+		oldRule := oldTc.BoundRule()
+		if oldRule.IsEqualsTo(r) {
+			// break if there is equivalent rule
+			equalIdx = idx
+			break
+		}
+		// find the index of first StatReusable rule
+		if !oldRule.IsStatReusable(r) {
+			continue
+		}
+		if reuseStatIdx >= 0 {
+			// had find reuse rule.
+			continue
+		}
+		reuseStatIdx = idx
+	}
+	return equalIdx, reuseStatIdx
+}
+
+func insertCbToCbMap(cb CircuitBreaker, res string, m map[string][]CircuitBreaker) {
+	cbsOfRes, exists := m[res]
+	if !exists {
+		cbsOfRes = make([]CircuitBreaker, 0, 1)
+		m[res] = append(cbsOfRes, cb)
+	} else {
+		m[res] = append(cbsOfRes, cb)
+	}
+}
+
 // Concurrent safe to update rules
 func onRuleUpdate(rules []Rule) (err error) {
 	defer func() {
@@ -145,43 +187,19 @@ func onRuleUpdate(rules []Rule) (err error) {
 	for res, resRules := range newBreakerRules {
 		emptyCircuitBreakerList := make([]CircuitBreaker, 0, 0)
 		for _, r := range resRules {
-			// TODO: rearrange the code here.
 			oldResCbs := breakers[res]
 			if oldResCbs == nil {
 				oldResCbs = emptyCircuitBreakerList
 			}
-			equalsIdx := -1
-			reuseStatIdx := -1
-			for idx, cb := range oldResCbs {
-				oldRule := cb.BoundRule()
-				if oldRule.IsEqualsTo(r) {
-					equalsIdx = idx
-					break
-				}
-				if !oldRule.IsStatReusable(r) {
-					continue
-				}
-				if reuseStatIdx >= 0 {
-					// had find reuse rule.
-					continue
-				}
-				reuseStatIdx = idx
-			}
+			equalIdx, reuseStatIdx := calculateReuseIndexFor(r, oldResCbs)
 
 			// First check equals scenario
-			if equalsIdx >= 0 {
+			if equalIdx >= 0 {
 				// reuse the old cb
-				reuseOldCb := oldResCbs[equalsIdx]
-				cbsOfRes, ok := newBreakers[res]
-				if !ok {
-					cbsOfRes = make([]CircuitBreaker, 0, 1)
-					newBreakers[res] = append(cbsOfRes, reuseOldCb)
-				} else {
-					newBreakers[res] = append(cbsOfRes, reuseOldCb)
-				}
+				equalOldCb := oldResCbs[equalIdx]
+				insertCbToCbMap(equalOldCb, res, newBreakers)
 				// remove old cb from oldResCbs
-				oldResCbs = append(oldResCbs[:equalsIdx], oldResCbs[equalsIdx+1:]...)
-				breakers[res] = oldResCbs
+				breakers[res] = append(oldResCbs[:equalIdx], oldResCbs[equalIdx+1:]...)
 				continue
 			}
 
@@ -205,13 +223,7 @@ func onRuleUpdate(rules []Rule) (err error) {
 			if reuseStatIdx >= 0 {
 				breakers[res] = append(oldResCbs[:reuseStatIdx], oldResCbs[reuseStatIdx+1:]...)
 			}
-			cbsOfRes, ok := newBreakers[res]
-			if !ok {
-				cbsOfRes = make([]CircuitBreaker, 0, 1)
-				newBreakers[res] = append(cbsOfRes, cb)
-			} else {
-				newBreakers[res] = append(cbsOfRes, cb)
-			}
+			insertCbToCbMap(cb, res, newBreakers)
 		}
 	}
 
@@ -241,12 +253,14 @@ func rulesFrom(rm map[string][]Rule) []Rule {
 }
 
 func logRuleUpdate(rules map[string][]Rule) {
-	s, err := json.Marshal(rules)
-	if err != nil {
-		logger.Info("Circuit breaking rules loaded")
-	} else {
-		logger.Infof("Circuit breaking rules loaded: %s", s)
+	sb := strings.Builder{}
+	sb.WriteString("Circuit breaking rules loaded:[")
+
+	for _, r := range rulesFrom(rules) {
+		sb.WriteString(r.String() + ",")
 	}
+	sb.WriteString("]")
+	logger.Info(sb.String())
 }
 
 func RegisterStateChangeListeners(listeners ...StateChangeListener) {
 
@@ -58,24 +58,24 @@ type ClusterRuleConfig struct {
 // FlowRule describes the strategy of flow control.
 type FlowRule struct {
 	// ID represents the unique ID of the rule (optional).
-	ID uint64 `json:"id,omitempty"`
+	ID uint64
 
 	// Resource represents the resource name.
-	Resource string `json:"resource"`
+	Resource string
 	// LimitOrigin represents the target origin (reserved field).
-	LimitOrigin string     `json:"limitApp"`
-	MetricType  MetricType `json:"grade"`
+	LimitOrigin string
+	MetricType  MetricType
 	// Count represents the threshold.
-	Count            float64          `json:"count"`
-	RelationStrategy RelationStrategy `json:"strategy"`
-	ControlBehavior  ControlBehavior  `json:"controlBehavior"`
+	Count            float64
+	RelationStrategy RelationStrategy
+	ControlBehavior  ControlBehavior
 
-	RefResource       string `json:"refResource,omitempty"`
-	WarmUpPeriodSec   uint32 `json:"warmUpPeriodSec"`
-	MaxQueueingTimeMs uint32 `json:"maxQueueingTimeMs"`
+	RefResource       string
+	WarmUpPeriodSec   uint32
+	MaxQueueingTimeMs uint32
 	// ClusterMode indicates whether the rule is for cluster flow control or local.
-	ClusterMode   bool              `json:"clusterMode"`
-	ClusterConfig ClusterRuleConfig `json:"clusterConfig"`
+	ClusterMode   bool
+	ClusterConfig ClusterRuleConfig
 }
 
 func (f *FlowRule) String() string {
 
@@ -1,4 +1,4 @@
-package freq_params_traffic
+package hotspot
 
 import (
 	"github.com/alibaba/sentinel-golang/core/base"
Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ func (b *RuleBase) IsStatReusable(r Rule) bool {`
`83`	`83`
`84`	`84`	`func (b *RuleBase) String() string {`
`85`	`85`	`// fallback string`
`86`		`- return fmt.Sprintf("RuleBase{id=%s,resource=%s, strategy=%+v, RetryTimeoutMs=%d, MinRequestAmount=%d}",`
	`86`	`+ return fmt.Sprintf("{id=%s,resource=%s, strategy=%+v, RetryTimeoutMs=%d, MinRequestAmount=%d}",`
`87`	`87`	`b.Id, b.Resource, b.Strategy, b.RetryTimeoutMs, b.MinRequestAmount)`
`88`	`88`	`}`
`89`	`89`
`@@ -140,7 +140,7 @@ func (r *slowRtRule) IsApplicable() error {`
`140`	`140`	`}`
`141`	`141`
`142`	`142`	`func (r *slowRtRule) String() string {`
`143`		`- return fmt.Sprintf("slowRtRule{RuleBase:%s, MaxAllowedRt=%d, MaxSlowRequestRatio=%f}", r.RuleBase.String(), r.MaxAllowedRt, r.MaxSlowRequestRatio)`
	`143`	`+ return fmt.Sprintf("{slowRtRule{RuleBase:%s, MaxAllowedRt=%d, MaxSlowRequestRatio=%f}", r.RuleBase.String(), r.MaxAllowedRt, r.MaxSlowRequestRatio)`
`144`	`144`	`}`
`145`	`145`
`146`	`146`	`// Error ratio circuit breaker rule`
`@@ -164,7 +164,7 @@ func NewErrorRatioRule(resource string, intervalMs uint32, retryTimeoutMs uint32`
`164`	`164`	`}`
`165`	`165`
`166`	`166`	`func (r *errorRatioRule) String() string {`
`167`		`- return fmt.Sprintf("errorRatioRule{RuleBase:%s, Threshold=%f}", r.RuleBase.String(), r.Threshold)`
	`167`	`+ return fmt.Sprintf("{errorRatioRule{RuleBase:%s, Threshold=%f}", r.RuleBase.String(), r.Threshold)`
`168`	`168`	`}`
`169`	`169`
`170`	`170`	`func (r *errorRatioRule) IsEqualsTo(newRule Rule) bool {`
`@@ -207,7 +207,7 @@ func NewErrorCountRule(resource string, intervalMs uint32, retryTimeoutMs uint32`
`207`	`207`	`}`
`208`	`208`
`209`	`209`	`func (r *errorCountRule) String() string {`
`210`		`- return fmt.Sprintf("errorCountRule{RuleBase:%s, Threshold=%d}", r.RuleBase.String(), r.Threshold)`
	`210`	`+ return fmt.Sprintf("{errorCountRule{RuleBase:%s, Threshold=%d}", r.RuleBase.String(), r.Threshold)`
`211`	`211`	`}`
`212`	`212`
`213`	`213`	`func (r *errorCountRule) IsEqualsTo(newRule Rule) bool {`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package freq_params_traffic`
	`1`	`+package hotspot`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"github.com/alibaba/sentinel-golang/core/base"`