-
Notifications
You must be signed in to change notification settings - Fork 486
/
process-exporter_linux.go
85 lines (73 loc) · 2.42 KB
/
process-exporter_linux.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
// Package process_exporter embeds https://github.com/ncabatoff/process-exporter
package process_exporter //nolint:golint
import (
"context"
"fmt"
"net/http"
"github.com/go-kit/log"
"github.com/grafana/agent/pkg/build"
"github.com/grafana/agent/pkg/integrations/config"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
"github.com/ncabatoff/process-exporter/collector"
)
// Integration is the process_exporter integration. The integration scrapes
// metrics based on information in the /proc filesystem for Linux.
// Agent's own metrics.
type Integration struct {
c *Config
collector *collector.NamedProcessCollector
}
// New creates a new instance of the process_exporter integration.
func New(logger log.Logger, c *Config) (*Integration, error) {
cfg, err := c.ProcessExporter.ToConfig()
if err != nil {
return nil, fmt.Errorf("process_names is invalid: %w", err)
}
pc, err := collector.NewProcessCollector(collector.ProcessCollectorOption{
ProcFSPath: c.ProcFSPath,
Children: c.Children,
Threads: c.Threads,
GatherSMaps: c.SMaps,
Namer: cfg.MatchNamers,
Recheck: c.Recheck,
Debug: false,
})
if err != nil {
return nil, err
}
return &Integration{c: c, collector: pc}, nil
}
// MetricsHandler satisfies Integration.RegisterRoutes.
func (i *Integration) MetricsHandler() (http.Handler, error) {
r := prometheus.NewRegistry()
if err := r.Register(i.collector); err != nil {
return nil, fmt.Errorf("couldn't register process_exporter collector: %w", err)
}
// Register process_exporter_build_info metrics, generally useful for
// dashboards that depend on them for discovering targets.
if err := r.Register(build.NewCollector("process_exporter")); err != nil {
return nil, fmt.Errorf("couldn't register process_exporter: %w", err)
}
return promhttp.HandlerFor(
prometheus.Gatherers{r},
promhttp.HandlerOpts{
ErrorHandling: promhttp.ContinueOnError,
MaxRequestsInFlight: 0,
},
), nil
}
// ScrapeConfigs satisfies Integration.ScrapeConfigs.
func (i *Integration) ScrapeConfigs() []config.ScrapeConfig {
return []config.ScrapeConfig{{
JobName: i.c.Name(),
MetricsPath: "/metrics",
}}
}
// Run satisfies Integration.Run.
func (i *Integration) Run(ctx context.Context) error {
// We don't need to do anything here, so we can just wait for the context to
// finish.
<-ctx.Done()
return ctx.Err()
}