-
Notifications
You must be signed in to change notification settings - Fork 1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Redis 6.2] Add idle option to XPENDING #1125
Conversation
Co-authored-by: Jean Boussier <[email protected]>
…pending_idle_option
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also please squash your commits.
redis.xadd('s1', { f: 'v2' }, id: '0-2') | ||
redis.xadd('s1', { f: 'v3' }, id: '0-3') | ||
redis.xreadgroup('g1', 'c1', 's1', '>') | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Rubocop is unhappy
Offenses:
test/lint/streams.rb:761:1: C: [Correctable] Layout/TrailingWhitespace: Trailing whitespace detected.
@@ -752,6 +752,49 @@ def test_xpending_with_range_options | |||
assert_equal 1, actual[2]['count'] | |||
end | |||
|
|||
def test_xpending_with_range_and_idle_options | |||
redis.xadd('s1', { f: 'v1' }, id: '0-1') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This test needs to be wrapped in a target_version "6.2" do
block.
Thanks for the Feedback and the Merge. |
Added support for Idle time filter on the XPENDING command, which is available since 6.2.0.
Reference: #978