summaryrefslogtreecommitdiffstats
path: root/src/go/collectors/go.d.plugin/modules/logind/logind.go
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/go/collectors/go.d.plugin/modules/logind/logind.go97
1 files changed, 97 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/logind/logind.go b/src/go/collectors/go.d.plugin/modules/logind/logind.go
new file mode 100644
index 000000000..56e61ffec
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/modules/logind/logind.go
@@ -0,0 +1,97 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+//go:build linux
+// +build linux
+
+package logind
+
+import (
+ _ "embed"
+ "errors"
+ "time"
+
+ "github.com/netdata/netdata/go/go.d.plugin/agent/module"
+ "github.com/netdata/netdata/go/go.d.plugin/pkg/web"
+)
+
+//go:embed "config_schema.json"
+var configSchema string
+
+func init() {
+ module.Register("logind", module.Creator{
+ JobConfigSchema: configSchema,
+ Defaults: module.Defaults{
+ Priority: 59999, // copied from the python collector
+ },
+ Create: func() module.Module { return New() },
+ })
+}
+
+func New() *Logind {
+ return &Logind{
+ Config: Config{
+ Timeout: web.Duration(time.Second),
+ },
+ newLogindConn: func(cfg Config) (logindConnection, error) {
+ return newLogindConnection(cfg.Timeout.Duration())
+ },
+ charts: charts.Copy(),
+ }
+}
+
+type Config struct {
+ UpdateEvery int `yaml:"update_every" json:"update_every"`
+ Timeout web.Duration `yaml:"timeout" json:"timeout"`
+}
+
+type Logind struct {
+ module.Base
+ Config `yaml:",inline" json:""`
+
+ charts *module.Charts
+
+ conn logindConnection
+ newLogindConn func(config Config) (logindConnection, error)
+}
+
+func (l *Logind) Configuration() any {
+ return l.Config
+}
+
+func (l *Logind) Init() error {
+ return nil
+}
+
+func (l *Logind) Check() error {
+ mx, err := l.collect()
+ if err != nil {
+ l.Error(err)
+ return err
+ }
+ if len(mx) == 0 {
+ return errors.New("no metrics collected")
+ }
+ return nil
+}
+
+func (l *Logind) Charts() *module.Charts {
+ return l.charts
+}
+
+func (l *Logind) Collect() map[string]int64 {
+ mx, err := l.collect()
+ if err != nil {
+ l.Error(err)
+ }
+
+ if len(mx) == 0 {
+ return nil
+ }
+ return mx
+}
+
+func (l *Logind) Cleanup() {
+ if l.conn != nil {
+ l.conn.Close()
+ }
+}