Method Start

db/change_cache.go:196–212

(initialSequence uint64)

}

func (c *changeCache) Start(initialSequence uint64) error {

	// Unlock the cache after this function returns.
	defer c.lock.Unlock()

	// Set initial sequence for sequence buffering
	c._setInitialSequence(initialSequence)

	// Set initial sequence for cache (validFrom)
	c.channelCache.Init(initialSequence)

	if !c.started.CompareAndSwap(false, true) {
		return errors.New("changeCache already started")
	}

	return nil
}

// Stops the cache. Clears its state and tells the housekeeping task to stop.
func (c *changeCache) Stop(ctx context.Context) {