// Package metrics implement a handler and plugin that provides Prometheus metrics. package metrics import ( "context" "net" "net/http" "sync" "time" "github.com/coredns/coredns/plugin" "github.com/coredns/coredns/plugin/metrics/vars" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" ) // Metrics holds the prometheus configuration. The metrics' path is fixed to be /metrics type Metrics struct { Next plugin.Handler Addr string Reg *prometheus.Registry ln net.Listener lnSetup bool mux *http.ServeMux srv *http.Server zoneNames []string zoneMap map[string]struct{} zoneMu sync.RWMutex } // New returns a new instance of Metrics with the given address func New(addr string) *Metrics { met := &Metrics{ Addr: addr, Reg: prometheus.NewRegistry(), zoneMap: make(map[string]struct{}), } // Add the default collectors met.MustRegister(prometheus.NewGoCollector()) met.MustRegister(prometheus.NewProcessCollector(prometheus.ProcessCollectorOpts{})) // Add all of our collectors met.MustRegister(buildInfo) met.MustRegister(vars.Panic) met.MustRegister(vars.RequestCount) met.MustRegister(vars.RequestDuration) met.MustRegister(vars.RequestSize) met.MustRegister(vars.RequestDo) met.MustRegister(vars.RequestType) met.MustRegister(vars.ResponseSize) met.MustRegister(vars.ResponseRcode) return met } // MustRegister wraps m.Reg.MustRegister. func (m *Metrics) MustRegister(c prometheus.Collector) { err := m.Reg.Register(c) if err != nil { // ignore any duplicate error, but fatal on any other kind of error if _, ok := err.(prometheus.AlreadyRegisteredError); !ok { log.Fatalf("Cannot register metrics collector: %s", err) } } } // AddZone adds zone z to m. func (m *Metrics) AddZone(z string) { m.zoneMu.Lock() m.zoneMap[z] = struct{}{} m.zoneNames = keys(m.zoneMap) m.zoneMu.Unlock() } // RemoveZone remove zone z from m. func (m *Metrics) RemoveZone(z string) { m.zoneMu.Lock() delete(m.zoneMap, z) m.zoneNames = keys(m.zoneMap) m.zoneMu.Unlock() } // ZoneNames returns the zones of m. func (m *Metrics) ZoneNames() []string { m.zoneMu.RLock() s := m.zoneNames m.zoneMu.RUnlock() return s } // OnStartup sets up the metrics on startup. func (m *Metrics) OnStartup() error { ln, err := net.Listen("tcp", m.Addr) if err != nil { log.Errorf("Failed to start metrics handler: %s", err) return err } m.ln = ln m.lnSetup = true ListenAddr = m.ln.Addr().String() // For tests m.mux = http.NewServeMux() m.mux.Handle("/metrics", promhttp.HandlerFor(m.Reg, promhttp.HandlerOpts{})) m.srv = &http.Server{Handler: m.mux} go func() { m.srv.Serve(m.ln) }() return nil } // OnRestart stops the listener on reload. func (m *Metrics) OnRestart() error { if !m.lnSetup { return nil } uniqAddr.Unset(m.Addr) return m.stopServer() } func (m *Metrics) stopServer() error { if !m.lnSetup { return nil } ctx, cancel := context.WithTimeout(context.Background(), shutdownTimeout) defer cancel() if err := m.srv.Shutdown(ctx); err != nil { log.Infof("Failed to stop prometheus http server: %s", err) return err } m.lnSetup = false m.ln.Close() return nil } // OnFinalShutdown tears down the metrics listener on shutdown and restart. func (m *Metrics) OnFinalShutdown() error { return m.stopServer() } func keys(m map[string]struct{}) []string { sx := []string{} for k := range m { sx = append(sx, k) } return sx } // ListenAddr is assigned the address of the prometheus listener. Its use is mainly in tests where // we listen on "localhost:0" and need to retrieve the actual address. var ListenAddr string // shutdownTimeout is the maximum amount of time the metrics plugin will wait // before erroring when it tries to close the metrics server const shutdownTimeout time.Duration = time.Second * 5 var buildInfo = prometheus.NewGaugeVec(prometheus.GaugeOpts{ Namespace: plugin.Namespace, Name: "build_info", Help: "A metric with a constant '1' value labeled by version, revision, and goversion from which CoreDNS was built.", }, []string{"version", "revision", "goversion"}) amework-svelte'>examples/framework-svelte Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/.github/workflows/issue.yml (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2021-09-15[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-14Revert "fix bad ci paths"Gravatar Fred K. Schott 1-5/+5
2021-09-15[ci] yarn formatGravatar FredKSchott 1-0/+1
2021-09-14Version Packages (#1358)astro@0.20.6@astrojs/renderer-vue@0.1.8@astrojs/renderer-svelte@0.1.2@astrojs/renderer-solid@0.1.1@astrojs/renderer-react@0.2.1@astrojs/renderer-preact@0.2.2@astrojs/renderer-lit@0.1.1Gravatar github-actions[bot] 41-70/+91
2021-09-14fix bad ci pathsGravatar Fred K. Schott 1-5/+5
2021-09-14update changesetsGravatar Fred K. Schott 1-1/+1
2021-09-14Fix passing Markdown content through props (#1259) (#1343)Gravatar kelvinsjk 4-0/+22
2021-09-14Improve stats logging to use `pretty-bytes` so that 20B doesn't get output as...Gravatar Caleb Jasik 4-2/+13
2021-09-14[ci] yarn formatGravatar FredKSchott 1-1/+1
2021-09-14Merge "Remove check for referenced files" (#1196)Gravatar (none) 6-6/+45
2021-09-14Docs: Add READMEs for renderers (#1351)Gravatar Drew Powers 8-1/+184
2021-09-14Update deployment docs for Netlify deployment (#1361)Gravatar Cassidy Williams 1-7/+9
2021-09-14Delete perfect-kids-occur.md (#1372)Gravatar Fred K. Schott 1-5/+0
2021-09-14[ci] yarn formatGravatar FredKSchott 1-15/+10
2021-09-14Self-host homepage fonts to improve page load speed (#1370)Gravatar mundry 14-5/+52
2021-09-14Add types to examples and docs (#1347)Gravatar Matthew Phillips 8-20/+60
2021-09-14[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-13Fix typo (#1360)Gravatar Marcus Otterström 1-1/+1
2021-09-13Disclaimer for Github pages / jekyll quirk (#1355)Gravatar Tc001 2-0/+7
2021-09-13fix outdated lockfile issue (#1357)Gravatar Fred K. Schott 1-3/+1
2021-09-13Add `astro.build/play` link (#1359)Gravatar Nate Moore 1-0/+6
2021-09-13[ci] yarn formatGravatar FredKSchott 2-8/+7
2021-09-13Add a new lockfile (#1356)Gravatar Matthew Phillips 1-19/+19
2021-09-13[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-12[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-11[ci] collect statsGravatar FredKSchott 1-0/+1
2021-09-10Prevent removing CSS preloads during bundling (#1326)Gravatar Bartek Igielski 8-18/+96
2021-09-10Fix typos in Netlify sponsorship announcement blog post (#1346)Gravatar mundry 1-4/+4
2021-09-10[ci] collect statsGravatar FredKSchott 2-1/+2
2021-09-09blog: announce netlify sponsorship (#1345)Gravatar Fred K. Schott 4-5/+64
2021-09-09Version Packages (#1344)Gravatar github-actions[bot] 29-53/+42
2021-09-09Revert "Version Packages (#1303)"Gravatar Fred K. Schott 29-42/+53
2021-09-09update lockfileastro@0.20.5@astrojs/markdown-support@0.3.1Gravatar Fred K. Schott 1-9/+9
2021-09-09Version Packages (#1303)Gravatar github-actions[bot] 29-53/+42
2021-09-09[ci] collect statsGravatar FredKSchott 2-1/+2
2021-09-08Update netlify deploy instructions for `.nvmrc` syntax (#1337)Gravatar Caleb Jasik 1-1/+1
2021-09-08[ci] yarn formatGravatar jasikpark 1-1/+0