Method selectAttrValues

pkg/metrics/attr_handler.go:234–298

(
	ctx context.Context, attrKey string, f *AttrFilter,
)

}

func (h *AttrHandler) selectAttrValues(
	ctx context.Context, attrKey string, f *AttrFilter,
) (any, bool, error) {
	const limit = 1000

	if len(f.Metric) == 1 {
		switch f.Metric[0] {
		case uptraceTracingSpans, uptraceTracingEvents, uptraceTracingLogs:
			typeFilter, err := newTypeFilter(ctx, f.ProjectID, &f.TimeFilter, f.Metric[0])
			if err != nil {
				return nil, false, err
			}

			spanFilter := newSpanFilter(typeFilter, "")
			return tracing.SelectAttrValues(ctx, h.CH, spanFilter, attrKey)
		}
	}

	tableName := DatapointTableForWhere(&f.TimeFilter)
	items := make([]AttrValueItem, 0)

	if err := h.CH.NewSelect().
		ColumnExpr("? AS value", chAttrExpr(attrKey)).
		ColumnExpr("count(DISTINCT metric) AS count").
		TableExpr("? AS d", ch.Name(tableName)).
		Where("d.project_id = ?", f.ProjectID).
		Where("d.time >= ?", f.TimeGTE).
		Where("d.time < ?", f.TimeLT).
		Apply(func(q *ch.SelectQuery) *ch.SelectQuery {
			if len(f.Metric) > 0 {
				q = q.Where("d.metric IN ?", ch.In(f.Metric))
			}
			if !isMandatoryAttr(attrKey) {
				q = q.Where("has(d.string_keys, ?)", attrKey)
			}

			for _, attrKey := range f.AttrKey {
				if isMandatoryAttr(attrKey) {
					continue
				}
				q = q.Where("has(d.string_keys, ?)", attrKey)
			}
			if len(f.Instrument) > 0 {
				q = q.Where("d.instrument IN ?", ch.In(f.Instrument))
			}
			if len(f.OtelLibraryName) > 0 {
				q = q.Where("d.otel_library_name IN ?", ch.In(f.OtelLibraryName))
			}

			if f.SearchInput != "" {
				q = q.Where("? like ?", chAttrExpr(attrKey), "%"+f.SearchInput+"%")
			}

			return q
		}).
		GroupExpr("value").
		OrderExpr("value ASC").
		Limit(limit).