style: format code annotations and fix lint fail.

Signed-off-by: adam <[email protected]>

Author: wujunwei

cmd/karpor/app/syncer.go

@@ -16,6 +16,7 @@ package app
 
 import (
 	"context"
+
 	"github.com/KusionStack/karpor/pkg/kubernetes/registry"
 	"github.com/KusionStack/karpor/pkg/kubernetes/registry/search"
 	"github.com/KusionStack/karpor/pkg/kubernetes/scheme"
@@ -82,8 +83,6 @@ func run(ctx context.Context, options *syncerOptions) error {
 		SearchUsername:    options.SearchUsername,
 		SearchPassword:    options.SearchPassword,
 	})
-	//nolint:contextcheck
-
 	if err != nil {
 		log.Error(err, "unable to init elasticsearch client")
 		return err

pkg/core/handler/resourcegroup/resource_group.go

@@ -15,9 +15,10 @@
 package resourcegroup
 
 import (
-	"github.com/KusionStack/karpor/pkg/infra/search/storage"
 	"net/http"
 
+	"github.com/KusionStack/karpor/pkg/infra/search/storage"
+
 	"github.com/KusionStack/karpor/pkg/core/handler"
 	"github.com/KusionStack/karpor/pkg/core/manager/resourcegroup"
 	"github.com/KusionStack/karpor/pkg/util/ctxutil"

pkg/core/handler/resourcegrouprule/resource_group_rule.go

@@ -15,9 +15,10 @@
 package resourcegrouprule
 
 import (
-	"github.com/KusionStack/karpor/pkg/infra/search/storage"
 	"net/http"
 
+	"github.com/KusionStack/karpor/pkg/infra/search/storage"
+
 	"github.com/KusionStack/karpor/pkg/core/handler"
 	"github.com/KusionStack/karpor/pkg/core/manager/resourcegroup"
 	"github.com/KusionStack/karpor/pkg/util/ctxutil"

pkg/infra/persistence/meilisearch/client.go

@@ -12,12 +12,12 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-//nolint:tagliatelle
 package meilisearch
 
 import (
 	"context"
 	"fmt"
+
 	"github.com/meilisearch/meilisearch-go"
 )
 
@@ -28,7 +28,6 @@ type Client struct {
 
 // NewClient creates a new Elasticsearch client instance
 func NewClient(address string, key string) (*Client, error) {
-
 	cl := meilisearch.New(address, meilisearch.WithAPIKey(key))
 	return &Client{client: cl}, nil
 }
@@ -126,15 +125,13 @@ func (cl *Client) Count(
 	ctx context.Context,
 	indexName string,
 ) (*CountResponse, error) {
-
 	resp, err := cl.client.Index(indexName).GetStatsWithContext(ctx)
 	if err != nil {
 		return nil, err
 	}
 	return &CountResponse{
 		Count: resp.NumberOfDocuments,
 	}, nil
-
 }
 
 // CreateIndex creates a new index with the specified settings and mappings,PrimaryKey is id by default

pkg/infra/persistence/meilisearch/types.go

@@ -22,8 +22,6 @@ import (
 const (
 	// maxAggSize defines the maximum number of aggregation buckets that can be returned in an aggregation query.
 	maxAggSize = 10000
-	// maxHitsSize defines the maximum number of search hits to be returned in a search query response.
-	maxHitsSize = 1000
 )
 
 type paginationConfig struct {

pkg/infra/search/storage/meilisearch/client.go

@@ -17,6 +17,7 @@ package meilisearch
 import (
 	"context"
 	"fmt"
+
 	"github.com/KusionStack/karpor/pkg/core/entity"
 	"github.com/KusionStack/karpor/pkg/infra/persistence/meilisearch"
 	"github.com/KusionStack/karpor/pkg/infra/search/storage"

pkg/infra/search/storage/meilisearch/convert.go

@@ -1,20 +1,27 @@
-/**
- * @Author:      Adam wu
- * @Description:
- * @File:        convert.go
- * @Version:     1.0.0
- * @Date:        2025/3/21
- */
+// Copyright The Karpor Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
 
 package meilisearch
 
 import (
 	"fmt"
+	"strings"
+	"time"
+
 	"github.com/KusionStack/karpor/pkg/infra/persistence/meilisearch"
 	"github.com/xwb1989/sqlparser"
 	"k8s.io/apimachinery/pkg/util/sets"
-	"strings"
-	"time"
 )
 
 var DefaultFilter = []string{"deleted = false"}
@@ -46,26 +53,26 @@ func ConvertWithDefaultFilter(sql string, defaultFilter []string) (*meilisearch.
 		return nil, "", fmt.Errorf("only single table queries are supported")
 	}
 
-	// 应用默认过滤器
+	// apply the default filter
 	sel = applyDefaultFilter(sel, defaultFilter)
 
-	// 获取表名
+	// obtain the table name
 	tableName := strings.ReplaceAll(sqlparser.String(sel.From), "`", "")
 
-	// 构建搜索请求
+	// build a search request
 	req := &meilisearch.SearchRequest{
-		Limit:  1000, //by default
+		Limit:  1000, // by default
 		Offset: 0,
 	}
 
-	// 处理WHERE条件
+	// handle the where condition
 	filter, err := buildFilter(sel.Where)
 	if err != nil {
 		return nil, "", err
 	}
 	req.Filter = filter
 
-	// 处理LIMIT/OFFSET
+	// deal with LIMIT/OFFSET
 	if sel.Limit != nil {
 		if offset, ok := sel.Limit.Offset.(*sqlparser.SQLVal); ok {
 			req.Offset = parseInt(string(offset.Val))
@@ -75,7 +82,7 @@ func ConvertWithDefaultFilter(sql string, defaultFilter []string) (*meilisearch.
 		}
 	}
 
-	// 处理ORDER BY
+	// deal with ORDER BY
 	if len(sel.OrderBy) > 0 {
 		sort := make([]string, 0, len(sel.OrderBy))
 		for _, order := range sel.OrderBy {
@@ -118,7 +125,7 @@ func buildFilterRecursive(expr sqlparser.Expr) (interface{}, error) {
 		return fmt.Sprintf("(%s) OR (%s)", left, right), nil
 
 	case *sqlparser.ComparisonExpr:
-		return buildComparisonFilter(e)
+		return buildComparisonFilter(e), nil
 
 	case *sqlparser.ParenExpr:
 		return buildFilterRecursive(e.Expr)
@@ -131,10 +138,10 @@ func buildFilterRecursive(expr sqlparser.Expr) (interface{}, error) {
 	}
 }
 
-func buildComparisonFilter(expr *sqlparser.ComparisonExpr) (string, error) {
+func buildComparisonFilter(expr *sqlparser.ComparisonExpr) string {
 	field := strings.Trim(sqlparser.String(expr.Left), "`")
 	op, value := extractOperatorAndValue(field, expr.Operator, expr.Right)
-	return fmt.Sprintf("%s %s %s", field, op, value), nil
+	return fmt.Sprintf("%s %s %s", field, op, value)
 }
 
 func buildRangeFilter(expr *sqlparser.RangeCond) (string, error) {
@@ -180,7 +187,6 @@ func extractLikeOperatorByValue(op, val string) string {
 
 // trimLikeValue trim string like '%abc%' to 'abc'
 func trimLikeValue(val string) string {
-
 	bs := []byte(val)
 	newBytes := make([]byte, 0, len(bs))
 	for i := 0; i < len(bs); i++ {
@@ -196,7 +202,7 @@ func extractOperatorAndValue(field, op string, expr sqlparser.Expr) (string, str
 	op = strings.ToLower(op)
 	val := extractValue(expr)
 	switch op {
-	//case sqlparser.EqualStr, sqlparser.GreaterEqualStr, sqlparser.GreaterThanStr, sqlparser.LessThanStr, sqlparser.LessEqualStr, sqlparser.NotEqualStr, sqlparser.InStr, sqlparser.NotInStr:
+	// case sqlparser.EqualStr, sqlparser.GreaterEqualStr, sqlparser.GreaterThanStr, sqlparser.LessThanStr, sqlparser.LessEqualStr, sqlparser.NotEqualStr, sqlparser.InStr, sqlparser.NotInStr:
 	//	return strings.ToUpper(op), val
 	case sqlparser.LikeStr, sqlparser.NotLikeStr:
 		return extractLikeOperatorByValue(op, val), trimLikeValue(val)
@@ -263,13 +269,12 @@ func getFilterFields(where *sqlparser.Where) sets.Set[string] {
 	}
 
 	_ = sqlparser.Walk(func(node sqlparser.SQLNode) (bool, error) {
-		switch n := node.(type) {
-		case *sqlparser.ColName:
+		if n, ok := node.(*sqlparser.ColName); ok {
 			fields.Insert(n.Name.String())
 		}
+
 		return true, nil
 	}, where)
-
 	return fields
 }
 

pkg/infra/search/storage/meilisearch/index.go

@@ -22,12 +22,10 @@ const (
 )
 
 var defaultResourceIndexSetting = &meilisearch.Settings{
-	// 对应 ES 的 max_result_window
 	Pagination: &meilisearch.Pagination{
-		MaxTotalHits: 1_000_000, // 控制最大返回结果数
+		MaxTotalHits: 1_000_000,
 	},
 
-	// 对应 ES analysis.normalizer
 	SortableAttributes: []string{
 		"creationTimestamp",
 		"deletionTimestamp",
@@ -42,15 +40,14 @@ var defaultResourceIndexSetting = &meilisearch.Settings{
 		},
 	},
 
-	// 对应 ES mappings.properties 字段配置
 	FilterableAttributes: []string{
 		"id",
 		"cluster",
 		"apiVersion",
-		"kind", // 启用过滤和精确匹配
+		"kind",
 		"namespace",
 		"name",
-		"labels", // 扁平化字段过滤
+		"labels",
 		"annotations",
 		"ownerReferences",
 		"content",
@@ -60,10 +57,9 @@ var defaultResourceIndexSetting = &meilisearch.Settings{
 	},
 
 	SearchableAttributes: []string{
-		"content", // 全文搜索字段
+		"content",
 	},
 
-	// 对应 _source.excludes 排除字段
 	DisplayedAttributes: []string{
 		"cluster",
 		"apiVersion",
@@ -77,16 +73,14 @@ var defaultResourceIndexSetting = &meilisearch.Settings{
 		"ownerReferences",
 		"resourceVersion",
 		"content",
-		// 排除 "custom" 字段
 	},
 }
+
 var defaultResourceGroupRuleIndexSetting = &meilisearch.Settings{
-	// 对应 Elasticsearch 的 max_result_window
 	Pagination: &meilisearch.Pagination{
-		MaxTotalHits: 1000000, // 控制最大返回结果数
-	}, // 控制最大返回结果数
+		MaxTotalHits: 1000000,
+	},
 
-	// 对应 mappings.properties 字段属性
 	FilterableAttributes: []string{
 		"id",
 		"name",
@@ -100,8 +94,6 @@ var defaultResourceGroupRuleIndexSetting = &meilisearch.Settings{
 		"deletedAt",
 	},
 
-	// 对应 mappings._source.excludes
-	// Meilisearch 无完全等效功能，但可通过以下方式近似实现
 	DisplayedAttributes: []string{
 		"id",
 		"name",
@@ -110,6 +102,5 @@ var defaultResourceGroupRuleIndexSetting = &meilisearch.Settings{
 		"createdAt",
 		"updatedAt",
 		"deletedAt",
-	}, // 显式指定返回字段
-
+	},
 }

pkg/infra/search/storage/meilisearch/parse.go

@@ -120,21 +120,21 @@ func ParseQueries(queries []storage.Query) ([]interface{}, error) {
 	return filter, nil
 }
 
-// ConvertToFilter 将 map 转换为 Meilisearch 等值过滤器
-// 输入示例:
+// ConvertToFilter convert the map to a meilisearch equivalent filter
+// Input:
 //
 //	{
 //	  "category": "electronics",
 //	  "tags": ["a", "b"],
 //	  "author": {"name": "Alice"}
 //	}
 //
-// 输出: ["category = 'electronics'", "tags IN ['a','b']", "author.name = 'Alice'"]
+// Output: ["category = 'electronics'", "tags IN ['a','b']", "author.name = 'Alice'"]
 func ConvertToFilter(query map[string]any) ([]any, error) {
 	return processMap(query, "")
 }
 
-// 递归处理嵌套 map
+// recursively handles nesting map
 func processMap(data map[string]any, parentKey string) ([]any, error) {
 	var filters []any
 
@@ -146,23 +146,20 @@ func processMap(data map[string]any, parentKey string) ([]any, error) {
 
 		switch v := value.(type) {
 		case map[string]any:
-			// 处理嵌套对象
 			nestedFilters, err := processMap(v, fullKey)
 			if err != nil {
 				return nil, err
 			}
 			filters = append(filters, nestedFilters)
 
 		case []any:
-			// 处理数组 (IN 查询)
 			inClause, err := buildInClause(fullKey, v)
 			if err != nil {
 				return nil, err
 			}
 			filters = append(filters, inClause)
 
 		default:
-			// 处理基本类型
 			eqClause, err := buildEqualClause(fullKey, v)
 			if err != nil {
 				return nil, err
@@ -174,7 +171,7 @@ func processMap(data map[string]any, parentKey string) ([]any, error) {
 	return filters, nil
 }
 
-// 构建等值条件
+// build an equivalence condition
 func buildEqualClause(key string, value any) (string, error) {
 	valueStr, err := convertValue(value)
 	if err != nil {
@@ -183,9 +180,9 @@ func buildEqualClause(key string, value any) (string, error) {
 	return fmt.Sprintf("%s = %s", key, valueStr), nil
 }
 
-// 构建 IN 条件
+// build an in condition
 func buildInClause(key string, values []any) (string, error) {
-	var elements []string
+	elements := make([]string, 0, len(values))
 	for _, v := range values {
 		element, err := convertValue(v)
 		if err != nil {
@@ -196,7 +193,7 @@ func buildInClause(key string, values []any) (string, error) {
 	return fmt.Sprintf("%s IN [%s]", key, strings.Join(elements, ",")), nil
 }
 
-// 值类型转换
+// value type conversion
 func convertValue(value any) (string, error) {
 	switch v := value.(type) {
 	case string: