[feat] eliminate log consumption

Author: UnderTreeTech

pkg/breaker/googlesrebreaker.go

@@ -83,12 +83,13 @@ func (gsb *googleSreBreaker) Allow() error {
 	success, total := gsb.summary()
 	googleAccepts := gsb.k * success
 	dropRatio := math.Max(0, (float64(total)-googleAccepts)/float64(total+1))
-	log.Debugf("breaker", log.String("name", gsb.name), log.Int64("total", total), log.Float64("success", success), log.Float64("accepts", googleAccepts), log.Float64("ratio", dropRatio))
 	if dropRatio <= 0 {
 		if atomic.LoadInt32(&gsb.state) == StateOpen {
 			atomic.CompareAndSwapInt32(&gsb.state, StateOpen, StateClosed)
 		}
 		return nil
+	} else {
+		log.Errorf("breaker", log.String("name", gsb.name), log.Int64("total", total), log.Float64("success", success), log.Float64("accepts", googleAccepts), log.Float64("ratio", dropRatio))
 	}
 
 	if atomic.LoadInt32(&gsb.state) == StateClosed {

pkg/server/rpc/client/client.go

@@ -123,9 +123,7 @@ func (c *Client) ChainUnaryClient() grpc.UnaryClientInterceptor {
 	}
 }
 
-// Chain creates a single interceptor out of a chain of many interceptors.
 // WithUnaryServerChain is a grpc.Client dial option that accepts multiple unary interceptors.
-// Basically syntactic sugar.
 func (c *Client) WithUnaryServerChain() grpc.DialOption {
 	return grpc.WithUnaryInterceptor(c.ChainUnaryClient())
 }
@@ -151,7 +149,7 @@ func (c *Client) GetConn() *grpc.ClientConn {
 	return c.conn
 }
 
-// GetConn return the client breakers
+// GetBreakers return the client breakers
 func (c *Client) GetBreakers() *breaker.BreakerGroup {
 	return c.breakers
 }

pkg/server/rpc/interceptors/logger.go

@@ -107,14 +107,13 @@ func LoggerForUnaryClient(config *config.ClientConfig) grpc.UnaryClientIntercept
 		if peerInfo.Addr != nil {
 			peerIP = peerInfo.Addr.String()
 		}
-		fields := make([]log.Field, 0, 8)
+		fields := make([]log.Field, 0, 7)
 		fields = append(
 			fields,
 			log.String("peer", peerIP),
 			log.String("method", method),
 			log.Float64("quota", quota),
 			log.Float64("duration", duration.Seconds()),
-			log.Any("reply", json.RawMessage(log.JsonBytes(reply))),
 			log.Int("code", estatus.Code()),
 			log.String("error", estatus.Message()),
 		)