(ctx context.Context, options ChannelCacheOptions, context *DatabaseContext)
| 108 | } |
| 109 | |
| 110 | func NewChannelCacheForContext(ctx context.Context, options ChannelCacheOptions, context *DatabaseContext) (*channelCacheImpl, error) { |
| 111 | return newChannelCache(ctx, context.Name, options, context.getQueryHandlerForCollection, context.activeChannels, context.DbStats.Cache()) |
| 112 | } |
| 113 | |
| 114 | func newChannelCache(ctx context.Context, dbName string, options ChannelCacheOptions, queryHandlerFactory ChannelQueryHandlerFactory, |
| 115 | activeChannels *channels.ActiveChannels, cacheStats *base.CacheStats) (*channelCacheImpl, error) { |
no test coverage detected