Closed wangshao1 closed 3 months ago
The changes introduce support for a new kStreams
data type within the BaseMetaFilter
and BaseDataFilter
classes across various files. The updates involve handling stream meta values, adding detailed error logging for stream meta value lengths, and enhancing the functionality to accumulate results in pattern matching deletions.
Files | Change Summaries |
---|---|
src/storage/src/base_filter.h |
Added support for the kStreams data type in BaseMetaFilter and BaseDataFilter classes. Included parsing and handling for stream meta values. |
src/storage/src/pika_stream_meta_value.h |
Enhanced error logging statements to include the actual and expected lengths of stream meta values. |
src/storage/src/redis_strings.cc |
Reordered assignments within the Redis::PKPatternMatchDel function for improved processing flow. |
src/storage/src/storage.cc |
Updated Storage::PKPatternMatchDel function to accumulate results from multiple instances before returning the final value. |
sequenceDiagram
participant Client
participant Storage
participant BaseFilter
participant PikaStreamMeta
Client->>Storage: Request to delete pattern match
Storage->>BaseFilter: Apply BaseMetaFilter with kStreams handling
BaseFilter->>PikaStreamMeta: Parse stream meta values
PikaStreamMeta-->>BaseFilter: Return parsed values
BaseFilter-->>Storage: Filtered results
Storage->>Client: Return accumulated results
A new type in the streams of code,
With filters so smart, they decode,
Meta values parsed with care,
Logging errors, now more aware. 🌟
Pattern matching with a touch so neat,
Rabbit's work, impossible to beat. 🐇✨
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Summary by CodeRabbit
New Features
kStreams
, enabling more efficient handling of stream data within filters.Bug Fixes
Refactor
Enhancements