Skip to content

Commit f9aa3f8

Browse files
authored
[-] fail early if Prometheus sink cannot be served (#627)
1 parent e2ae8d4 commit f9aa3f8

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

internal/sinks/prometheus.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ package sinks
33
import (
44
"context"
55
"fmt"
6+
"net"
67
"net/http"
78
"reflect"
89
"slices"
@@ -65,9 +66,15 @@ func NewPrometheusWriter(ctx context.Context, connstr string) (promw *Prometheus
6566
Addr: addr,
6667
Handler: promhttp.Handler(),
6768
}
68-
go func() {
69-
log.GetLogger(ctx).Error(promServer.ListenAndServe())
70-
}()
69+
70+
ln, err := net.Listen("tcp", promServer.Addr)
71+
if err != nil {
72+
return nil, err
73+
}
74+
75+
go func() { log.GetLogger(ctx).Error(promServer.Serve(ln)) }()
76+
77+
l.Info(`measurements sink is activated`)
7178
return
7279
}
7380

0 commit comments

Comments
 (0)