Method getChannelCache

db/channel_cache.go:318–343

(ctx context.Context, channel channels.ID)

}

func (c *channelCacheImpl) getChannelCache(ctx context.Context, channel channels.ID) (SingleChannelCache, error) {

	cacheValue, found := c.channelCaches.Get(channel)
	if found {
		return AsSingleChannelCache(ctx, cacheValue), nil
	}

	// Attempt to add a singleChannelCache for the channel name.  If unsuccessful, return a bypass channel cache
	singleChannelCache, ok := c.addChannelCache(ctx, channel)
	if ok {
		return singleChannelCache, nil
	}

	queryHandler, err := c.queryHandlerFactory(channel.CollectionID)
	if err != nil {
		return nil, err
	}

	bypassChannelCache := &bypassChannelCache{
		channel:      channel,
		queryHandler: queryHandler,
	}
	c.cacheStats.ChannelCacheBypassCount.Add(1)
	return bypassChannelCache, nil

}

func (c *channelCacheImpl) getBypassChannelCache(ch channels.ID) (SingleChannelCache, error) {
	queryHandler, err := c.queryHandlerFactory(ch.CollectionID)