chore: refactor the imports (#2406)

core/metric/counter.go

@@ -1,10 +1,9 @@
 package metric
 
 import (
+	prom "github.com/prometheus/client_golang/prometheus"
 	"github.com/zeromicro/go-zero/core/proc"
 	"github.com/zeromicro/go-zero/core/prometheus"
-
-	prom "github.com/prometheus/client_golang/prometheus"
 )
 
 type (

core/metric/counter_test.go

@@ -3,10 +3,9 @@ package metric
 import (
 	"testing"
 
-	"github.com/zeromicro/go-zero/core/prometheus"
-
 	"github.com/prometheus/client_golang/prometheus/testutil"
 	"github.com/stretchr/testify/assert"
+	"github.com/zeromicro/go-zero/core/prometheus"
 )
 
 func TestNewCounterVec(t *testing.T) {

core/metric/gauge.go

@@ -1,10 +1,9 @@
 package metric
 
 import (
+	prom "github.com/prometheus/client_golang/prometheus"
 	"github.com/zeromicro/go-zero/core/proc"
 	"github.com/zeromicro/go-zero/core/prometheus"
-
-	prom "github.com/prometheus/client_golang/prometheus"
 )
 
 type (

core/metric/histogram.go

@@ -1,10 +1,9 @@
 package metric
 
 import (
+	prom "github.com/prometheus/client_golang/prometheus"
 	"github.com/zeromicro/go-zero/core/proc"
 	"github.com/zeromicro/go-zero/core/prometheus"
-
-	prom "github.com/prometheus/client_golang/prometheus"
 )
 
 type (

core/stores/redis/hook.go

@@ -57,7 +57,7 @@ func (h hook) AfterProcess(ctx context.Context, cmd red.Cmder) error {
 	}
 
 	metricReqDur.Observe(int64(duration/time.Millisecond), cmd.Name())
-	if msg := errFormat(err); len(msg) > 0 {
+	if msg := formatError(err); len(msg) > 0 {
 		metricReqErr.Inc(cmd.Name(), msg)
 	}
 
@@ -104,14 +104,14 @@ func (h hook) AfterProcessPipeline(ctx context.Context, cmds []red.Cmder) error
 	}
 
 	metricReqDur.Observe(int64(duration/time.Millisecond), "Pipeline")
-	if msg := errFormat(batchError.Err()); len(msg) > 0 {
+	if msg := formatError(batchError.Err()); len(msg) > 0 {
 		metricReqErr.Inc("Pipeline", msg)
 	}
 
 	return nil
 }
 
-func errFormat(err error) string {
+func formatError(err error) string {
 	if err == nil || err == red.Nil {
 		return ""
 	}

core/stores/sqlx/metrics.go

@@ -2,7 +2,7 @@ package sqlx
 
 import "github.com/zeromicro/go-zero/core/metric"
 
-const namespace = "mysql_client"
+const namespace = "sql_client"
 
 var (
 	metricReqDur = metric.NewHistogramVec(&metric.HistogramVecOpts{

core/stores/sqlx/sqlconn.go

@@ -153,7 +153,6 @@ func (db *commonSqlConn) ExecCtx(ctx context.Context, q string, args ...interfac
 		result, err = exec(ctx, conn, q, args...)
 		return err
 	}, db.acceptable)
-
 	if err == breaker.ErrServiceUnavailable {
 		metricReqErr.Inc("Exec", "breaker")
 	}
@@ -190,7 +189,6 @@ func (db *commonSqlConn) PrepareCtx(ctx context.Context, query string) (stmt Stm
 		}
 		return nil
 	}, db.acceptable)
-
 	if err == breaker.ErrServiceUnavailable {
 		metricReqErr.Inc("Prepare", "breaker")
 	}
@@ -281,7 +279,6 @@ func (db *commonSqlConn) TransactCtx(ctx context.Context, fn func(context.Contex
 	err = db.brk.DoWithAcceptable(func() error {
 		return transact(ctx, db, db.beginTx, fn)
 	}, db.acceptable)
-
 	if err == breaker.ErrServiceUnavailable {
 		metricReqErr.Inc("Transact", "breaker")
 	}
@@ -315,7 +312,6 @@ func (db *commonSqlConn) queryRows(ctx context.Context, scanner func(*sql.Rows)
 	}, func(err error) bool {
 		return qerr == err || db.acceptable(err)
 	})
-
 	if err == breaker.ErrServiceUnavailable {
 		metricReqErr.Inc("queryRows", "breaker")
 	}

zrpc/internal/clientinterceptors/prometheusinterceptor.go

@@ -7,7 +7,6 @@ import (
 
 	"github.com/zeromicro/go-zero/core/metric"
 	"github.com/zeromicro/go-zero/core/timex"
-
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/status"
 )

zrpc/internal/serverinterceptors/prometheusinterceptor.go

@@ -7,7 +7,6 @@ import (
 
 	"github.com/zeromicro/go-zero/core/metric"
 	"github.com/zeromicro/go-zero/core/timex"
-
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/status"
 )