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.

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

New data structure —— Stream #141

Closed
qishenonly opened this issue Jul 3, 2023 · 0 comments
Closed

New data structure —— Stream #141

qishenonly opened this issue Jul 3, 2023 · 0 comments
Assignees
Labels
difficult:⭐⭐⭐⭐⭐ Up to five stars enhancement New feature or request

Comments

@qishenonly
Copy link
Member

qishenonly commented Jul 3, 2023

We need a new data structure, Stream , to extend the database's key-value storage structure.
We need to build some instructions into Stream to make it more complete.
If you are interested in extending the Stream data structure, you can comment below on the issue id you would like to try and we will assign it to you.

ID Method Command Description Progress People
1 XAdd XAdd key ID field value1 Insert a single message with an ID and a field into a stream @qishenonly  finished
2 XAdds XAdds key ID field1 value1 ... Insert multiple messages with IDs and fields into a stream    
3 XDel XDel key ID Delete a single message from a stream @qishenonly   finished
4 XDels XDels key ID1 ID2 ... Delete multiple messages from a stream    
5 XLen XLen key Get the number of messages in a stream @qishenonly   finished
6 XRange XRange key start end [COUNT count] Get messages within a specified range, with an optional count @qishenonly   finished
7 XRevRange XRevRange key end start [COUNT count] Get messages within a specified range in reverse order, with count  @qishenonly  finished
8 XRead XRead COUNT count STREAMS key Read a message from a streams @qishenonly   finished
9 XReads XReads COUNT count STREAMS key ... Read multiple messages from a streams    
10 XGroup XGroup CREATE key groupname id-or-$ Create a new consumer group or update an existing group's settings @qishenonly   finished
11 XAck XAck key group ID1 Confirm that a consumer group has processed messages in the stream    
12 XAck XAck key group ID1 ID2 ... Confirm that a consumer group has processed multiple messages    
13 XPending XPending key group [start end count] Get information about pending messages in the specified group    
14 XClaim XClaim key group consumer min-idle-time ID Get a specified message from the pending messages of a specific group and assign it to a consumer    
15 XClaim XClaim key group consumer min-idle-time ID [ID ...] Get multiple specified messages from the pending messages of a specific group and assign them to a consumer
@qishenonly qishenonly added difficult:⭐⭐⭐⭐⭐ Up to five stars enhancement New feature or request labels Jul 3, 2023
@qishenonly qishenonly self-assigned this Jul 11, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 12, 2023
CrazyJius pushed a commit that referenced this issue Jul 16, 2023
CrazyJius pushed a commit that referenced this issue Jul 16, 2023
CrazyJius pushed a commit that referenced this issue Jul 16, 2023
CrazyJius pushed a commit that referenced this issue Jul 17, 2023
CrazyJius pushed a commit that referenced this issue Jul 17, 2023
qishenonly added a commit that referenced this issue Jul 21, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
difficult:⭐⭐⭐⭐⭐ Up to five stars enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

1 participant