Implement HEXPIRE, HEXPIREAT, HEXPIRETIME and HPERSIST

src/main/java/io/lettuce/core/AbstractRedisAsyncCommands.java

@@ -794,6 +794,27 @@ public RedisFuture<Boolean> expire(K key, Duration seconds, ExpireArgs expireArg
         return expire(key, seconds.toMillis() / 1000, expireArgs);
     }
 
+    @Override
+    public RedisFuture<Boolean> hexpire(K key, long seconds, List<V> fields) {
+        return hexpire(key, seconds, null, fields);
+    }
+
+    @Override
+    public RedisFuture<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields) {
+        return dispatch(commandBuilder.hexpire(key, seconds, expireArgs, fields));
+    }
+
+    @Override
+    public RedisFuture<Boolean> hexpire(K key, Duration seconds, List<V> fields) {
+        return hexpire(key, seconds, null, fields);
+    }
+
+    @Override
+    public RedisFuture<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields) {
+        LettuceAssert.notNull(seconds, "Timeout must not be null");
+        return hexpire(key, seconds.toMillis() / 1000, expireArgs, fields);
+    }
+
     @Override
     public RedisFuture<Boolean> expireat(K key, long timestamp) {
         return expireat(key, timestamp, null);

src/main/java/io/lettuce/core/AbstractRedisReactiveCommands.java

@@ -854,6 +854,27 @@ public Mono<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs) {
         return expire(key, seconds.toMillis() / 1000, expireArgs);
     }
 
+    @Override
+    public Mono<Boolean> hexpire(K key, long seconds, List<V> fields) {
+        return hexpire(key, seconds, null, fields);
+    }
+
+    @Override
+    public Mono<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields) {
+        return createMono(() -> commandBuilder.hexpire(key, seconds, expireArgs, fields));
+    }
+
+    @Override
+    public Mono<Boolean> hexpire(K key, Duration seconds, List<V> fields) {
+        return hexpire(key, seconds, null, fields);
+    }
+
+    @Override
+    public Mono<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields) {
+        LettuceAssert.notNull(seconds, "Timeout must not be null");
+        return hexpire(key, seconds.toMillis() / 1000, expireArgs, fields);
+    }
+
     @Override
     public Mono<Boolean> expireat(K key, long timestamp) {
         return expireat(key, timestamp, null);

src/main/java/io/lettuce/core/RedisCommandBuilder.java

@@ -978,6 +978,23 @@ Command<K, V, Boolean> expire(K key, long seconds, ExpireArgs expireArgs) {
         return createCommand(EXPIRE, new BooleanOutput<>(codec), args);
     }
 
+    Command<K, V, Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields) {
+        notNullKey(key);
+        notEmpty(fields == null ? new Object[]{} : fields.toArray());
+
+        CommandArgs<K, V> args = new CommandArgs<>(codec).addKey(key).add(seconds);
+
+        if (expireArgs != null) {
+            expireArgs.build(args);
+        }
+
+        args.add(fields.size());
+
+        fields.forEach(args::addValue);
+
+        return createCommand(HEXPIRE, new BooleanOutput<>(codec), args);
+    }
+
     Command<K, V, Boolean> expireat(K key, long timestamp, ExpireArgs expireArgs) {
         notNullKey(key);
 

src/main/java/io/lettuce/core/api/async/RedisKeyAsyncCommands.java

@@ -137,6 +137,56 @@ public interface RedisKeyAsyncCommands<K, V> {
      */
     RedisFuture<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs);
 
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    RedisFuture<Boolean> hexpire(K key, long seconds, List<V> fields);
+
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param expireArgs the expire arguments.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    RedisFuture<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    RedisFuture<Boolean> hexpire(K key, Duration seconds, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param expireArgs the {@link ExpireArgs}.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    RedisFuture<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields);
+
     /**
      * Set the expiration for a key as a UNIX timestamp.
      *

src/main/java/io/lettuce/core/api/reactive/RedisKeyReactiveCommands.java

@@ -22,6 +22,7 @@
 import java.time.Duration;
 import java.time.Instant;
 import java.util.Date;
+import java.util.List;
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -147,6 +148,56 @@ public interface RedisKeyReactiveCommands<K, V> {
      */
     Mono<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs);
 
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Mono<Boolean> hexpire(K key, long seconds, List<V> fields);
+
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param expireArgs the expire arguments.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Mono<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Mono<Boolean> hexpire(K key, Duration seconds, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param expireArgs the {@link ExpireArgs}.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Mono<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields);
+
     /**
      * Set the expiration for a key as a UNIX timestamp.
      *

src/main/java/io/lettuce/core/api/sync/RedisKeyCommands.java

@@ -146,6 +146,56 @@ public interface RedisKeyCommands<K, V> {
      */
     Boolean expire(K key, Duration seconds, ExpireArgs expireArgs);
 
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Boolean hexpire(K key, long seconds, List<V> fields);
+
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param expireArgs the expire arguments.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Boolean hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Boolean hexpire(K key, Duration seconds, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param expireArgs the {@link ExpireArgs}.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Boolean hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields);
+
     /**
      * Set the expiration for a key as a UNIX timestamp.
      *

src/main/java/io/lettuce/core/cluster/api/async/NodeSelectionKeyAsyncCommands.java

@@ -146,6 +146,56 @@ public interface NodeSelectionKeyAsyncCommands<K, V> {
      */
     AsyncExecutions<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs);
 
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    AsyncExecutions<Boolean> hexpire(K key, long seconds, List<V> fields);
+
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param expireArgs the expire arguments.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    AsyncExecutions<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    AsyncExecutions<Boolean> hexpire(K key, Duration seconds, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param expireArgs the {@link ExpireArgs}.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    AsyncExecutions<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields);
+
     /**
      * Set the expiration for a key as a UNIX timestamp.
      *

src/main/java/io/lettuce/core/cluster/api/sync/NodeSelectionKeyCommands.java

@@ -146,6 +146,56 @@ public interface NodeSelectionKeyCommands<K, V> {
      */
     Executions<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs);
 
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Executions<Boolean> hexpire(K key, long seconds, List<V> fields);
+
+    /**
+     * Set the time to live (in seconds) for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key of the fields.
+     * @param seconds the seconds type: long.
+     * @param expireArgs the expire arguments.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Executions<Boolean> hexpire(K key, long seconds, ExpireArgs expireArgs, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Executions<Boolean> hexpire(K key, Duration seconds, List<V> fields);
+
+    /**
+     * Set the time to live for a {@link List} of fields, belonging to a certain key.
+     *
+     * @param key the key.
+     * @param seconds the TTL {@link Duration}
+     * @param expireArgs the {@link ExpireArgs}.
+     * @param fields a {@link List} of fields to set the TTL for.
+     * @return Boolean integer-reply specifically: {@code true} if the timeout was set. {@code false} if {@code key} does not
+     *         exist or the timeout could not be set.
+     * @since 7.0
+     */
+    Executions<Boolean> hexpire(K key, Duration seconds, ExpireArgs expireArgs, List<V> fields);
+
     /**
      * Set the expiration for a key as a UNIX timestamp.
      *

src/main/java/io/lettuce/core/protocol/CommandType.java

@@ -46,7 +46,7 @@ public enum CommandType implements ProtocolKeyword {
 
     // Keys
 
-    COPY, DEL, DUMP, EXISTS, EXPIRE, EXPIREAT, EXPIRETIME, KEYS, MIGRATE, MOVE, OBJECT, PERSIST, PEXPIRE, PEXPIREAT, PEXPIRETIME, PTTL, RANDOMKEY, RENAME, RENAMENX, RESTORE, TOUCH, TTL, TYPE, SCAN, UNLINK,
+    COPY, DEL, DUMP, EXISTS, HEXPIRE, EXPIRE, EXPIREAT, EXPIRETIME, KEYS, MIGRATE, MOVE, OBJECT, PERSIST, PEXPIRE, PEXPIREAT, PEXPIRETIME, PTTL, RANDOMKEY, RENAME, RENAMENX, RESTORE, TOUCH, TTL, TYPE, SCAN, UNLINK,
 
     // String