Skip to content

Commit

Permalink
Rename XGroup to XInfoGroups
Browse files Browse the repository at this point in the history
  • Loading branch information
vmihailenco committed Oct 8, 2019
1 parent d5b2ecc commit f10f34e
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions command.go
Original file line number Diff line number Diff line change
Expand Up @@ -1291,10 +1291,10 @@ func (cmd *XPendingExtCmd) readReply(rd *proto.Reader) error {

type XInfoGroupsCmd struct {
baseCmd
val []XGroup
val []XInfoGroups
}

type XGroup struct {
type XInfoGroups struct {
Name string
Consumers int64
Pending int64
Expand All @@ -1309,11 +1309,11 @@ func NewXInfoGroupsCmd(stream string) *XInfoGroupsCmd {
}
}

func (cmd *XInfoGroupsCmd) Val() []XGroup {
func (cmd *XInfoGroupsCmd) Val() []XInfoGroups {
return cmd.val
}

func (cmd *XInfoGroupsCmd) Result() ([]XGroup, error) {
func (cmd *XInfoGroupsCmd) Result() ([]XInfoGroups, error) {
return cmd.val, cmd.err
}

Expand All @@ -1329,7 +1329,7 @@ func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
if err != nil {
return nil, err
}
cmd.val = append(cmd.val, v.(XGroup))
cmd.val = append(cmd.val, v.(XInfoGroups))
}
return nil, nil
})
Expand All @@ -1343,7 +1343,7 @@ func xGroupInfoParser(rd *proto.Reader, n int64) (interface{}, error) {
}
var (
err error
grp XGroup
grp XInfoGroups
key string
val string
)
Expand Down

0 comments on commit f10f34e

Please sign in to comment.