package promrelabel import ( "fmt" "regexp" "github.com/VictoriaMetrics/VictoriaMetrics/lib/logger" "github.com/VictoriaMetrics/VictoriaMetrics/lib/prompbmarshal" "github.com/VictoriaMetrics/metricsql" ) // IfExpression represents `if` expression at RelabelConfig. // // The `if` expression can contain arbitrary PromQL-like label filters such as `metric_name{filters...}` type IfExpression struct { s string lfs []*labelFilter } // UnmarshalYAML unmarshals ie from YAML passed to f. func (ie *IfExpression) UnmarshalYAML(f func(interface{}) error) error { var s string if err := f(&s); err != nil { return fmt.Errorf("cannot unmarshal `if` option: %w", err) } expr, err := metricsql.Parse(s) if err != nil { return fmt.Errorf("cannot parse `if` series selector: %w", err) } me, ok := expr.(*metricsql.MetricExpr) if !ok { return fmt.Errorf("expecting `if` series selector; got %q", expr.AppendString(nil)) } lfs, err := metricExprToLabelFilters(me) if err != nil { return fmt.Errorf("cannot parse `if` filters: %w", err) } ie.s = s ie.lfs = lfs return nil } // MarshalYAML marshals ie to YAML. func (ie *IfExpression) MarshalYAML() (interface{}, error) { return ie.s, nil } // Match returns true if ie matches the given labels. func (ie *IfExpression) Match(labels []prompbmarshal.Label) bool { for _, lf := range ie.lfs { if !lf.match(labels) { return false } } return true } func metricExprToLabelFilters(me *metricsql.MetricExpr) ([]*labelFilter, error) { lfs := make([]*labelFilter, len(me.LabelFilters)) for i := range me.LabelFilters { lf, err := newLabelFilter(&me.LabelFilters[i]) if err != nil { return nil, fmt.Errorf("cannot parse %s: %w", me.AppendString(nil), err) } lfs[i] = lf } return lfs, nil } // labelFilter contains PromQL filter for `{label op "value"}` type labelFilter struct { label string op string value string // re contains compiled regexp for `=~` and `!~` op. re *regexp.Regexp } func newLabelFilter(mlf *metricsql.LabelFilter) (*labelFilter, error) { lf := &labelFilter{ label: toCanonicalLabelName(mlf.Label), op: getFilterOp(mlf), value: mlf.Value, } if lf.op == "=~" || lf.op == "!~" { // PromQL regexps are anchored by default. // See https://prometheus.io/docs/prometheus/latest/querying/basics/#time-series-selectors reString := "^(?:" + lf.value + ")$" re, err := regexp.Compile(reString) if err != nil { return nil, fmt.Errorf("cannot parse regexp for %s: %w", mlf.AppendString(nil), err) } lf.re = re } return lf, nil } func (lf *labelFilter) match(labels []prompbmarshal.Label) bool { switch lf.op { case "=": return lf.equalValue(labels) case "!=": return !lf.equalValue(labels) case "=~": return lf.equalRegexp(labels) case "!~": return !lf.equalRegexp(labels) default: logger.Panicf("BUG: unexpected operation for label filter: %s", lf.op) } return false } func (lf *labelFilter) equalValue(labels []prompbmarshal.Label) bool { labelNameMatches := 0 for _, label := range labels { if toCanonicalLabelName(label.Name) != lf.label { continue } labelNameMatches++ if label.Value == lf.value { return true } } if labelNameMatches == 0 { // Special case for {non_existing_label=""}, which matches anything except of non-empty non_existing_label return lf.value == "" } return false } func (lf *labelFilter) equalRegexp(labels []prompbmarshal.Label) bool { labelNameMatches := 0 for _, label := range labels { if toCanonicalLabelName(label.Name) != lf.label { continue } labelNameMatches++ if lf.re.MatchString(label.Value) { return true } } if labelNameMatches == 0 { // Special case for {non_existing_label=~"something|"}, which matches empty non_existing_label return lf.re.MatchString("") } return false } func toCanonicalLabelName(labelName string) string { if labelName == "__name__" { return "" } return labelName } func getFilterOp(mlf *metricsql.LabelFilter) string { if mlf.IsNegative { if mlf.IsRegexp { return "!~" } return "!=" } if mlf.IsRegexp { return "=~" } return "=" }