diff --git a/error.go b/error.go index 9b348193a..db96fd82b 100644 --- a/error.go +++ b/error.go @@ -63,6 +63,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 }