Concurrent buffer Redis, remove sets when they are empty (#176)

Akira013 · web-flow · commit 6cbb34410681 · 2025-11-14T09:52:00.000-08:00
diff --git a/concurrent_buffer.go b/concurrent_buffer.go
@@ -151,6 +151,7 @@ func (c *ConcurrentBufferRedis) Add(ctx context.Context, key string) (int64, err
 				Score:  float64(now.UnixNano()),
 				Member: key,
 			})
+			pipeliner.Expire(ctx, c.key, c.ttl)
 			countCmd = pipeliner.ZCard(ctx, c.key)
 
 			return nil
