describe add retry

Author: mikatong

tencentcloud/services/mongodb/service_tencentcloud_mongodb.go

@@ -476,37 +476,51 @@ func (me *MongodbService) DescribeSecurityGroup(ctx context.Context, instanceId
 	logId := tccommon.GetLogId(ctx)
 	request := mongodb.NewDescribeSecurityGroupRequest()
 	request.InstanceId = helper.String(instanceId)
-	ratelimit.Check(request.GetAction())
-	response, err := me.client.UseMongodbClient().DescribeSecurityGroup(request)
+
+	err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
+		ratelimit.Check(request.GetAction())
+		response, e := me.client.UseMongodbClient().DescribeSecurityGroup(request)
+		if e != nil {
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]",
+				logId, request.GetAction(), request.ToJsonString(), e.Error())
+			return tccommon.RetryError(e)
+		}
+		log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]",
+			logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
+
+		groups = response.Response.Groups
+		return nil
+	})
 	if err != nil {
-		log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]",
-			logId, request.GetAction(), request.ToJsonString(), err.Error())
 		errRet = err
 		return
 	}
-	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]",
-		logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
-
-	groups = response.Response.Groups
 	return
 }
 
 func (me *MongodbService) DescribeDBInstanceNodeProperty(ctx context.Context, instanceId string) (replicateSets []*mongodb.ReplicateSetInfo, errRet error) {
 	logId := tccommon.GetLogId(ctx)
 	request := mongodb.NewDescribeDBInstanceNodePropertyRequest()
 	request.InstanceId = helper.String(instanceId)
-	ratelimit.Check(request.GetAction())
-	response, err := me.client.UseMongodbClient().DescribeDBInstanceNodeProperty(request)
+
+	err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
+		ratelimit.Check(request.GetAction())
+		response, e := me.client.UseMongodbClient().DescribeDBInstanceNodeProperty(request)
+		if e != nil {
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]",
+				logId, request.GetAction(), request.ToJsonString(), e.Error())
+			return tccommon.RetryError(e)
+		}
+		log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]",
+			logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
+
+		replicateSets = response.Response.ReplicateSets
+		return nil
+	})
 	if err != nil {
-		log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]",
-			logId, request.GetAction(), request.ToJsonString(), err.Error())
 		errRet = err
 		return
 	}
-	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]",
-		logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
-
-	replicateSets = response.Response.ReplicateSets
 	return
 }