Method Cleanup

weed/mq/kafka/protocol/response_cache.go:58–68

Cleanup removes expired entries from the cache

()

// Cleanup removes expired entries from the cache
func (c *ResponseCache) Cleanup() {
	c.mu.Lock()
	defer c.mu.Unlock()

	now := time.Now()
	for key, entry := range c.cache {
		if now.Sub(entry.timestamp) > c.ttl {
			delete(c.cache, key)
		}
	}
}

// StartCleanupLoop starts a background goroutine to periodically clean up expired entries
func (c *ResponseCache) StartCleanupLoop(interval time.Duration) {