(ctx context.Context, a *XPendingExtArgs)
| 475 | } |
| 476 | |
| 477 | func (c cmdable) XPendingExt(ctx context.Context, a *XPendingExtArgs) *XPendingExtCmd { |
| 478 | args := make([]interface{}, 0, 9) |
| 479 | args = append(args, "xpending", a.Stream, a.Group) |
| 480 | if a.Idle != 0 { |
| 481 | args = append(args, "idle", formatMs(ctx, a.Idle)) |
| 482 | } |
| 483 | args = append(args, a.Start, a.End, a.Count) |
| 484 | if a.Consumer != "" { |
| 485 | args = append(args, a.Consumer) |
| 486 | } |
| 487 | cmd := NewXPendingExtCmd(ctx, args...) |
| 488 | _ = c(ctx, cmd) |
| 489 | return cmd |
| 490 | } |
| 491 | |
| 492 | type XAutoClaimArgs struct { |
| 493 | Stream string |
nothing calls this directly
no test coverage detected