Skip to content

Commit f10f34e

Browse files
committed
Rename XGroup to XInfoGroups
1 parent d5b2ecc commit f10f34e

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

command.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1291,10 +1291,10 @@ func (cmd *XPendingExtCmd) readReply(rd *proto.Reader) error {
12911291

12921292
type XInfoGroupsCmd struct {
12931293
baseCmd
1294-
val []XGroup
1294+
val []XInfoGroups
12951295
}
12961296

1297-
type XGroup struct {
1297+
type XInfoGroups struct {
12981298
Name string
12991299
Consumers int64
13001300
Pending int64
@@ -1309,11 +1309,11 @@ func NewXInfoGroupsCmd(stream string) *XInfoGroupsCmd {
13091309
}
13101310
}
13111311

1312-
func (cmd *XInfoGroupsCmd) Val() []XGroup {
1312+
func (cmd *XInfoGroupsCmd) Val() []XInfoGroups {
13131313
return cmd.val
13141314
}
13151315

1316-
func (cmd *XInfoGroupsCmd) Result() ([]XGroup, error) {
1316+
func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroups, error) {
13171317
return cmd.val, cmd.err
13181318
}
13191319

@@ -1329,7 +1329,7 @@ func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
13291329
if err != nil {
13301330
return nil, err
13311331
}
1332-
cmd.val = append(cmd.val, v.(XGroup))
1332+
cmd.val = append(cmd.val, v.(XInfoGroups))
13331333
}
13341334
return nil, nil
13351335
})
@@ -1343,7 +1343,7 @@ func xGroupInfoParser(rd *proto.Reader, n int64) (interface{}, error) {
13431343
}
13441344
var (
13451345
err error
1346-
grp XGroup
1346+
grp XInfoGroups
13471347
key string
13481348
val string
13491349
)

0 commit comments

Comments
 (0)