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

Merge 9f7f07f8b9 into e63669e170

This commit is contained in:
Sangriot 2024-11-22 00:17:39 -05:00 committed by GitHub
parent e63669e170 9f7f07f8b9
commit a116e2e4c1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
command.go
View File

@ -1787,7 +1787,7 @@ type XPendingExt struct {
ID string ID string
Consumer string Consumer string
Idle time.Duration Idle time.Duration
RetryCount int64 DeliveredTimes int64
} }
type XPendingExtCmd struct { type XPendingExtCmd struct {
@ -1848,7 +1848,7 @@ func (cmd *XPendingExtCmd) readReply(rd *proto.Reader) error {
} }
cmd.val[i].Idle = time.Duration(idle) * time.Millisecond cmd.val[i].Idle = time.Duration(idle) * time.Millisecond
if cmd.val[i].RetryCount, err = rd.ReadInt(); err != nil && err != Nil { if cmd.val[i].DeliveredTimes, err = rd.ReadInt(); err != nil && err != Nil {
return err return err
} }
} }

6
commands_test.go
View File

@ -6063,9 +6063,9 @@ var _ = Describe("Commands", func() {
infoExt[i].Idle = 0 infoExt[i].Idle = 0
} }
Expect(infoExt).To(Equal([]redis.XPendingExt{ Expect(infoExt).To(Equal([]redis.XPendingExt{
{ID: "1-0", Consumer: "consumer", Idle: 0, RetryCount: 1}, {ID: "1-0", Consumer: "consumer", Idle: 0, DeliveredTimes: 1},
{ID: "2-0", Consumer: "consumer", Idle: 0, RetryCount: 1}, {ID: "2-0", Consumer: "consumer", Idle: 0, DeliveredTimes: 1},
{ID: "3-0", Consumer: "consumer", Idle: 0, RetryCount: 1}, {ID: "3-0", Consumer: "consumer", Idle: 0, DeliveredTimes: 1},
})) }))
args.Idle = 72 * time.Hour args.Idle = 72 * time.Hour