add 重试规则 🐜

retry/retry.go

@@ -41,3 +41,18 @@ func RetryDurations(name string, max time.Duration, sleep time.Duration, callbac
 	}
 }
 
+// RetryTimes 重试规则
+func RetryTimesRules(name string, rules []int, callback func() error) (err error) {
+	for i := 1; i <= len(rules); i++ {
+		err = callback()
+		if err == nil {
+			return nil
+		}
+		fmt.Printf("[%v]失败，第%v次重试， 错误信息:%s \n", name, i, err)
+		time.Sleep(time.Duration(rules[i] * time.Now().Second()))
+	}
+	err = fmt.Errorf("[%v]失败，共重试%d次, 最近一次错误:%s \n", name, len(rules), err)
+	fmt.Println(err)
+	return err
+
+}