You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
Added
Replicated map (rmap) TTL support
Absolute TTL: rmap.WithTTL(ttl) sets expiry once (uses EXPIRENX).
Sliding TTL: rmap.WithSlidingTTL(ttl) refreshes expiry on every write.
Fixed
Prevent leaked per-stream sink metadata (map:stream:*) for TTL’d streams by applying the stream TTL policy to the sink consumer rmap (stream:<name>:sinks).
Stream.Destroy() now also clears the per-stream sink consumer map hash and publishes a reset notification (mirrors rmap destroy semantics).
