Function AsSingleChannelCache

db/channel_cache.go:359–366

Converts an RangeSafeCollection value to a singleChannelCacheImpl. On type conversion error, logs a warning and returns nil.

(ctx context.Context, cacheValue interface{})

// Converts an RangeSafeCollection value to a singleChannelCacheImpl.  On type
// conversion error, logs a warning and returns nil.
func AsSingleChannelCache(ctx context.Context, cacheValue interface{}) *singleChannelCacheImpl {
	singleChannelCache, ok := cacheValue.(*singleChannelCacheImpl)
	if !ok {
		base.WarnfCtx(ctx, "Unexpected channel cache value type: %T", cacheValue)
		return nil
	}
	return singleChannelCache
}

// Adds a new channel to the channel cache.  Locking seqLock is required here to prevent missed data in the following scenario:
//