Conversation
|
Hi @LiuYuHui , how's it going now? Feel free to ask question if you have any problems. :) |
| uint64_t last_idle; | ||
| uint64_t last_active; | ||
| StreamEntryID min_pending_entry_id; | ||
| StreamEntryID max_pending_entry_id; |
There was a problem hiding this comment.
Hi @Yangsx-1, currently I only record min_entry_id/max_entry_id in stream consumer metadata, because If put every every entry in metadata, it will make the metadata very big. But I am not sure the current design is efficient when I want to read entries in PEL, I have to iterate the elements range from min_entry_id and max_entry_id, maybe it will be too slow. Do you have any suggestions about this?
There was a problem hiding this comment.
Yes, it is a little inefficient. But only XPENDING and XINFO commands need to iterate the whole elements, and XACK, XCLAIM will only have o(1) complexity in this design, I think it's ok for now. @LiuYuHui
|
Hi @LiuYuHui , is there any progress? |
This PR is still in a very early stage, it is not ready for review.