(ctx context.Context, channel channels.ID)
| 411 | } |
| 412 | |
| 413 | func (c *channelCacheImpl) getActiveChannelCache(ctx context.Context, channel channels.ID) (*singleChannelCacheImpl, bool) { |
| 414 | |
| 415 | cacheValue, found := c.channelCaches.Get(channel) |
| 416 | if !found { |
| 417 | return nil, false |
| 418 | } |
| 419 | cache := AsSingleChannelCache(ctx, cacheValue) |
| 420 | return cache, cache != nil |
| 421 | } |
| 422 | |
| 423 | func (c *channelCacheImpl) MaxCacheSize(ctx context.Context) int { |
| 424 |
no test coverage detected