validate the label name
This commit is contained in:
parent
56e8e7cac3
commit
8f77d271b1
@ -61,17 +61,17 @@ func relabel(labels model.LabelSet, cfg *config.RelabelConfig) model.LabelSet {
|
|||||||
if indexes == nil {
|
if indexes == nil {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
target := model.LabelName(cfg.Regex.ExpandString([]byte{}, string(cfg.TargetLabel), val, indexes))
|
||||||
|
if !target.IsValid() {
|
||||||
|
delete(labels, cfg.TargetLabel)
|
||||||
|
break
|
||||||
|
}
|
||||||
res := cfg.Regex.ExpandString([]byte{}, cfg.Replacement, val, indexes)
|
res := cfg.Regex.ExpandString([]byte{}, cfg.Replacement, val, indexes)
|
||||||
if len(res) == 0 {
|
if len(res) == 0 {
|
||||||
delete(labels, cfg.TargetLabel)
|
delete(labels, cfg.TargetLabel)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
target := cfg.Regex.ExpandString([]byte{}, string(cfg.TargetLabel), val, indexes)
|
labels[target] = model.LabelValue(res)
|
||||||
if len(target) == 0 {
|
|
||||||
delete(labels, cfg.TargetLabel)
|
|
||||||
break
|
|
||||||
}
|
|
||||||
labels[model.LabelName(target)] = model.LabelValue(res)
|
|
||||||
case config.RelabelHashMod:
|
case config.RelabelHashMod:
|
||||||
mod := sum64(md5.Sum([]byte(val))) % cfg.Modulus
|
mod := sum64(md5.Sum([]byte(val))) % cfg.Modulus
|
||||||
labels[cfg.TargetLabel] = model.LabelValue(fmt.Sprintf("%d", mod))
|
labels[cfg.TargetLabel] = model.LabelValue(fmt.Sprintf("%d", mod))
|
||||||
|
Loading…
x
Reference in New Issue
Block a user