Struct channelCacheImpl

db/channel_cache.go:91–108

type StableSequenceCallbackFunc func() uint64

type channelCacheImpl struct {
	queryHandlerFactory  ChannelQueryHandlerFactory    // Factory to look up ChannelQueryHandler for a collectionID
	channelCaches        *channels.RangeSafeCollection // A collection of singleChannelCaches
	backgroundTasks      []BackgroundTask              // List of background tasks specific to channel cache.
	dbName               string                        // Name of the database associated with the channel cache.
	terminator           chan bool                     // Signal terminator of background goroutines
	options              ChannelCacheOptions           // Channel cache options
	lateSeqLock          sync.RWMutex                  // Coordinates access to late sequence caches
	highCacheSequence    uint64                        // The highest sequence that has been cached.  Used to initialize validFrom for new singleChannelCaches
	seqLock              sync.RWMutex                  // Mutex for highCacheSequence
	maxChannels          int                           // Maximum number of channels in the cache
	compactHighWatermark int                           // High Watermark for cache compaction
	compactLowWatermark  int                           // Low Watermark for cache compaction
	compactRunning       base.AtomicBool               // Whether compact is currently running
	activeChannels       *channels.ActiveChannels      // Active channel handler
	cacheStats           *base.CacheStats              // Map used for cache stats
	validFromLock        sync.RWMutex                  // Mutex used to avoid race between AddToCache and addChannelCache.  See CBG-520 for more details
}

func NewChannelCacheForContext(ctx context.Context, options ChannelCacheOptions, context *DatabaseContext) (*channelCacheImpl, error) {
	return newChannelCache(ctx, context.Name, options, context.getQueryHandlerForCollection, context.activeChannels, context.DbStats.Cache())