mirror of
https://github.com/ClusterCockpit/cc-metric-collector.git
synced 2026-02-13 06:31:46 +01:00
cca0d23efa
* Add golangci-lin as make target * Fix: could omit type ... from declaration; it will be inferred from the right-hand side (staticcheck) * Fix func intArrayContains is unused (unused) * Fix: could use strings.ReplaceAll instead (staticcheck) * Fix: could expand call to math.Pow (staticcheck) * Fix: could use tagged switch on `...` (staticcheck) * Fix: Error return value of `...` is not checked (errcheck) * Fix: ineffectual assignment to err (ineffassign) * Fix: There is no need to wait for command completion * Add cpustat, diskstat and schedstat config * Use slices to exclude metrics * Replaced stringArrayContains by slices.Contains * Replace m[k]=v loop with maps.Copy * Use module slices from the standard library. Remove use of golang.org/x/exp/slices * Use SplitSeq and max to modernize code
64 lines
1.9 KiB
Go
64 lines
1.9 KiB
Go
// Copyright (C) NHR@FAU, University Erlangen-Nuremberg.
|
|
// All rights reserved. This file is part of cc-lib.
|
|
// Use of this source code is governed by a MIT-style
|
|
// license that can be found in the LICENSE file.
|
|
// additional authors:
|
|
// Holger Obermaier (NHR@KIT)
|
|
|
|
package collectors
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"time"
|
|
|
|
lp "github.com/ClusterCockpit/cc-lib/v2/ccMessage"
|
|
)
|
|
|
|
type MetricCollector interface {
|
|
Name() string // Name of the metric collector
|
|
Init(config json.RawMessage) error // Initialize metric collector
|
|
Initialized() bool // Is metric collector initialized?
|
|
Parallel() bool
|
|
Read(duration time.Duration, output chan lp.CCMessage) // Read metrics from metric collector
|
|
Close() // Close / finish metric collector
|
|
}
|
|
|
|
type metricCollector struct {
|
|
name string // name of the metric
|
|
init bool // is metric collector initialized?
|
|
parallel bool // can the metric collector be executed in parallel with others
|
|
meta map[string]string // static meta data tags
|
|
}
|
|
|
|
// Name returns the name of the metric collector
|
|
func (c *metricCollector) Name() string {
|
|
return c.name
|
|
}
|
|
|
|
// Name returns the name of the metric collector
|
|
func (c *metricCollector) Parallel() bool {
|
|
return c.parallel
|
|
}
|
|
|
|
// Setup is for future use
|
|
func (c *metricCollector) setup() error {
|
|
return nil
|
|
}
|
|
|
|
// Initialized indicates whether the metric collector has been initialized
|
|
func (c *metricCollector) Initialized() bool {
|
|
return c.init
|
|
}
|
|
|
|
// RemoveFromStringList removes the string r from the array of strings s
|
|
// If r is not contained in the array an error is returned
|
|
func RemoveFromStringList(s []string, r string) ([]string, error) {
|
|
for i := range s {
|
|
if r == s[i] {
|
|
return append(s[:i], s[i+1:]...), nil
|
|
}
|
|
}
|
|
return s, fmt.Errorf("no such string in list")
|
|
}
|