Struct singleChannelCacheImpl

db/channel_cache_single.go:103–118

}

type singleChannelCacheImpl struct {
	channelID        channels.ID          // The channel
	queryHandler     ChannelQueryHandler  // Channel query function
	logs             LogEntries           // Log entries in sequence order
	validFrom        uint64               // First sequence that logs is valid for, not necessarily the seq number of a change entry.
	lock             sync.RWMutex         // Controls access to logs, validFrom
	queryLock        sync.Mutex           // Ensures only one view query is made at a time
	lateLogs         []*lateLogEntry      // Late arriving LogEntries, stored in the order they were received
	lastLateSequence uint64               // Used for fast check of whether listener has the latest
	lateLogLock      sync.RWMutex         // Controls access to lateLogs
	lateSequenceUUID uuid.UUID            // UUID for late sequence consistency across cache compaction
	options          *ChannelCacheOptions // Cache size/expiry settings
	cachedDocIDs     map[string]struct{}  // Set of keys present in the cache.  Used for efficient check for previous revisions on append
	recentlyUsed     base.AtomicBool      // Atomic recently used flag, used by cache compaction.
	cacheStats       *base.CacheStats     // Map used for cache stats
}

func newSingleChannelCache(queryHandler ChannelQueryHandler, channel channels.ID, validFrom uint64, cacheStats *base.CacheStats) *singleChannelCacheImpl {
	cache := &singleChannelCacheImpl{queryHandler: queryHandler, channelID: channel, validFrom: validFrom}