Skip to content

Commit

Permalink
chore: update goctl version to 1.6.0 (zeromicro#3674)
Browse files Browse the repository at this point in the history
  • Loading branch information
kevwan authored Oct 27, 2023
1 parent f8adc71 commit 9394e59
Show file tree
Hide file tree
Showing 4 changed files with 32 additions and 29 deletions.
8 changes: 3 additions & 5 deletions core/stores/redis/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,11 +34,9 @@ var (
Labels: []string{"command"},
})

connLabels = []string{"key", "client_type"}

connCollector = newCollector()

_ prometheus.Collector = (*collector)(nil)
connLabels = []string{"key", "client_type"}
connCollector = newCollector()
_ prometheus.Collector = (*collector)(nil)
)

type (
Expand Down
35 changes: 21 additions & 14 deletions core/stores/sqlx/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,11 +34,9 @@ var (
Labels: []string{"command"},
})

connLabels = []string{"db_name", "hash"}

connCollector = newCollector()

_ prometheus.Collector = (*collector)(nil)
connLabels = []string{"db_name", "hash"}
connCollector = newCollector()
_ prometheus.Collector = (*collector)(nil)
)

type (
Expand Down Expand Up @@ -143,15 +141,24 @@ func (c *collector) Collect(ch chan<- prometheus.Metric) {
for _, client := range c.clients {
dbName, hash := client.dbName, client.hash
stats := client.poolStats()
ch <- prometheus.MustNewConstMetric(c.maxOpenConnections, prometheus.GaugeValue, float64(stats.MaxOpenConnections), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.openConnections, prometheus.GaugeValue, float64(stats.OpenConnections), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.inUseConnections, prometheus.GaugeValue, float64(stats.InUse), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.idleConnections, prometheus.GaugeValue, float64(stats.Idle), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.waitCount, prometheus.CounterValue, float64(stats.WaitCount), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.waitDuration, prometheus.CounterValue, stats.WaitDuration.Seconds(), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxIdleClosed, prometheus.CounterValue, float64(stats.MaxIdleClosed), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxLifetimeClosed, prometheus.CounterValue, float64(stats.MaxLifetimeClosed), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxIdleTimeClosed, prometheus.CounterValue, float64(stats.MaxIdleTimeClosed), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxOpenConnections, prometheus.GaugeValue,
float64(stats.MaxOpenConnections), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.openConnections, prometheus.GaugeValue,
float64(stats.OpenConnections), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.inUseConnections, prometheus.GaugeValue,
float64(stats.InUse), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.idleConnections, prometheus.GaugeValue,
float64(stats.Idle), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.waitCount, prometheus.CounterValue,
float64(stats.WaitCount), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.waitDuration, prometheus.CounterValue,
stats.WaitDuration.Seconds(), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxIdleClosed, prometheus.CounterValue,
float64(stats.MaxIdleClosed), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxLifetimeClosed, prometheus.CounterValue,
float64(stats.MaxLifetimeClosed), dbName, hash)
ch <- prometheus.MustNewConstMetric(c.maxIdleTimeClosed, prometheus.CounterValue,
float64(stats.MaxIdleTimeClosed), dbName, hash)
}
}

Expand Down
16 changes: 7 additions & 9 deletions rest/httpc/internal/metricsinterceptor.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,26 +31,24 @@ var (
})
)

type (
MetricsURLRewriter func(u url.URL) string
)
type MetricsURLRewriter func(u url.URL) string

func MetricsInterceptor(name string, pr MetricsURLRewriter) Interceptor {
return func(r *http.Request) (*http.Request, ResponseHandler) {
startTime := timex.Now()
return r, func(resp *http.Response, err error) {
u := cleanURL(*r.URL)
method := r.Method
var (
code int
path string
)
var code int
var path string

// error or resp is nil, set code=500
if err != nil || resp == nil {
code = http.StatusInternalServerError
} else {
code = resp.StatusCode
}

u := cleanURL(*r.URL)
method := r.Method
if pr != nil {
path = pr(u)
} else {
Expand Down
2 changes: 1 addition & 1 deletion tools/goctl/internal/version/version.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
)

// BuildVersion is the version of goctl.
const BuildVersion = "1.5.6"
const BuildVersion = "1.6.0"

var tag = map[string]int{"pre-alpha": 0, "alpha": 1, "pre-bata": 2, "beta": 3, "released": 4, "": 5}

Expand Down

0 comments on commit 9394e59

Please sign in to comment.