Function selectMetricsFromCH

pkg/metrics/metric_handler.go:141–213

(
	ctx context.Context, pg *bun.DB, chdb *ch.DB, f *MetricFilter,
)

}

func selectMetricsFromCH(
	ctx context.Context, pg *bun.DB, chdb *ch.DB, f *MetricFilter,
) ([]*Metric, bool, error) {
	const limit = 1000

	tableName := DatapointTableForWhere(&f.TimeFilter)
	q := chdb.NewSelect().
		ColumnExpr("m.metric AS name").
		ColumnExpr("anyLast(m.instrument) AS instrument").
		ColumnExpr("uniqCombined64(m.attrs_hash) AS num_timeseries").
		TableExpr("? AS m", ch.Name(tableName)).
		Where("m.project_id = ?", f.ProjectID).
		Where("m.time >= ?", f.TimeGTE).
		Where("m.time < ?", f.TimeLT).
		GroupExpr("m.metric").
		OrderExpr("name ASC").
		Limit(limit)

	if len(f.AttrKey) > 0 {
		q = q.Where("hasAll(m.string_keys, ?)", chschema.Array(f.AttrKey))
	}
	if len(f.Instrument) > 0 {
		q = q.Where("m.instrument IN ?", ch.In(f.Instrument))
	}
	if len(f.OtelLibraryName) > 0 {
		q = q.Where("m.otel_library_name IN ?", ch.In(f.OtelLibraryName))
	}
	if f.SearchInput != "" {
		values := strings.Split(f.SearchInput, "|")
		q = q.Where("multiSearchAnyCaseInsensitiveUTF8(metric, ?) != 0", ch.Array(values))
	}

	if f.Query != "" {
		query := mql.ParseQuery(f.Query)
		for _, part := range query.Parts {
			if part.Error.Wrapped != nil {
				continue
			}

			switch v := part.AST.(type) {
			case *ast.Where:
				if err := compileFilters(q, InstrumentDeleted, v.Filters); err != nil {
					return nil, false, err
				}
			default:
				return nil, false, fmt.Errorf("unsupported AST type: %T", v)
			}
		}
	}

	metrics := make([]*Metric, 0)
	if err := q.Scan(ctx, &metrics); err != nil {
		return nil, false, err
	}

	if len(metrics) == 0 {
		return metrics, false, nil
	}