Merge pull request #30 from joomcode/feature/INFRA-6490-instante-infos

atikhono · web-flow · commit c558557c50c5 · 2024-04-26T14:08:20.000+03:00
Indicate if redis node is disconnected in InstanceInfo
diff --git a/rediscluster/redisclusterutil/cluster.go b/rediscluster/redisclusterutil/cluster.go
@@ -105,6 +105,7 @@ type InstanceInfo struct {
 	// More probably, redis instance with other UUID were started on the same port.
 	NoAddr    bool
 	SlaveOf   string
+	Connected bool
 	Slots     [][2]uint16
 	Migrating []SlotMigration
 }
@@ -312,6 +313,7 @@ func ParseClusterNodes(res interface{}) (InstanceInfos, error) {
 		}
 		node.NoAddr = strings.Contains(parts[2], "noaddr")
 		node.MySelf = strings.Contains(parts[2], "myself")
+		node.Connected = parts[7] == "connected"
 
 		for _, slot := range parts[8:] {
 			if slot[0] == '[' {

Original file line number	Diff line number	Diff line change
`@@ -105,6 +105,7 @@ type InstanceInfo struct {`
`105`	`105`	`// More probably, redis instance with other UUID were started on the same port.`
`106`	`106`	`NoAddr bool`
`107`	`107`	`SlaveOf string`
	`108`	`+ Connected bool`
`108`	`109`	`Slots [][2]uint16`
`109`	`110`	`Migrating []SlotMigration`
`110`	`111`	`}`
`@@ -312,6 +313,7 @@ func ParseClusterNodes(res interface{}) (InstanceInfos, error) {`
`312`	`313`	`}`
`313`	`314`	`node.NoAddr = strings.Contains(parts[2], "noaddr")`
`314`	`315`	`node.MySelf = strings.Contains(parts[2], "myself")`
	`316`	`+ node.Connected = parts[7] == "connected"`
`315`	`317`
`316`	`318`	`for _, slot := range parts[8:] {`
`317`	`319`	`if slot[0] == '[' {`