Skip to content
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.

Sign up for GitHub

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

Jump to bottom

Add reactive scanning #638

Closed
mp911de opened this issue Oct 29, 2017 · 0 comments
Closed

Add reactive scanning #638

mp911de opened this issue Oct 29, 2017 · 0 comments
Labels
type: feature A new feature
Milestone
Lettuce 5.1.0 M1

Comments

@mp911de
Copy link
Collaborator

mp911de commented Oct 29, 2017

Add support to scan data structures using the reactive API:

Flux<String> keys = ScanStream.scan(reactive);

Like ScanIterator, ScanStream should encapsulate a cursor and the scan progress. Stream scanning should respect demand and issue only subsequent scan commands if the subscriber has sufficient demand.
@mp911de mp911de added the type: feature A new feature label Oct 29, 2017
@mp911de mp911de added this to the Lettuce 5.1.0 milestone Oct 29, 2017
mp911de added a commit that referenced this issue Oct 29, 2017
@mp911de
Polishing #638
607ab37 
Improve javadoc.
mp911de added a commit that referenced this issue Oct 29, 2017
@mp911de
Polishing #638
51a14a8 
Improve javadoc.
mp911de added a commit that referenced this issue Oct 29, 2017
@mp911de
Polishing #638
3428a9d 
Improve javadoc.
mp911de added a commit that referenced this issue Oct 29, 2017
@mp911de
Add reactive scanning #638
ee84ba9 
Lettuce now supports reactive scanning for all connections (Standalone, Master/Slave, Cluster). Progressive scanning respects demand and executes subsequent scan commands if the subscriber has signalled enough demand.

RedisReactiveCommands<String, String> reactive = …;

Flux<String> keys = ScanStream.scan(reactive);

Flux<ScoredValue<String>> scoredValues = ScanStream.zscan(reactive, key, ScanArgs.Builder.limit(200)); // set batch size to 200
mp911de added a commit that referenced this issue Oct 29, 2017
@mp911de
Polishing #638
fb9a215 
Improve javadoc.
@mp911de mp911de closed this as completed Oct 29, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
type: feature A new feature
Projects
None yet
Milestone
Lettuce 5.1.0 M1
Development

No branches or pull requests
1 participant
@mp911de