Tag EOF as retryable error.

lib/db/db.go

@@ -56,7 +56,7 @@ func (s *storeWrapper) Begin() (*sql.Tx, error) {
 }
 
 func (s *storeWrapper) IsRetryableError(err error) bool {
-	return retryableError(err)
+	return isRetryableError(err)
 }
 
 func Open(driverName, dsn string) (Store, error) {

lib/db/errors.go

@@ -2,12 +2,25 @@ package db
 
 import (
 	"errors"
+	"io"
 	"syscall"
 )
 
-func retryableError(err error) bool {
-	if errors.Is(err, syscall.ECONNRESET) || errors.Is(err, syscall.ECONNREFUSED) {
-		return true
+var retryableErrs = []error{
+	syscall.ECONNRESET,
+	syscall.ECONNREFUSED,
+	io.EOF,
+}
+
+func isRetryableError(err error) bool {
+	if err == nil {
+		return false
+	}
+
+	for _, retryableErr := range retryableErrs {
+		if errors.Is(err, retryableErr) {
+			return true
+		}
 	}
 
 	return false

lib/db/errors_test.go

@@ -8,7 +8,7 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
-func TestRetryable_Errors(t *testing.T) {
+func TestIsRetryable_Errors(t *testing.T) {
 	type _tc struct {
 		name           string
 		err            error
@@ -49,7 +49,7 @@ func TestRetryable_Errors(t *testing.T) {
 	}
 
 	for _, tc := range tcs {
-		actualErr := retryableError(tc.err)
+		actualErr := isRetryableError(tc.err)
 		assert.Equal(t, tc.expectedResult, actualErr, tc.name)
 	}
 }