Method registerKeyForActiveExpiration

db.go:843–866

registerKeyForActiveExpiration registers a key with TTL in the timing wheel for active expiration.

(record *core.Record, entry *core.Entry)

// registerKeyForActiveExpiration registers a key with TTL in the timing wheel for active expiration.
func (db *DB) registerKeyForActiveExpiration(record *core.Record, entry *core.Entry) {
	if db.ttlService == nil {
		return
	}

	meta := entry.Meta

	if meta.TTL > 0 && meta.Flag != DataDeleteFlag {
		if db.ttlService.IsExpired(record.TTL, record.Timestamp) {
			return
		}

		// Deregister old TTL before registering new one (handles TTL updates)
		db.ttlService.DeregisterKeyFromActiveExpiration(meta.BucketId, entry.Key)

		db.ttlService.RegisterKeyForActiveExpiration(
			meta.BucketId,
			entry.Key,
			meta.Ds,
			meta.TTL,
			meta.Timestamp,
		)
	}
}

// buildSetIdx builds set index when opening the DB.
func (db *DB) buildSetIdx(record *core.Record, entry *core.Entry) error {