Method startCacheCompaction

db/channel_cache.go:447–452

startCacheCompaction starts a goroutine for cache compaction if it's not already running.

(ctx context.Context)

// startCacheCompaction starts a goroutine for cache compaction if it's not already running.
func (c *channelCacheImpl) startCacheCompaction(ctx context.Context) {
	compactNotStarted := c.compactRunning.CompareAndSwap(false, true)
	if compactNotStarted {
		go c.compactChannelCache(ctx)
	}
}

// Compact runs until the number of channels in the cache is lower than compactLowWatermark
func (c *channelCacheImpl) compactChannelCache(ctx context.Context) {