Skip to content

Commit 7ea8059

Browse files
committed
Remove observers from client
1 parent e3d3aa8 commit 7ea8059

File tree

2 files changed

+4
-35
lines changed

2 files changed

+4
-35
lines changed

prometheus/promhttp/client.go

Lines changed: 1 addition & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -19,20 +19,14 @@
1919

2020
package promhttp
2121

22-
import (
23-
"net/http"
24-
25-
"github.com/prometheus/client_golang/prometheus"
26-
)
22+
import "net/http"
2723

2824
type Client struct {
2925
// Do we want to allow users to modify the underlying client after creating the wrapping client?
3026
// c defaults to the http DefaultClient. We use a pointer to support
3127
// the user relying on modifying this behavior globally.
3228
c *http.Client
3329

34-
observers []prometheus.Observer
35-
3630
middleware Middleware
3731
}
3832

@@ -62,15 +56,6 @@ func (c *Client) do(r *http.Request, _ middlewareFunc) (*http.Response, error) {
6256
return c.c.Do(r)
6357
}
6458

65-
// SetObservers sets the observers on Client. Each Observer has Observe called
66-
// at the conclusion of an HTTP roundtrip.
67-
func SetObservers(obs []prometheus.Observer) ConfigFunc {
68-
return func(c *Client) error {
69-
c.observers = obs
70-
return nil
71-
}
72-
}
73-
7459
func SetMiddleware(middlewares ...middlewareFunc) ConfigFunc {
7560
return func(c *Client) error {
7661
c.middleware = build(c, middlewares...)

prometheus/promhttp/client_test.go

Lines changed: 3 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -69,49 +69,33 @@ func TestMiddlewareWrapsFirstToLast(t *testing.T) {
6969
}
7070

7171
func TestMiddlewareAPI(t *testing.T) {
72-
var (
73-
his = prometheus.NewHistogram(prometheus.HistogramOpts{Name: "test_histogram"})
74-
sum = prometheus.NewSummary(prometheus.SummaryOpts{Name: "test_summary"})
75-
gauge = prometheus.NewGauge(prometheus.GaugeOpts{Name: "test_gauge"})
76-
)
77-
78-
obs := []prometheus.Observer{
79-
his,
80-
sum,
81-
prometheus.ObserverFunc(gauge.Set),
82-
}
83-
8472
client := *http.DefaultClient
8573
client.Timeout = 300 * time.Millisecond
8674

8775
inFlightGauge := prometheus.NewGauge(prometheus.GaugeOpts{Name: "inFlight"})
8876
inFlight := func(r *http.Request, next Middleware) (*http.Response, error) {
89-
log.Println("1st")
9077
inFlightGauge.Inc()
9178

9279
resp, err := next(r)
9380

9481
inFlightGauge.Dec()
9582

96-
log.Println("last")
9783
return resp, err
9884
}
9985

10086
counter := prometheus.NewCounter(prometheus.CounterOpts{Name: "test_counter"})
101-
bytesSent := func(req *http.Request, next Middleware) (*http.Response, error) {
87+
addFortyTwo := func(req *http.Request, next Middleware) (*http.Response, error) {
10288
counter.Add(42)
103-
log.Println("2nd")
104-
// counter.Add(float64(req.ContentLength))
10589

10690
return next(req)
10791
}
10892

10993
logging := func(req *http.Request, next Middleware) (*http.Response, error) {
110-
log.Println("3rd")
94+
log.Println("log something interesting")
11195
return next(req)
11296
}
11397

114-
promclient, err := NewClient(SetClient(client), SetObservers(obs), SetMiddleware(inFlight, bytesSent, logging))
98+
promclient, err := NewClient(SetClient(client), SetMiddleware(inFlight, addFortyTwo, logging))
11599
if err != nil {
116100
t.Fatalf("%v", err)
117101
}

0 commit comments

Comments
 (0)