Method _incrementSequence

db/sequence_allocator.go:389–398

Increments the _sync:seq document. Retry handling provided by bucket.Incr. Expects sequenceAllocator.mutex to be held to ensure consistent LastSequenceReservedValue updates.

(numToReserve uint64)

// Increments the _sync:seq document.  Retry handling provided by bucket.Incr.
// Expects sequenceAllocator.mutex to be held to ensure consistent LastSequenceReservedValue updates.
func (s *sequenceAllocator) _incrementSequence(numToReserve uint64) (uint64, error) {
	value, err := s.datastore.Incr(s.metaKeys.SyncSeqKey(), numToReserve, numToReserve, 0)
	if err != nil {
		return value, err
	}
	s.dbStats.SequenceIncrCount.Add(1)
	s.dbStats.SequenceReservedCount.Add(int64(numToReserve))
	s.dbStats.LastSequenceReservedValue.Set(int64(value))
	return value, nil
}

// ReleaseSequence writes an unused sequence document, used to notify sequence buffering that a sequence has been allocated and not used.
// Sequence is stored as the document body to avoid null doc issues.