ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-04-17 02:15:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

Renamed TagMap() -> Tags(), MetaMap() -> Meta

Browse Source
This commit is contained in:
Holger Obermaier 2022-02-01 14:49:09 +01:00
parent 0e70b663ee
commit 00fdb189a4
4 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/ccMetric/ccMetric.go
View File

@ -27,12 +27,12 @@ type CCMetric interface {
SetTime(t time.Time)
MetaMap() map[string]string // Map of meta data tags
Meta() map[string]string // Map of meta data tags
MetaList() []*lp.Tag // Ordered list of meta data
AddMeta(key, value string) // Add a meta data tag
GetMeta(key string) (string, bool) // Get a meta data tab addressed by its key
TagMap() map[string]string // Map of tags
Tags() map[string]string // Map of tags
AddTag(key, value string) // Add a tag
GetTag(key string) (string, bool) // Get a tag by its key
RemoveTag(key string) // Remove a tag by its key
@ -42,8 +42,8 @@ type CCMetric interface {
RemoveField(key string) // Remove a field addressed by its key
}
// MetaMap returns the meta data tags as key-value mapping
func (m *ccMetric) MetaMap() map[string]string {
// Meta returns the meta data tags as key-value mapping
func (m *ccMetric) Meta() map[string]string {
return m.meta
}
@ -68,8 +68,8 @@ func (m *ccMetric) Name() string {
return m.name
}
// TagMap returns the the list of tags as key-value-mapping
func (m *ccMetric) TagMap() map[string]string {
// Tags returns the the list of tags as key-value-mapping
func (m *ccMetric) Tags() map[string]string {
return m.tags
}
@ -248,10 +248,10 @@ func FromMetric(other ccMetric) CCMetric {
tm: other.Time(),
}
for key, value := range other.TagMap() {
for key, value := range other.Tags() {
m.tags[key] = value
}
for key, value := range other.MetaMap() {
for key, value := range other.Meta() {
m.meta[key] = value
}

4
internal/metricRouter/metricRouter.go
View File

@ -141,10 +141,10 @@ func (r *metricRouter) EvalCondition(cond string, point lp.CCMetric) (bool, erro
// Add metric name, tags, meta data, fields and timestamp to the parameter list
params := make(map[string]interface{})
params["name"] = point.Name()
for key, value := range point.TagMap() {
for key, value := range point.Tags() {
params[key] = value
}
for key, value := range point.MetaMap() {
for key, value := range point.Meta() {
params[key] = value
}
for _, f := range point.FieldList() {

2
sinks/gangliaSink.go
View File

@ -30,7 +30,7 @@ func (s *GangliaSink) Write(point lp.CCMetric) error {
var err error = nil
var tagsstr []string
var argstr []string
for key, value := range point.TagMap() {
for key, value := range point.Tags() {
switch key {
case "cluster":
argstr = append(argstr, fmt.Sprintf("--cluster=%s", value))

4
sinks/influxSink.go
View File

@ -62,11 +62,11 @@ func (s *InfluxSink) Init(config sinkConfig) error {
func (s *InfluxSink) Write(point lp.CCMetric) error {
tags := map[string]string{}
fields := map[string]interface{}{}
for key, value := range point.TagMap() {
for key, value := range point.Tags() {
tags[key] = value
}
if s.meta_as_tags {
for key, value := range point.MetaMap() {
for key, value := range point.Meta() {
tags[key] = value
}
}