github.com/joomcode/redispipe
Advanced tools
+2
-0
@@ -72,2 +72,4 @@ package redis | ||
| ErrAsk = ErrResult.NewSubtype("ask", ErrTraitClusterMove) | ||
| // ErrClusterDown - CLUSTERDOWN response | ||
| ErrClusterDown = ErrResult.NewSubtype("clusterdown", ErrTraitNotSent) | ||
| // ErrLoading - redis didn't finish start | ||
@@ -74,0 +76,0 @@ ErrLoading = ErrResult.NewSubtype("loading", ErrTraitNotSent) |
+3
-0
@@ -51,2 +51,5 @@ package redis | ||
| } | ||
| if strings.HasPrefix(txt, "CLUSTERDOWN") { | ||
| return ErrClusterDown.New(txt), len(line) | ||
| } | ||
| if strings.HasPrefix(txt, "LOADING") { | ||
@@ -53,0 +56,0 @@ return ErrLoading.New(txt), len(line) |