ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2024-12-25 07:09:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Check for Ganglia group explicitly in tags and meta info

Browse Source
This commit is contained in:
Thomas Roehl 2022-02-11 16:10:59 +01:00
parent b15fdf72b9
commit dc1e4f28a0
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
sinks/gangliaSink.go
View File

@ -21,6 +21,7 @@ type GangliaSinkConfig struct {
GmetricPath string `json:"gmetric_path,omitempty"` GmetricPath string `json:"gmetric_path,omitempty"`
GmetricConfig string `json:"gmetric_config,omitempty"` GmetricConfig string `json:"gmetric_config,omitempty"`
AddGangliaGroup bool `json:"add_ganglia_group,omitempty"` AddGangliaGroup bool `json:"add_ganglia_group,omitempty"`
AddTagsAsDesc bool `json:"add_tags_as_desc,omitempty"`
} }
type GangliaSink struct { type GangliaSink struct {
@ -33,6 +34,8 @@ type GangliaSink struct {
func (s *GangliaSink) Init(config json.RawMessage) error { func (s *GangliaSink) Init(config json.RawMessage) error {
var err error = nil var err error = nil
s.name = "GangliaSink" s.name = "GangliaSink"
s.config.AddTagsAsDesc = false
s.config.AddGangliaGroup = false
if len(config) > 0 { if len(config) > 0 {
err := json.Unmarshal(config, &s.config) err := json.Unmarshal(config, &s.config)
if err != nil { if err != nil {
@ -67,16 +70,22 @@ func (s *GangliaSink) Write(point lp.CCMetric) error {
var err error = nil var err error = nil
var tagsstr []string var tagsstr []string
var argstr []string var argstr []string
if s.config.AddGangliaGroup {
if point.HasTag("group") {
g, _ := point.GetTag("group")
argstr = append(argstr, fmt.Sprintf("--group=%s", g))
} else if point.HasMeta("group") {
g, _ := point.GetMeta("group")
argstr = append(argstr, fmt.Sprintf("--group=%s", g))
}
}
for key, value := range point.Tags() { for key, value := range point.Tags() {
switch key { switch key {
case "cluster": case "cluster":
argstr = append(argstr, fmt.Sprintf("--cluster=%s", value)) argstr = append(argstr, fmt.Sprintf("--cluster=%s", value))
case "unit": case "unit":
argstr = append(argstr, fmt.Sprintf("--units=%s", value)) argstr = append(argstr, fmt.Sprintf("--units=%s", value))
case "group":
if s.config.AddGangliaGroup {
argstr = append(argstr, fmt.Sprintf("--group=%s", value))
}
default: default:
tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", key, value)) tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", key, value))
} }
@ -88,16 +97,12 @@ func (s *GangliaSink) Write(point lp.CCMetric) error {
argstr = append(argstr, fmt.Sprintf("--cluster=%s", value)) argstr = append(argstr, fmt.Sprintf("--cluster=%s", value))
case "unit": case "unit":
argstr = append(argstr, fmt.Sprintf("--units=%s", value)) argstr = append(argstr, fmt.Sprintf("--units=%s", value))
case "group":
if s.config.AddGangliaGroup {
argstr = append(argstr, fmt.Sprintf("--group=%s", value))
}
default: default:
tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", key, value)) tagsstr = append(tagsstr, fmt.Sprintf("%s=%s", key, value))
} }
} }
} }
if len(tagsstr) > 0 { if s.config.AddTagsAsDesc && len(tagsstr) > 0 {
argstr = append(argstr, fmt.Sprintf("--desc=%q", strings.Join(tagsstr, ","))) argstr = append(argstr, fmt.Sprintf("--desc=%q", strings.Join(tagsstr, ",")))
} }
if len(s.gmetric_config) > 0 { if len(s.gmetric_config) > 0 {