sendnrw/windows_exporter
2
0
Fork 0
mirror of https://github.com/prometheus-community/windows_exporter.git synced 2026-02-23 13:16:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: allow setting of exporter process priority (#1488)

Browse Source
This commit is contained in:
Ben Reedy
2024-05-18 06:51:33 +10:00
committed by GitHub
parent b2ab542b6d
commit eeaefba0d7
1 changed files with 44 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
exporter.go
View File

@@ -31,8 +31,12 @@ import (
"github.com/prometheus/common/version" "github.com/prometheus/common/version"
"github.com/prometheus/exporter-toolkit/web" "github.com/prometheus/exporter-toolkit/web"
webflag "github.com/prometheus/exporter-toolkit/web/kingpinflag" webflag "github.com/prometheus/exporter-toolkit/web/kingpinflag"
"golang.org/x/sys/windows"
) )
// https://learn.microsoft.com/en-us/windows/win32/procthread/process-security-and-access-rights
const PROCESS_ALL_ACCESS = windows.STANDARD_RIGHTS_REQUIRED | windows.SYNCHRONIZE | windows.SPECIFIC_RIGHTS_ALL
// Same struct prometheus uses for their /version endpoint. // Same struct prometheus uses for their /version endpoint.
// Separate copy to avoid pulling all of prometheus as a dependency // Separate copy to avoid pulling all of prometheus as a dependency
type prometheusVersion struct { type prometheusVersion struct {
@@ -44,6 +48,32 @@ type prometheusVersion struct {
GoVersion string `json:"goVersion"` GoVersion string `json:"goVersion"`
} }
// Mapping of priority names to uin32 values required by windows.SetPriorityClass
var priorityStringToInt = map[string]uint32{
"realtime": windows.REALTIME_PRIORITY_CLASS,
"high": windows.HIGH_PRIORITY_CLASS,
"abovenormal": windows.ABOVE_NORMAL_PRIORITY_CLASS,
"normal": windows.NORMAL_PRIORITY_CLASS,
"belownormal": windows.BELOW_NORMAL_PRIORITY_CLASS,
"low": windows.IDLE_PRIORITY_CLASS,
}
func setPriorityWindows(pid int, priority uint32) error {
handle, err := windows.OpenProcess(PROCESS_ALL_ACCESS, false, uint32(pid))
if err != nil {
return err
}
//nolint:errcheck
defer windows.CloseHandle(handle) // Technically this can fail, but we ignore it
err = windows.SetPriorityClass(handle, priority)
if err != nil {
return err
}
return nil
}
func main() { func main() {
app := kingpin.New("windows_exporter", "A metrics collector for Windows.") app := kingpin.New("windows_exporter", "A metrics collector for Windows.")
var ( var (
@@ -84,6 +114,10 @@ func main() {
"debug.enabled", "debug.enabled",
"If true, windows_exporter will expose debug endpoints under /debug/pprof.", "If true, windows_exporter will expose debug endpoints under /debug/pprof.",
).Default("false").Bool() ).Default("false").Bool()
processPriority = app.Flag(
"process.priority",
"Priority of the exporter process. Higher priorities may improve exporter responsiveness during periods of system load. Can be one of [\"realtime\", \"high\", \"abovenormal\", \"normal\", \"belownormal\", \"low\"]",
).Default("normal").String()
) )
winlogConfig := &winlog.Config{} winlogConfig := &winlog.Config{}
@@ -145,6 +179,16 @@ func main() {
return return
} }
// Only set process priority if a non-default and valid value has been set
if *processPriority != "normal" && priorityStringToInt[*processPriority] != 0 {
_ = level.Debug(logger).Log("msg", "setting process priority to "+*processPriority)
err = setPriorityWindows(os.Getpid(), priorityStringToInt[*processPriority])
if err != nil {
_ = level.Error(logger).Log("msg", "failed to set process priority", "err", err)
os.Exit(1)
}
}
if err = wmi.InitWbem(logger); err != nil { if err = wmi.InitWbem(logger); err != nil {
_ = level.Error(logger).Log("err", err) _ = level.Error(logger).Log("err", err)
os.Exit(1) os.Exit(1)