Introducing the FT.CREATE command

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

@@ -48,6 +48,8 @@
 import io.lettuce.core.protocol.CommandType;
 import io.lettuce.core.protocol.ProtocolKeyword;
 import io.lettuce.core.protocol.RedisCommand;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
 import reactor.core.publisher.Mono;
 
 import java.time.Duration;
@@ -79,14 +81,17 @@ public abstract class AbstractRedisAsyncCommands<K, V> implements RedisAclAsyncC
         RedisKeyAsyncCommands<K, V>, RedisStringAsyncCommands<K, V>, RedisListAsyncCommands<K, V>, RedisSetAsyncCommands<K, V>,
         RedisSortedSetAsyncCommands<K, V>, RedisScriptingAsyncCommands<K, V>, RedisServerAsyncCommands<K, V>,
         RedisHLLAsyncCommands<K, V>, BaseRedisAsyncCommands<K, V>, RedisTransactionalAsyncCommands<K, V>,
-        RedisGeoAsyncCommands<K, V>, RedisClusterAsyncCommands<K, V>, RedisJsonAsyncCommands<K, V> {
+        RedisGeoAsyncCommands<K, V>, RedisClusterAsyncCommands<K, V>, RedisJsonAsyncCommands<K, V>,
+        RediSearchAsyncCommands<K, V> {
 
     private final StatefulConnection<K, V> connection;
 
     private final RedisCommandBuilder<K, V> commandBuilder;
 
     private final RedisJsonCommandBuilder<K, V> jsonCommandBuilder;
 
+    private final RediSearchCommandBuilder<K, V> searchCommandBuilder;
+
     private final Mono<JsonParser> parser;
 
     /**
@@ -101,6 +106,7 @@ public AbstractRedisAsyncCommands(StatefulConnection<K, V> connection, RedisCode
         this.connection = connection;
         this.commandBuilder = new RedisCommandBuilder<>(codec);
         this.jsonCommandBuilder = new RedisJsonCommandBuilder<>(codec, parser);
+        this.searchCommandBuilder = new RediSearchCommandBuilder<>(codec);
     }
 
     /**
@@ -1478,6 +1484,11 @@ public boolean isOpen() {
         return connection.isOpen();
     }
 
+    @Override
+    public RedisFuture<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields) {
+        return dispatch(searchCommandBuilder.ftCreate(index, options, fields));
+    }
+
     @Override
     public RedisFuture<List<Long>> jsonArrappend(K key, JsonPath jsonPath, JsonValue... values) {
         return dispatch(jsonCommandBuilder.jsonArrappend(key, jsonPath, values));

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

@@ -49,6 +49,8 @@
 import io.lettuce.core.protocol.RedisCommand;
 import io.lettuce.core.protocol.TracedCommand;
 import io.lettuce.core.resource.ClientResources;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
 import io.lettuce.core.tracing.TraceContext;
 import io.lettuce.core.tracing.TraceContextProvider;
 import io.lettuce.core.tracing.Tracing;
@@ -84,19 +86,21 @@
  * @author Tihomir Mateev
  * @since 4.0
  */
-public abstract class AbstractRedisReactiveCommands<K, V>
-        implements RedisAclReactiveCommands<K, V>, RedisHashReactiveCommands<K, V>, RedisKeyReactiveCommands<K, V>,
-        RedisStringReactiveCommands<K, V>, RedisListReactiveCommands<K, V>, RedisSetReactiveCommands<K, V>,
-        RedisSortedSetReactiveCommands<K, V>, RedisScriptingReactiveCommands<K, V>, RedisServerReactiveCommands<K, V>,
-        RedisHLLReactiveCommands<K, V>, BaseRedisReactiveCommands<K, V>, RedisTransactionalReactiveCommands<K, V>,
-        RedisGeoReactiveCommands<K, V>, RedisClusterReactiveCommands<K, V>, RedisJsonReactiveCommands<K, V> {
+public abstract class AbstractRedisReactiveCommands<K, V> implements RedisAclReactiveCommands<K, V>,
+        RedisHashReactiveCommands<K, V>, RedisKeyReactiveCommands<K, V>, RedisStringReactiveCommands<K, V>,
+        RedisListReactiveCommands<K, V>, RedisSetReactiveCommands<K, V>, RedisSortedSetReactiveCommands<K, V>,
+        RedisScriptingReactiveCommands<K, V>, RedisServerReactiveCommands<K, V>, RedisHLLReactiveCommands<K, V>,
+        BaseRedisReactiveCommands<K, V>, RedisTransactionalReactiveCommands<K, V>, RedisGeoReactiveCommands<K, V>,
+        RedisClusterReactiveCommands<K, V>, RedisJsonReactiveCommands<K, V>, RediSearchReactiveCommands<K, V> {
 
     private final StatefulConnection<K, V> connection;
 
     private final RedisCommandBuilder<K, V> commandBuilder;
 
     private final RedisJsonCommandBuilder<K, V> jsonCommandBuilder;
 
+    private final RediSearchCommandBuilder<K, V> searchCommandBuilder;
+
     private final Mono<JsonParser> parser;
 
     private final ClientResources clientResources;
@@ -117,6 +121,7 @@ public AbstractRedisReactiveCommands(StatefulConnection<K, V> connection, RedisC
         this.parser = parser;
         this.commandBuilder = new RedisCommandBuilder<>(codec);
         this.jsonCommandBuilder = new RedisJsonCommandBuilder<>(codec, parser);
+        this.searchCommandBuilder = new RediSearchCommandBuilder<>(codec);
         this.clientResources = connection.getResources();
         this.tracingEnabled = clientResources.tracing().isEnabled();
     }
@@ -1543,6 +1548,11 @@ public boolean isOpen() {
         return connection.isOpen();
     }
 
+    @Override
+    public Mono<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields) {
+        return createMono(() -> searchCommandBuilder.ftCreate(index, options, fields));
+    }
+
     @Override
     public Flux<Long> jsonArrappend(K key, JsonPath jsonPath, JsonValue... values) {
         return createDissolvingFlux(() -> jsonCommandBuilder.jsonArrappend(key, jsonPath, values));

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

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core;
+
+import io.lettuce.core.codec.RedisCodec;
+import io.lettuce.core.output.StatusOutput;
+import io.lettuce.core.protocol.BaseRedisCommandBuilder;
+import io.lettuce.core.protocol.Command;
+import io.lettuce.core.protocol.CommandArgs;
+import io.lettuce.core.protocol.CommandKeyword;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+import io.lettuce.core.search.Field;
+
+import static io.lettuce.core.protocol.CommandType.*;
+
+/**
+ * Command builder for RediSearch commands.
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @since 6.6
+ */
+class RediSearchCommandBuilder<K, V> extends BaseRedisCommandBuilder<K, V> {
+
+    RediSearchCommandBuilder(RedisCodec<K, V> codec) {
+        super(codec);
+    }
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param createArgs the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    public Command<K, V, String> ftCreate(K index, CreateArgs<K, V> createArgs, Fields<K> fields) {
+        notNullKey(index);
+        notEmpty(fields.getFields().toArray());
+
+        CommandArgs<K, V> args = new CommandArgs<>(codec).addKey(index);
+
+        if (createArgs != null) {
+            createArgs.build(args);
+        }
+
+        args.add(CommandKeyword.SCHEMA);
+
+        for (Field<K> field : fields.getFields()) {
+            field.build(args);
+        }
+
+        return createCommand(FT_CREATE, new StatusOutput<>(codec), args);
+
+    }
+
+}

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

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core.api.async;
+
+import io.lettuce.core.RedisFuture;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+
+/**
+ * Asynchronous executed commands for RediSearch functionality
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @author Tihomir Mateev
+ * @see <a href="https://redis.io/docs/latest/operate/oss_and_stack/stack-with-enterprise/search/">RediSearch</a>
+ * @since 6.6
+ * @generated by io.lettuce.apigenerator.CreateAsyncApi
+ */
+public interface RediSearchAsyncCommands<K, V> {
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param options the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    RedisFuture<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields);
+
+}

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

@@ -37,7 +37,7 @@ public interface RedisAsyncCommands<K, V> extends BaseRedisAsyncCommands<K, V>,
         RedisHashAsyncCommands<K, V>, RedisHLLAsyncCommands<K, V>, RedisKeyAsyncCommands<K, V>, RedisListAsyncCommands<K, V>,
         RedisScriptingAsyncCommands<K, V>, RedisServerAsyncCommands<K, V>, RedisSetAsyncCommands<K, V>,
         RedisSortedSetAsyncCommands<K, V>, RedisStreamAsyncCommands<K, V>, RedisStringAsyncCommands<K, V>,
-        RedisTransactionalAsyncCommands<K, V>, RedisJsonAsyncCommands<K, V> {
+        RedisTransactionalAsyncCommands<K, V>, RedisJsonAsyncCommands<K, V>, RediSearchAsyncCommands<K, V> {
 
     /**
      * Authenticate to the server.

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

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core.api.reactive;
+
+import io.lettuce.core.search.Field;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+import reactor.core.publisher.Mono;
+
+/**
+ * Reactive executed commands for RediSearch functionality
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @author Tihomir Mateev
+ * @see <a href="https://redis.io/docs/latest/operate/oss_and_stack/stack-with-enterprise/search/">RediSearch</a>
+ * @since 6.6
+ * @generated by io.lettuce.apigenerator.CreateReactiveApi
+ */
+public interface RediSearchReactiveCommands<K, V> {
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param options the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    Mono<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields);
+
+}

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

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core.api.sync;
+
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+
+/**
+ * Synchronous executed commands for RediSearch functionality
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @author Tihomir Mateev
+ * @see <a href="https://redis.io/docs/latest/operate/oss_and_stack/stack-with-enterprise/search/">RediSearch</a>
+ * @since 6.6
+ * @generated by io.lettuce.apigenerator.CreateSyncApi
+ */
+public interface RediSearchCommands<K, V> {
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param options the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    String ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields);
+
+}

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

@@ -36,7 +36,7 @@ public interface RedisCommands<K, V> extends BaseRedisCommands<K, V>, RedisAclCo
         RedisFunctionCommands<K, V>, RedisGeoCommands<K, V>, RedisHashCommands<K, V>, RedisHLLCommands<K, V>,
         RedisKeyCommands<K, V>, RedisListCommands<K, V>, RedisScriptingCommands<K, V>, RedisServerCommands<K, V>,
         RedisSetCommands<K, V>, RedisSortedSetCommands<K, V>, RedisStreamCommands<K, V>, RedisStringCommands<K, V>,
-        RedisTransactionalCommands<K, V>, RedisJsonCommands<K, V> {
+        RedisTransactionalCommands<K, V>, RedisJsonCommands<K, V>, RediSearchCommands<K, V> {
 
     /**
      * Authenticate to the server.

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

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core.cluster.api.async;
+
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+
+/**
+ * Asynchronous executed commands on a node selection for RediSearch functionality
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @author Tihomir Mateev
+ * @see <a href="https://redis.io/docs/latest/operate/oss_and_stack/stack-with-enterprise/search/">RediSearch</a>
+ * @since 6.6
+ * @generated by io.lettuce.apigenerator.CreateAsyncNodeSelectionClusterApi
+ */
+public interface RediSearchAsyncCommands<K, V> {
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param options the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    AsyncExecutions<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields);
+
+}

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

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2025, Redis Ltd. and Contributors
+ * All rights reserved.
+ *
+ * Licensed under the MIT License.
+ */
+package io.lettuce.core.cluster.api.sync;
+
+import io.lettuce.core.search.Field;
+import io.lettuce.core.search.Fields;
+import io.lettuce.core.search.arguments.CreateArgs;
+
+/**
+ * Synchronous executed commands on a node selection for RediSearch functionality
+ *
+ * @param <K> Key type.
+ * @param <V> Value type.
+ * @author Tihomir Mateev
+ * @see <a href="https://redis.io/docs/latest/operate/oss_and_stack/stack-with-enterprise/search/">RediSearch</a>
+ * @since 6.6
+ * @generated by io.lettuce.apigenerator.CreateSyncNodeSelectionClusterApi
+ */
+public interface RediSearchCommands<K, V> {
+
+    /**
+     * Create a new index with the given name, index options and fields.
+     *
+     * @param index the index name
+     * @param options the index options
+     * @param fields the fields
+     * @return the result of the create command
+     */
+    Executions<String> ftCreate(K index, CreateArgs<K, V> options, Fields<K> fields);
+
+}

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

@@ -34,6 +34,7 @@
  * @param <V> Value type.
  * @author Mark Paluch
  * @author dengliming
+ * @author Tihomir Mateev
  * @since 4.0
  */
 public interface RedisClusterCommands<K, V>

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

@@ -49,7 +49,11 @@ public enum CommandKeyword implements ProtocolKeyword {
 
     MIGRATING, IMPORTING, SAVE, SKIPME, SLAVES, STREAM, STORE, SUM, SEGFAULT, SETUSER, TAKEOVER, TRACKING, TRACKINGINFO, TYPE, UNBLOCK, USERS, USAGE, WEIGHTS, WHOAMI,
 
-    WITHMATCHLEN, WITHSCORE, WITHSCORES, WITHVALUES, XOR, XX, YES, INDENT, NEWLINE, SPACE, GT, LT;
+    WITHMATCHLEN, WITHSCORE, WITHSCORES, WITHVALUES, XOR, XX, YES, INDENT, NEWLINE, SPACE, GT, LT,
+
+    MAXTEXTFIELDS, PREFIX, FILTER, LANGUAGE, LANGUAGE_FIELD, SCORE, SCORE_FIELD, PAYLOAD_FIELD, TEMPORARY, NOOFFSETS, NOHL, NOFIELDS, NOFREQS, SKIPINITIALSCAN, STOPWORDS, AS, SORTABLE, SCHEMA, UNF, NOINDEX,
+
+    NOSTEM, PHONETIC, WEIGHT, SEPARATOR, CASESENSITIVE, WITHSUFFIXTRIE, INDEXEMPTY, INDEXMISSING;
 
     public final byte[] bytes;
 

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

@@ -112,6 +112,9 @@ public enum CommandType implements ProtocolKeyword {
                                     "JSON.OBJLEN"), JSON_SET("JSON.SET"), JSON_STRAPPEND("JSON.STRAPPEND"), JSON_STRLEN(
                                             "JSON.STRLEN"), JSON_TOGGLE("JSON.TOGGLE"), JSON_TYPE("JSON.TYPE"),
 
+    // RediSearch
+    FT_CREATE("FT.CREATE"),
+
     // Others
 
     TIME, WAIT,