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 930d904205

This commit is contained in:
Sangriot 2024-11-15 14:24:49 +08:00 committed by GitHub
parent 930d904205 9f7f07f8b9
commit 2b2640e849
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

10
command.go
View File

@ -1782,10 +1782,10 @@ func (cmd *XPendingCmd) readReply(rd *proto.Reader) error {
//------------------------------------------------------------------------------
type XPendingExt struct {
ID string
Consumer string
Idle time.Duration
RetryCount int64
ID string
Consumer string
Idle time.Duration
DeliveredTimes int64
}
type XPendingExtCmd struct {
@ -1846,7 +1846,7 @@ func (cmd *XPendingExtCmd) readReply(rd *proto.Reader) error {
}
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
}
}

6
commands_test.go
View File

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