| 118 | } |
| 119 | |
| 120 | func newSingleChannelCache(queryHandler ChannelQueryHandler, channel channels.ID, validFrom uint64, cacheStats *base.CacheStats) *singleChannelCacheImpl { |
| 121 | cache := &singleChannelCacheImpl{queryHandler: queryHandler, channelID: channel, validFrom: validFrom} |
| 122 | cache.initializeLateLogs() |
| 123 | cache.cachedDocIDs = make(map[string]struct{}) |
| 124 | cache.cacheStats = cacheStats |
| 125 | cache.options = &ChannelCacheOptions{ |
| 126 | ChannelCacheMinLength: DefaultChannelCacheMinLength, |
| 127 | ChannelCacheMaxLength: DefaultChannelCacheMaxLength, |
| 128 | ChannelCacheAge: DefaultChannelCacheAge, |
| 129 | MaxNumChannels: DefaultChannelCacheMaxNumber, |
| 130 | } |
| 131 | cache.logs = make(LogEntries, 0) |
| 132 | cache.recentlyUsed.Set(true) |
| 133 | |
| 134 | return cache |
| 135 | } |
| 136 | |
| 137 | func newChannelCacheWithOptions(ctx context.Context, queryHandler ChannelQueryHandler, channel channels.ID, validFrom uint64, options ChannelCacheOptions, cacheStats *base.CacheStats) *singleChannelCacheImpl { |
| 138 | cache := newSingleChannelCache(queryHandler, channel, validFrom, cacheStats) |