Method releaseSequence

db/sequence_allocator.go:402–413

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.

(ctx context.Context, sequence uint64)

// 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.
func (s *sequenceAllocator) releaseSequence(ctx context.Context, sequence uint64) error {
	key := fmt.Sprintf("%s%d", s.metaKeys.UnusedSeqPrefix(), sequence)
	body := make([]byte, 8)
	binary.LittleEndian.PutUint64(body, sequence)
	_, err := s.datastore.AddRaw(key, UnusedSequenceTTL, body)
	if err != nil {
		return err
	}
	s.dbStats.SequenceReleasedCount.Add(1)
	base.DebugfCtx(ctx, base.KeyCRUD, "Released unused sequence #%d", sequence)
	return nil
}

// releaseSequenceRange writes a binary document with the key _sync:unusedSeqs:fromSeq:toSeq.
// fromSeq and toSeq are inclusive (i.e. both fromSeq and toSeq are unused).