Add s3 connection reset retries

pkg/storages/s3/retryer.go

@@ -0,0 +1,25 @@
+package s3
+
+import (
+	"strings"
+
+	"github.com/aws/aws-sdk-go/aws/request"
+)
+
+func NewConnResetRetryer(baseRetryer request.Retryer) *ConnResetRetryer {
+	return &ConnResetRetryer{
+		baseRetryer: baseRetryer,
+	}
+}
+
+type ConnResetRetryer struct {
+	baseRetryer request.Retryer
+}
+
+func (r ConnResetRetryer) ShouldRetry(req *request.Request) bool {
+	if req.Error != nil && strings.Contains(req.Error.Error(), "connection reset by peer") {
+		return true
+	}
+
+	return r.baseRetryer.ShouldRetry(req)
+}

pkg/storages/s3/session.go

@@ -87,7 +87,7 @@ func getDefaultConfig(settings map[string]string) *aws.Config {
 	// most services. If you want to implement custom retry logic, you can implement the
 	// request.Retryer interface.
 	config := defaults.Get().Config.WithRegion(settings[RegionSetting])
-	config = request.WithRetryer(config, client.DefaultRetryer{NumMaxRetries: MaxRetries})
+	config = request.WithRetryer(config, NewConnResetRetryer(client.DefaultRetryer{NumMaxRetries: MaxRetries}))
 
 	if logLevel, ok := settings[LogLevel]; ok {
 		config = config.WithLogLevel(func(s string) aws.LogLevelType {