Java: Add FUNCTION FLUSH command.

glide-core/src/protobuf/redis_request.proto

@@ -192,6 +192,7 @@ enum RequestType {
     FunctionLoad = 150;
     FunctionList = 151;
     FunctionDelete = 152;
+    FunctionFlush = 153;
     LMPop = 155;
     ExpireTime = 156;
     PExpireTime = 157;

glide-core/src/request_type.rs

@@ -162,6 +162,7 @@ pub enum RequestType {
     FunctionLoad = 150,
     FunctionList = 151,
     FunctionDelete = 152,
+    FunctionFlush = 153,
     LMPop = 155,
     ExpireTime = 156,
     PExpireTime = 157,
@@ -343,6 +344,7 @@ impl From<::protobuf::EnumOrUnknown<ProtobufRequestType>> for RequestType {
             ProtobufRequestType::FunctionLoad => RequestType::FunctionLoad,
             ProtobufRequestType::FunctionList => RequestType::FunctionList,
             ProtobufRequestType::FunctionDelete => RequestType::FunctionDelete,
+            ProtobufRequestType::FunctionFlush => RequestType::FunctionFlush,
             ProtobufRequestType::BitPos => RequestType::BitPos,
             ProtobufRequestType::BitOp => RequestType::BitOp,
             ProtobufRequestType::HStrlen => RequestType::HStrlen,
@@ -521,6 +523,7 @@ impl RequestType {
             RequestType::FunctionLoad => Some(get_two_word_command("FUNCTION", "LOAD")),
             RequestType::FunctionList => Some(get_two_word_command("FUNCTION", "LIST")),
             RequestType::FunctionDelete => Some(get_two_word_command("FUNCTION", "DELETE")),
+            RequestType::FunctionFlush => Some(get_two_word_command("FUNCTION", "FLUSH")),
             RequestType::BitPos => Some(cmd("BITPOS")),
             RequestType::BitOp => Some(cmd("BITOP")),
             RequestType::HStrlen => Some(cmd("HSTRLEN")),

java/client/src/main/java/glide/api/RedisClient.java

@@ -17,6 +17,7 @@
 import static redis_request.RedisRequestOuterClass.RequestType.Echo;
 import static redis_request.RedisRequestOuterClass.RequestType.FlushAll;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionDelete;
+import static redis_request.RedisRequestOuterClass.RequestType.FunctionFlush;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionList;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionLoad;
 import static redis_request.RedisRequestOuterClass.RequestType.Info;
@@ -227,6 +228,18 @@ public CompletableFuture<Map<String, Object>[]> functionList(
                 response -> handleFunctionListResponse(handleArrayResponse(response)));
     }
 
+    @Override
+    public CompletableFuture<String> functionFlush() {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[0], this::handleStringResponse);
+    }
+
+    @Override
+    public CompletableFuture<String> functionFlush(@NonNull FlushMode mode) {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[] {mode.toString()}, this::handleStringResponse);
+    }
+
     @Override
     public CompletableFuture<String> functionDelete(@NonNull String libName) {
         return commandManager.submitNewCommand(

java/client/src/main/java/glide/api/RedisClusterClient.java

@@ -19,6 +19,7 @@
 import static redis_request.RedisRequestOuterClass.RequestType.Echo;
 import static redis_request.RedisRequestOuterClass.RequestType.FlushAll;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionDelete;
+import static redis_request.RedisRequestOuterClass.RequestType.FunctionFlush;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionList;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionLoad;
 import static redis_request.RedisRequestOuterClass.RequestType.Info;
@@ -496,6 +497,30 @@ public CompletableFuture<ClusterValue<Map<String, Object>[]>> functionList(
                 response -> handleFunctionListResponse(response, route));
     }
 
+    @Override
+    public CompletableFuture<String> functionFlush() {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[0], this::handleStringResponse);
+    }
+
+    @Override
+    public CompletableFuture<String> functionFlush(@NonNull FlushMode mode) {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[] {mode.toString()}, this::handleStringResponse);
+    }
+
+    @Override
+    public CompletableFuture<String> functionFlush(@NonNull Route route) {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[0], route, this::handleStringResponse);
+    }
+
+    @Override
+    public CompletableFuture<String> functionFlush(@NonNull FlushMode mode, @NonNull Route route) {
+        return commandManager.submitNewCommand(
+                FunctionFlush, new String[] {mode.toString()}, route, this::handleStringResponse);
+    }
+
     @Override
     public CompletableFuture<String> functionDelete(@NonNull String libName) {
         return commandManager.submitNewCommand(

java/client/src/main/java/glide/api/commands/ScriptingAndFunctionsClusterCommands.java

@@ -2,6 +2,7 @@
 package glide.api.commands;
 
 import glide.api.models.ClusterValue;
+import glide.api.models.commands.FlushMode;
 import glide.api.models.configuration.RequestRoutingConfiguration.Route;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
@@ -168,6 +169,72 @@ CompletableFuture<ClusterValue<Map<String, Object>[]>> functionList(
     CompletableFuture<ClusterValue<Map<String, Object>[]>> functionList(
             String libNamePattern, boolean withCode, Route route);
 
+    /**
+     * Deletes all function libraries.<br>
+     * The command will be routed to all primary nodes.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush().get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush();
+
+    /**
+     * Deletes all function libraries.<br>
+     * The command will be routed to all primary nodes.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @param mode The flushing mode, could be either {@link FlushMode#SYNC} or {@link
+     *     FlushMode#ASYNC}.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush(SYNC).get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush(FlushMode mode);
+
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @param route Specifies the routing configuration for the command. The client will route the
+     *     command to the nodes defined by <code>route</code>.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush(RANDOM).get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush(Route route);
+
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @param mode The flushing mode, could be either {@link FlushMode#SYNC} or {@link
+     *     FlushMode#ASYNC}.
+     * @param route Specifies the routing configuration for the command. The client will route the
+     *     command to the nodes defined by <code>route</code>.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush(SYNC, RANDOM).get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush(FlushMode mode, Route route);
+
     /**
      * Deletes a library and all its functions.<br>
      * The command will be routed to all primary nodes.
@@ -190,8 +257,6 @@ CompletableFuture<ClusterValue<Map<String, Object>[]>> functionList(
      * @since Redis 7.0 and above.
      * @see <a href="https://redis.io/docs/latest/commands/function-delete/">redis.io</a> for details.
      * @param libName The library name to delete.
-     * @param route Specifies the routing configuration for the command. The client will route the
-     *     command to the nodes defined by <code>route</code>.
      * @return <code>OK</code>.
      * @example
      *     <pre>{@code

java/client/src/main/java/glide/api/commands/ScriptingAndFunctionsCommands.java

@@ -1,6 +1,7 @@
 /** Copyright GLIDE-for-Redis Project Contributors - SPDX Identifier: Apache-2.0 */
 package glide.api.commands;
 
+import glide.api.models.commands.FlushMode;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 
@@ -82,6 +83,36 @@ public interface ScriptingAndFunctionsCommands {
      */
     CompletableFuture<Map<String, Object>[]> functionList(String libNamePattern, boolean withCode);
 
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush().get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush();
+
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @param mode The flushing mode, could be either {@link FlushMode#SYNC} or {@link
+     *     FlushMode#ASYNC}.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * String response = client.functionFlush(SYNC).get();
+     * assert response.equals("OK");
+     * }</pre>
+     */
+    CompletableFuture<String> functionFlush(FlushMode mode);
+
     /**
      * Deletes a library and all its functions.
      *

java/client/src/main/java/glide/api/models/BaseTransaction.java

@@ -48,6 +48,7 @@
 import static redis_request.RedisRequestOuterClass.RequestType.ExpireTime;
 import static redis_request.RedisRequestOuterClass.RequestType.FlushAll;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionDelete;
+import static redis_request.RedisRequestOuterClass.RequestType.FunctionFlush;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionList;
 import static redis_request.RedisRequestOuterClass.RequestType.FunctionLoad;
 import static redis_request.RedisRequestOuterClass.RequestType.GeoAdd;
@@ -4140,6 +4141,32 @@ public T bitfieldReadOnly(
         return getThis();
     }
 
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @return Command Response - <code>OK</code>.
+     */
+    public T functionFlush() {
+        protobufTransaction.addCommands(buildCommand(FunctionFlush));
+        return getThis();
+    }
+
+    /**
+     * Deletes all function libraries.
+     *
+     * @since Redis 7.0 and above.
+     * @see <a href="https://redis.io/docs/latest/commands/function-flush/">redis.io</a> for details.
+     * @param mode The flushing mode, could be either {@link FlushMode#SYNC} or {@link
+     *     FlushMode#ASYNC}.
+     * @return Command Response - <code>OK</code>.
+     */
+    public T functionFlush(@NonNull FlushMode mode) {
+        protobufTransaction.addCommands(buildCommand(FunctionFlush, buildArgs(mode.toString())));
+        return getThis();
+    }
+
     /**
      * Deletes a library and all its functions.
      *

java/client/src/main/java/glide/api/models/commands/FlushMode.java

@@ -4,17 +4,27 @@
 import glide.api.RedisClient;
 import glide.api.RedisClusterClient;
 import glide.api.models.configuration.RequestRoutingConfiguration.Route;
+import glide.api.models.configuration.RequestRoutingConfiguration.SingleNodeRoute;
 
+// TODO add links to script flush
 /**
- * Defines flushing mode for <code>FLUSHALL</code> command implemented by {@link
- * RedisClient#flushall(FlushMode)}, {@link RedisClusterClient#flushall(FlushMode)}, and {@link
- * RedisClusterClient#flushall(FlushMode, Route)}.
+ * Defines flushing mode for:
  *
- * @see <a href="https://valkey.io/commands/flushall/">valkey.io</a>
+ * <ul>
+ *   <li><code>FLUSHALL</code> command implemented by {@link RedisClient#flushall(FlushMode)},
+ *       {@link RedisClusterClient#flushall(FlushMode)}, and {@link
+ *       RedisClusterClient#flushall(FlushMode, SingleNodeRoute)}.
+ *   <li><code>FUNCTION FLUSH</code> command implemented by {@link
+ *       RedisClient#functionFlush(FlushMode)}, {@link RedisClusterClient#functionFlush(FlushMode)},
+ *       and {@link RedisClusterClient#functionFlush(FlushMode, Route)}.
+ * </ul>
+ *
+ * @see <a href="https://valkey.io/commands/flushall/">valkey.io</a> and <a
+ *     href="https://valkey.io/commands/function-flush/">valkey.io</a>
  */
 public enum FlushMode {
-    /** Flushes the databases synchronously. */
+    /** Flushes synchronously. */
     SYNC,
-    /** Flushes the databases asynchronously. */
+    /** Flushes asynchronously. */
     ASYNC
 }