diff --git a/error.go b/error.go index ec2224c0..6f47f7cf 100644 --- a/error.go +++ b/error.go @@ -75,6 +75,9 @@ func shouldRetry(err error, retryTimeout bool) bool { if strings.HasPrefix(s, "READONLY ") { return true } + if strings.HasPrefix(s, "MASTERDOWN ") { + return true + } if strings.HasPrefix(s, "CLUSTERDOWN ") { return true }