Fixed output value of wsrep_cluster_status

adivinho · adivinho · commit 0001ee55eca1 · 2020-06-01T11:39:55.000+03:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -12,6 +12,7 @@
 * [FEATURE] Add `tls.insecure-skip-verify` flag to ignore tls verification errors (PR #417) #348
 * [FEATURE] Add new metrics to `replication_group_member_stats` collector to support MySQL 8.x.
 * [FEATURE] Add collector for `replication_group_members` (PR #459) #362
+* [BUGFIX] Fixed output value of wsrep_cluster_status #473
 
 ### BREAKING CHANGES:
 
diff --git a/collector/collector.go b/collector/collector.go
@@ -56,7 +56,7 @@ func parseStatus(data sql.RawBytes) (float64, bool) {
 	if bytes.Equal(data, []byte("Primary")) {
 		return 1, true
 	}
-	if bytes.Equal(data, []byte("non-Primary")) || bytes.Equal(data, []byte("Disconnected")) {
+	if strings.EqualFold(string(data), "non-Primary") || bytes.Equal(data, []byte("Disconnected")) {
 		return 0, true
 	}
 	if logNum := logRE.Find(data); logNum != nil {

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ func parseStatus(data sql.RawBytes) (float64, bool) {`
`56`	`56`	`if bytes.Equal(data, []byte("Primary")) {`
`57`	`57`	`return 1, true`
`58`	`58`	`}`
`59`		`- if bytes.Equal(data, []byte("non-Primary")) \|\| bytes.Equal(data, []byte("Disconnected")) {`
	`59`	`+ if strings.EqualFold(string(data), "non-Primary") \|\| bytes.Equal(data, []byte("Disconnected")) {`
`60`	`60`	`return 0, true`
`61`	`61`	`}`
`62`	`62`	`if logNum := logRE.Find(data); logNum != nil {`