Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

VW: allow setting custom timeouts (#1111)

Browse source 
* VW: allow setting custom timeouts
* Add HTTP request metrics
This commit is contained in:
andig 2021-06-03 18:18:55 +02:00 • committed by GitHub
parent 0b1864bb97
commit ae035be94d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
8 changed files with 83 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

52
util/request/roundtrip.go
View file

@ -2,12 +2,13 @@ package request
import (
"bytes"
"fmt"
"net/http"
"net/http/httputil"
"strings"
"time"
"github.com/andig/evcc/util"
"github.com/prometheus/client_golang/prometheus"
)
type roundTripper struct {
@ -17,6 +18,43 @@ type roundTripper struct {
const max = 2048 * 2
var (
reqMetric *prometheus.SummaryVec
cntMetric, errMetric *prometheus.CounterVec
)
func init() {
labels := []string{"host"}
reqMetric = prometheus.NewSummaryVec(prometheus.SummaryOpts{
Namespace: "evcc",
Subsystem: "http",
Name: "request_duration_seconds",
Help: "A summary of HTTP request durations",
Objectives: map[float64]float64{
0.5: 0.05, // 50th percentile with a max. absolute error of 0.05
0.9: 0.01, // 90th percentile with a max. absolute error of 0.01
0.99: 0.001, // 99th percentile with a max. absolute error of 0.001
},
}, labels)
cntMetric = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "evcc",
Subsystem: "http",
Name: "request_total",
Help: "Total count of HTTP requests",
}, labels)
errMetric = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "evcc",
Subsystem: "http",
Name: "request_errors",
Help: "Total count of HTTP request errors",
}, labels)
prometheus.MustRegister(reqMetric, cntMetric, errMetric)
}
// NewTripper creates a logging roundtrip handler
func NewTripper(log *util.Logger, base http.RoundTripper) http.RoundTripper {
tripper := &roundTripper{
@ -35,21 +73,27 @@ func min(a, b int) int {
}
func (r *roundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
var bld strings.Builder
bld.WriteString(fmt.Sprintf("%s %s", req.Method, req.URL.String()))
r.log.TRACE.Printf("%s %s", req.Method, req.URL.String())
var bld strings.Builder
if body, err := httputil.DumpRequestOut(req, true); err == nil {
bld.WriteString("\n")
bld.Write(bytes.TrimSpace(body[:min(max, len(body))]))
}
startTime := time.Now()
resp, err := r.base.RoundTrip(req)
cntMetric.WithLabelValues(req.URL.Hostname()).Add(1)
if err == nil {
reqMetric.WithLabelValues(req.URL.Hostname()).Observe(time.Since(startTime).Seconds())
if resp != nil {
if body, err := httputil.DumpResponse(resp, true); err == nil {
bld.WriteString("\n\n")
bld.Write(bytes.TrimSpace(body[:min(max, len(body))]))
}
} else {
errMetric.WithLabelValues(req.URL.Hostname()).Add(1)
}
if bld.Len() > 0 {