Method QueryPatterns

internal/engine/engine.go:600–656

QueryPatterns returns drain3 patterns grouped by the specified dimension.

(_ context.Context, filters InsightsFilters)

// QueryPatterns returns drain3 patterns grouped by the specified dimension.
func (e *Engine) QueryPatterns(_ context.Context, filters InsightsFilters) ([]PatternGroup, error) {
	e.mu.RLock()
	defer e.mu.RUnlock()

	groupBy := filters.GroupBy
	if groupBy == "" {
		groupBy = "service"
	}

	limit := 20
	if filters.Limit != nil && *filters.Limit > 0 {
		limit = *filters.Limit
	}

	// For severity grouping, use the pre-built drain3 instances
	if groupBy == "severity" {
		result := make([]PatternGroup, 0)
		for severity, dm := range e.drain3BySeverity {
			if dm == nil {
				continue
			}
			patterns := dm.GetTopPatterns(limit)
			if len(patterns) == 0 {
				continue
			}
			items := make([]PatternItem, len(patterns))
			for i, p := range patterns {
				items[i] = PatternItem{
					Pattern:    p.Template,
					Count:      p.Count,
					Percentage: p.Percentage,
				}
			}
			result = append(result, PatternGroup{
				GroupValue: severity,
				Patterns:   items,
			})
		}
		return result, nil
	}

	// For other groupings, use the combined drain3 and return as single group
	patterns := e.drain3All.GetTopPatterns(limit)
	items := make([]PatternItem, len(patterns))
	for i, p := range patterns {
		items[i] = PatternItem{
			Pattern:    p.Template,
			Count:      p.Count,
			Percentage: p.Percentage,
		}
	}

	return []PatternGroup{{
		GroupValue: "all",
		Patterns:   items,
	}}, nil
}