Added backoff time

hashicorp · Jan 22, 2020 · 53fbaf3 · 53fbaf3
1 parent 5dc76b5
commit 53fbaf3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugins/database/mongodb/mongodb.go b/plugins/database/mongodb/mongodb.go
@@ -233,6 +233,7 @@ func (m *MongoDB) RotateRootCredentials(ctx context.Context, statements []string
 // runCommandWithRetry runs a command with retry.
 func runCommandWithRetry(ctx context.Context, client *mongo.Client, db string, cmd interface{}) error {
 	timeout := time.Now().Add(1 * time.Minute)
+	backoffTime := 3
 	for {
 		// Run command
 		result := client.Database(db).RunCommand(ctx, cmd, nil)
@@ -243,7 +244,8 @@ func runCommandWithRetry(ctx context.Context, client *mongo.Client, db string, c
 		if time.Now().After(timeout) {
 			return result.Err()
 		}
-		time.Sleep(30 * time.Millisecond)
+		time.Sleep(time.Duration(backoffTime) * time.Second)
+		backoffTime += backoffTime
 	}
 	return nil
 }