func()

in pkg/admin/services/traffic/timeout.go [49:88]


func (tm *TimeoutService) Search(t *model.Timeout) ([]*model.Timeout, error) {
	result := make([]*model.Timeout, 0)

	var con string
	if t.Service != "" && t.Service != "*" {
		con = util.ColonSeparatedKey(t.Service, t.Group, t.Version)
	}

	list, err := services.GetRules(con, constant.ConfiguratorRuleSuffix)
	if err != nil {
		return result, err
	}

	for k, v := range list {
		k, _ = strings.CutSuffix(k, constant.ConfiguratorRuleSuffix)
		split := strings.Split(k, ":")

		t := &model.Timeout{
			Service: split[0],
		}
		if len(split) >= 2 {
			t.Version = split[1]
		}
		if len(split) >= 3 {
			t.Group = split[2]
		}

		tv, err2 := getValue(v, "consumer", "timeout")
		if err2 != nil {
			return result, err2
		}

		if tv != nil {
			t.Timeout = tv.(int)
			result = append(result, t)
		}
	}

	return result, nil
}