From 4f08776500861a9f7cb83d236dfcc259dff23c61 Mon Sep 17 00:00:00 2001 From: Fusl Date: Fri, 5 May 2023 19:00:05 +0000 Subject: [PATCH] delete last_ts info for unlinked keys --- globalbackfeedmanager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/globalbackfeedmanager.go b/globalbackfeedmanager.go index d7d39f5..6c9f14e 100644 --- a/globalbackfeedmanager.go +++ b/globalbackfeedmanager.go @@ -281,6 +281,7 @@ func (that *GlobalBackfeedManager) HandleUnlink(res http.ResponseWriter, req *ht return } pipe := that.BackfeedRedis.Pipeline() + pipe.HDel(req.Context(), ":last_ts", keys...) for _, key := range keys { pipe.Unlink(req.Context(), key) }