use global breaker group instance brks

pkg/breaker/breaker.go

@@ -61,16 +61,24 @@ func (p *Proba) TrueOnProba(proba float64) bool {
 	return reject
 }
 
+// brks global breaker group instance
+var brks *BreakerGroup
+
+func init() {
+	brks = &BreakerGroup{
+		breakers: make(map[string]Breaker),
+	}
+}
+
+// BreakerGroup brks
 type BreakerGroup struct {
 	mutex    sync.RWMutex
 	breakers map[string]Breaker
 }
 
-// NewBreakerGroup return a breaker group pointer
+// NewBreakerGroup returns global breaker group instance brks
 func NewBreakerGroup() *BreakerGroup {
-	return &BreakerGroup{
-		breakers: make(map[string]Breaker),
-	}
+	return brks
 }
 
 // Get return a break associate with the name
@@ -85,7 +93,9 @@ func (bg *BreakerGroup) Get(name string) Breaker {
 	bg.mutex.Lock()
 	breaker, ok = bg.breakers[name]
 	if !ok {
-		breaker = newGoogleSreBreaker(nil)
+		cfg := defaultGoogleSreBreakerConfig()
+		cfg.Name = name
+		breaker = newGoogleSreBreaker(cfg)
 		bg.breakers[name] = breaker
 	}
 	bg.mutex.Unlock()

pkg/breaker/googlesrebreaker_test.go

@@ -19,18 +19,24 @@
 package breaker
 
 import (
+	"os"
 	"testing"
 
 	"github.com/UnderTreeTech/waterdrop/pkg/log"
 
 	"github.com/stretchr/testify/assert"
 )
 
-var bg = NewBreakerGroup()
+var bg *BreakerGroup
+
+func TestMain(m *testing.M) {
+	defer log.New(nil).Sync()
+	bg = NewBreakerGroup()
+	os.Exit(m.Run())
+}
 
 // TestBreakerAccept test breaker Accept
 func TestBreakerAccept(t *testing.T) {
-	defer log.New(nil).Sync()
 	breaker := bg.Get("breaker")
 	for i := 0; i < 100; i++ {
 		breaker.Accept()
@@ -40,7 +46,6 @@ func TestBreakerAccept(t *testing.T) {
 
 // TestBreakerReject test breaker Reject
 func TestBreakerReject(t *testing.T) {
-	defer log.New(nil).Sync()
 	breaker := bg.Get("breaker")
 	for i := 0; i < 40000; i++ {
 		breaker.Reject()
@@ -51,7 +56,6 @@ func TestBreakerReject(t *testing.T) {
 
 // TestBreakerDo test breaker Do
 func TestBreakerDo(t *testing.T) {
-	defer log.New(nil).Sync()
 	err := bg.Do("do", func() error {
 		return nil
 	}, func(e error) bool {