Skip to content

New data structure —— Stream  #141

Closed
@qishenonly

Description

@qishenonly

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

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions