Skip to content

Commit edb6283

Browse files
committed
xinfo-groups: support nil lag in XINFO GROUPS
1 parent 8ba559c commit edb6283

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

command.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2189,6 +2189,8 @@ func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
21892189
// to the group's consumers, or a NULL(Nil) when that number can't be determined.
21902190
if err != nil && err != Nil {
21912191
return err
2192+
} else if err == Nil {
2193+
group.Lag = -1
21922194
}
21932195
default:
21942196
return fmt.Errorf("redis: unexpected key %q in XINFO GROUPS reply", key)

0 commit comments

Comments
 (0)