Add field expiration options to reactive API.

Make sure tests do not run when targeting older server versions.

Introduce dedicated objects for time to live and status changes.

See spring-projects#3054

Author: christophstrobl

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -30,6 +30,7 @@
 import org.springframework.data.geo.Metric;
 import org.springframework.data.geo.Point;
 import org.springframework.data.redis.RedisSystemException;
+import org.springframework.data.redis.connection.Hash.FieldExpirationOptions;
 import org.springframework.data.redis.connection.convert.Converters;
 import org.springframework.data.redis.connection.convert.ListConverter;
 import org.springframework.data.redis.connection.convert.MapConverter;
@@ -2571,6 +2572,11 @@ public Long hStrLen(byte[] key, byte[] field) {
 		return convertAndReturn(delegate.hStrLen(key, field), Converters.identityConverter());
 	}
 
+	public @Nullable List<Long> expireHashField(byte[] key, org.springframework.data.redis.core.types.Expiration expiration,
+		FieldExpirationOptions options, byte[]... fields) {
+		return this.delegate.expireHashField(key, expiration, options, fields);
+	}
+
 	@Override
 	public List<Long> hExpire(byte[] key, long seconds, byte[]... fields) {
 		return this.delegate.hExpire(key, seconds, fields);
@@ -2601,11 +2607,21 @@ public List<Long> hTtl(byte[] key, byte[]... fields) {
 		return this.delegate.hTtl(key, fields);
 	}
 
+	@Override
+	public List<Long> hpTtl(byte[] key, byte[]... fields) {
+		return this.delegate.hpTtl(key, fields);
+	}
+
 	@Override
 	public List<Long> hTtl(byte[] key, TimeUnit timeUnit, byte[]... fields) {
 		return this.delegate.hTtl(key, timeUnit, fields);
 	}
 
+	public @Nullable List<Long> expireHashField(String key, org.springframework.data.redis.core.types.Expiration expiration,
+		FieldExpirationOptions options, String... fields) {
+		return expireHashField(serialize(key), expiration, options, serializeMulti(fields));
+	}
+
 	@Override
 	public List<Long> hExpire(String key, long seconds, String... fields) {
 		return hExpire(serialize(key), seconds, serializeMulti(fields));
@@ -2641,6 +2657,11 @@ public List<Long> hTtl(String key, TimeUnit timeUnit, String... fields) {
 		return hTtl(serialize(key), timeUnit, serializeMulti(fields));
 	}
 
+	@Override
+	public List<Long> hpTtl(String key, String... fields) {
+		return hTtl(serialize(key), serializeMulti(fields));
+	}
+
 	@Override
 	public void setClientName(byte[] name) {
 		this.delegate.setClientName(name);

src/main/java/org/springframework/data/redis/connection/DefaultedRedisConnection.java

@@ -28,6 +28,7 @@
 import org.springframework.data.geo.GeoResults;
 import org.springframework.data.geo.Metric;
 import org.springframework.data.geo.Point;
+import org.springframework.data.redis.connection.Hash.FieldExpirationOptions;
 import org.springframework.data.redis.connection.stream.ByteRecord;
 import org.springframework.data.redis.connection.stream.Consumer;
 import org.springframework.data.redis.connection.stream.MapRecord;
@@ -1527,6 +1528,21 @@ default List<Long> hTtl(byte[] key, TimeUnit timeUnit, byte[]... fields) {
 		return hashCommands().hTtl(key, timeUnit, fields);
 	}
 
+	/** @deprecated in favor of {@link RedisConnection#hashCommands()}}. */
+	@Override
+	@Deprecated
+	default List<Long> hpTtl(byte[] key, byte[]... fields) {
+		return hashCommands().hpTtl(key, fields);
+	}
+
+	/** @deprecated in favor of {@link RedisConnection#hashCommands()}}. */
+	@Override
+	@Deprecated
+	default @Nullable List<Long> expireHashField(byte[] key, org.springframework.data.redis.core.types.Expiration expiration,
+		FieldExpirationOptions options, byte[]... fields) {
+		return hashCommands().expireHashField(key, expiration, options, fields);
+	}
+
 	// GEO COMMANDS
 
 	/** @deprecated in favor of {@link RedisConnection#geoCommands()}}. */

src/main/java/org/springframework/data/redis/connection/Hash.java

@@ -0,0 +1,115 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.redis.connection;
+
+import java.util.Objects;
+
+import org.springframework.lang.Contract;
+import org.springframework.lang.Nullable;
+import org.springframework.util.ObjectUtils;
+
+/**
+ * @author Christoph Strobl
+ * @since 3.5
+ */
+public interface Hash {
+
+	class FieldExpirationOptions {
+
+		private static final FieldExpirationOptions NONE = new FieldExpirationOptions(null);
+		private @Nullable Condition condition;
+
+		FieldExpirationOptions(@Nullable Condition condition) {
+			this.condition = condition;
+		}
+
+		public static FieldExpirationOptions none() {
+			return NONE;
+		}
+
+		@Contract("_ -> new")
+		public static FieldExpireOptionsBuilder builder() {
+			return new FieldExpireOptionsBuilder();
+		}
+
+		public @Nullable Condition getCondition() {
+			return condition;
+		}
+
+		@Override
+		public boolean equals(Object o) {
+			if (o == this) {
+				return true;
+			}
+			if (o == null || getClass() != o.getClass()) {
+				return false;
+			}
+			FieldExpirationOptions that = (FieldExpirationOptions) o;
+			return ObjectUtils.nullSafeEquals(this.condition, that.condition);
+		}
+
+		@Override
+		public int hashCode() {
+			return Objects.hash(condition);
+		}
+
+		public static class FieldExpireOptionsBuilder {
+
+			@Nullable Condition condition;
+
+			@Contract("_ -> this")
+			public FieldExpireOptionsBuilder nx() {
+				this.condition = Condition.NX;
+				return this;
+			}
+
+			@Contract("_ -> this")
+			public FieldExpireOptionsBuilder xx() {
+				this.condition = Condition.XX;
+				return this;
+			}
+
+			@Contract("_ -> this")
+			public FieldExpireOptionsBuilder gt() {
+				this.condition = Condition.GT;
+				return this;
+			}
+
+			@Contract("_ -> this")
+			public FieldExpireOptionsBuilder lt() {
+				this.condition = Condition.LT;
+				return this;
+			}
+
+			@Contract("_ -> !null")
+			public FieldExpirationOptions build() {
+				return condition == null ? NONE : new FieldExpirationOptions(condition);
+			}
+		}
+
+		public enum Condition {
+
+			/** Set expiration only when the field has no expiration. */
+			NX,
+			/** Set expiration only when the field has an existing expiration. */
+			XX,
+			/** Set expiration only when the new expiration is greater than current one. */
+			GT,
+			/** Set expiration only when the new expiration is greater than current one. */
+			LT
+		}
+	}
+}