mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

fix: struct XInfoGroup add attributes EntriesRead and Lan to avoid default err

This commit is contained in:
lianghongle 2022-12-23 03:30:48 +08:00
parent 52af8ba852
commit ba471af0b7
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
command.go
View File

@ -1962,6 +1962,9 @@ type XInfoGroup struct {
Consumers int64 Consumers int64
Pending int64 Pending int64
LastDeliveredID string LastDeliveredID string
Lan int64
EntriesRead int64
} }
var _ Cmder = (*XInfoGroupsCmd)(nil) var _ Cmder = (*XInfoGroupsCmd)(nil)
@ -2016,11 +2019,11 @@ func readXGroupInfo(rd *proto.Reader) (XInfoGroup, error) {
if err != nil { if err != nil {
return group, err return group, err
} }
if n != 8 { /*if n != 8 {
return group, fmt.Errorf("redis: got %d elements in XINFO GROUPS reply, wanted 8", n) return group, fmt.Errorf("redis: got %d elements in XINFO GROUPS reply, wanted 8", n)
} }*/
for i := 0; i < 4; i++ { for i := 0; i < n/2; i++ {
key, err := rd.ReadString() key, err := rd.ReadString()
if err != nil { if err != nil {
return group, err return group, err
@ -2046,8 +2049,18 @@ func readXGroupInfo(rd *proto.Reader) (XInfoGroup, error) {
} }
case "last-delivered-id": case "last-delivered-id":
group.LastDeliveredID = val group.LastDeliveredID = val
case "entries-read":
group.EntriesRead, err = strconv.ParseInt(val, 0, 64)
if err != nil {
return group, err
}
case "lag":
group.Lan, err = strconv.ParseInt(val, 0, 64)
if err != nil {
return group, err
}
default: default:
return group, fmt.Errorf("redis: unexpected content %s in XINFO GROUPS reply", key) return group, fmt.Errorf("redis: unexpected content %s in XINFO GROUPS reply 2050", key)
} }
} }