feat: 忽略阿里云限流以及服务器内部错误

error.go

@@ -0,0 +1,21 @@
+package aliacm
+
+// Error ACM错误
+type Error string
+
+func (e Error) Error() string {
+	return string(e)
+}
+
+const (
+	serviceUnavailableErr = Error("ServiceUnavailable")
+	internalServerErr     = Error("InternalServerError")
+)
+
+// ShouldIgnore 忽略一些不想关心的错误
+func ShouldIgnore(err error) bool {
+	if err == serviceUnavailableErr || err == internalServerErr {
+		return true
+	}
+	return false
+}

long_pull.go

@@ -42,9 +42,18 @@ func (d *Diamond) LongPull(unit Unit, contentMD5 string) (string, error) {
 	if err != nil {
 		return "", err
 	}
+
+	switch response.StatusCode() {
+	case http.StatusServiceUnavailable:
+		return "", serviceUnavailableErr
+	case http.StatusInternalServerError:
+		return "", internalServerErr
+	}
+
 	if !response.Success() {
 		return "", errors.New(response.String())
 	}
+
 	ret := url.QueryEscape(strings.Join([]string{unit.DataID, unit.Group, d.option.tenant}, wordSeparator) + lineSeparator)
 	if contentMD5 == "" ||
 		ret == strings.TrimSpace(response.String()) {