Method Search

module/strategy/iml.go:164–211

(ctx context.Context, keyword string, driver string, scope strategy_dto.Scope, target string, page int, pageSize int, filters []string, order ...string)

}

func (i *imlStrategyModule) Search(ctx context.Context, keyword string, driver string, scope strategy_dto.Scope, target string, page int, pageSize int, filters []string, order ...string) ([]*strategy_dto.StrategyItem, int64, error) {
	list, total, err := i.strategyService.SearchByDriver(ctx, keyword, driver, scope.Int(), target, page, pageSize, filters, order...)
	if err != nil {
		return nil, 0, err
	}
	if len(list) < 1 {
		return nil, 0, nil
	}
	strategyIds := utils.SliceToSlice(list, func(l *strategy.Strategy) string { return l.Id })
	commits, err := i.strategyService.ListLatestStrategyCommit(ctx, scope.String(), target, strategyIds...)
	if err != nil {
		return nil, 0, err
	}
	commitMap := utils.SliceToMapO(commits, func(c *commit.Commit[strategy.Commit]) (string, string) { return c.Data.Id, c.Data.Version })
	items := make([]*strategy_dto.StrategyItem, 0, len(list))
	countMap := make(map[string]int64)
	c, err := i.clusterService.Get(ctx, cluster.DefaultClusterID)
	if err == nil {
		countMap, err = i.logService.LogCount(ctx, "loki", c.Cluster, map[string]string{
			"#1": fmt.Sprintf("strategy =~ \"%s\"", strings.Join(strategyIds, "|")),
		}, 720,
			"strategy")
		if err != nil {
			log.Errorf("get log count error: %v", err)
		}
	}

	for _, l := range list {
		fs := make([]*strategy_dto.Filter, 0)

		json.Unmarshal([]byte(l.Filters), &fs)
		filterList := make([]string, 0, len(fs))
		for _, f := range fs {
			info, err := strategy_filter.FilterLabel(f.Name, f.Values)
			if err != nil {
				log.Errorf("get filter label error: %v", err)
				continue
			}
			filterList = append(filterList, fmt.Sprintf("[%s:%s]", info.Title, info.Label))
		}
		item := strategy_dto.ToStrategyItem(l, commitMap[l.Id], strings.Join(filterList, ";"), countMap[l.Id])
		items = append(items, item)
	}
	sort.Slice(items, func(i, j int) bool {
		return items[i].Priority < items[j].Priority
	})
	return items, total, nil
}

func (i *imlStrategyModule) Get(ctx context.Context, id string) (*strategy_dto.Strategy, error) {
	info, err := i.strategyService.Get(ctx, id)