File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -2057,6 +2057,9 @@ func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
2057
2057
}
2058
2058
case "lag" :
2059
2059
group .Lag , err = rd .ReadInt ()
2060
+
2061
+ // lag: the number of entries in the stream that are still waiting to be delivered
2062
+ // to the group's consumers, or a NULL(Nil) when that number can't be determined.
2060
2063
if err != nil && err != Nil {
2061
2064
return err
2062
2065
}
@@ -2366,6 +2369,8 @@ func readStreamGroups(rd *proto.Reader) ([]XInfoStreamGroup, error) {
2366
2369
return nil , err
2367
2370
}
2368
2371
case "lag" :
2372
+ // lag: the number of entries in the stream that are still waiting to be delivered
2373
+ // to the group's consumers, or a NULL(Nil) when that number can't be determined.
2369
2374
group .Lag , err = rd .ReadInt ()
2370
2375
if err != nil && err != Nil {
2371
2376
return nil , err
You can’t perform that action at this time.
0 commit comments