Trims a stream by length. Returns the number of deleted items. */
| 867 | |
| 868 | /* Trims a stream by length. Returns the number of deleted items. */ |
| 869 | int64_t streamTrimByLength(stream *s, long long maxlen, int approx) { |
| 870 | streamAddTrimArgs args = { |
| 871 | .trim_strategy = TRIM_STRATEGY_MAXLEN, |
| 872 | .approx_trim = approx, |
| 873 | .limit = approx ? 100 * server.stream_node_max_entries : 0, |
| 874 | .maxlen = maxlen |
| 875 | }; |
| 876 | return streamTrim(s, &args); |
| 877 | } |
| 878 | |
| 879 | /* Trims a stream by minimum ID. Returns the number of deleted items. */ |
| 880 | int64_t streamTrimByID(stream *s, streamID minid, int approx) { |
no test coverage detected