Method Clear

db/change_cache.go:240–260

Empty out all channel caches.

(ctx context.Context)

// Empty out all channel caches.
func (c *changeCache) Clear(ctx context.Context) error {
	c.lock.Lock()
	defer c.lock.Unlock()

	// Reset initialSequence so that any new channel caches have their validFrom set to the current last sequence
	// the point at which the change cache was initialized / re-initialized.
	// No need to touch c.nextSequence here, because we don't want to touch the sequence buffering state.
	var err error
	c.initialSequence, err = c.db.LastSequence(ctx)
	if err != nil {
		return err
	}

	c.pendingLogs = nil
	heap.Init(&c.pendingLogs)

	c.initTime = time.Now()

	c.channelCache.Clear()
	return nil
}

// If set to false, DocChanged() becomes a no-op.
func (c *changeCache) EnableChannelIndexing(enable bool) {