Method registerKeysForActiveExpiration

tx.go:908–932

registerKeysForActiveExpiration registers keys with TTL in the timing wheel for active expiration.

(records []*core.Record, entries []*core.Entry)

// registerKeysForActiveExpiration registers keys with TTL in the timing wheel for active expiration.
func (tx *Tx) registerKeysForActiveExpiration(records []*core.Record, entries []*core.Entry) {
	if tx.db.ttlService == nil {
		return
	}

	for i, entry := range entries {
		meta := entry.Meta

		if meta.TTL > 0 && meta.Flag != DataDeleteFlag {
			record := records[i]

			if tx.db.ttlService.IsExpired(record.TTL, record.Timestamp) {
				continue
			}

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