Merge branch 'main' into preview-rc-rdi

Author: cmilesb

.github/workflows/main-staging.yml

@@ -66,6 +66,10 @@ jobs:
         rs_versions=($(find content/operate/rs/ -maxdepth 1 -type d -regex ".*[0-9-]" | awk -F/ '{print $NF}'))
         rdi_versions=($(find content/integrate/redis-data-integration/ -maxdepth 1 -type d -regex ".*[0-9-]" | awk -F/ '{print $NF}'))
 
+        printf "%s\n" "${kubernetes_versions[@]}" > kubernetes-versions
+        printf "%s\n" "${rs_versions[@]}" > rs-versions
+        printf "%s\n" "${rdi_versions[@]}" > rdi-versions
+
         # build latest
         for version in "${kubernetes_versions[@]}"; do
           rm -r "content/operate/kubernetes/${version}"

.github/workflows/main.yml

@@ -66,6 +66,10 @@ jobs:
         rs_versions=($(find content/operate/rs/ -maxdepth 1 -type d -regex ".*[0-9-]" | awk -F/ '{print $NF}'))
         rdi_versions=($(find content/integrate/redis-data-integration/ -maxdepth 1 -type d -regex ".*[0-9-]" | awk -F/ '{print $NF}'))
 
+        printf "%s\n" "${kubernetes_versions[@]}" > kubernetes-versions
+        printf "%s\n" "${rs_versions[@]}" > rs-versions
+        printf "%s\n" "${rdi_versions[@]}" > rdi-versions
+
         # build latest
         for version in "${kubernetes_versions[@]}"; do
           rm -r "content/operate/kubernetes/${version}"

build/local_examples.py

@@ -51,6 +51,24 @@ def get_client_name_from_language(language: str) -> str:
     return LANGUAGE_TO_CLIENT.get(language, language.title())
 
 
+def get_client_name_from_language_and_path(language: str, path: str) -> str:
+    """Get client name from language with path-based overrides.
+
+    For Java (.java) files, override based on path substrings:
+    - If 'lettuce-async' in path -> Java-Async
+    - If 'lettuce-reactive' in path -> Java-Reactive
+
+    Substring checks are case-sensitive and can appear anywhere in the path.
+    """
+    if language == 'java':
+        if 'lettuce-async' in path:
+            return 'Java-Async'
+        if 'lettuce-reactive' in path:
+            return 'Java-Reactive'
+    # Default behavior for all languages (and Java fallback)
+    return get_client_name_from_language(language)
+
+
 def get_example_id_from_file(path: str) -> str:
     """Extract example ID from the first line of a file."""
     try:
@@ -136,8 +154,8 @@ def process_local_examples(local_examples_dir: str = 'local_examples',
             # Process with Example class
             example = Example(language, target_file)
 
-            # Get client name
-            client_name = get_client_name_from_language(language)
+            # Get client name (with Java path-based overrides)
+            client_name = get_client_name_from_language_and_path(language, source_file)
 
             # Create metadata
             example_metadata = {

build/version_archiver.py

@@ -8,8 +8,10 @@ def __init__(self, product, version):
 
         if self.product in ("kubernetes", "rs"):
             self.prefix = "operate"
-        else:
+        elif self.product in ("redis-data-integration"):
             self.prefix = "integrate"
+        elif self.product in ("redisvl"):
+            self.prefix = "develop/ai"
         self.new_directory = os.path.join("content",self.prefix,self.product,self.new_version)
         self.latest = os.path.join("content",self.prefix,self.product)
 
@@ -179,9 +181,9 @@ def inject_url_frontmatter(self):
 
 def validate_product(value):
     """Custom validator for product argument to allow only 'rs' or 'kubernetes'"""
-    if value not in ["rs", "kubernetes", "redis-data-integration"]:
+    if value not in ["rs", "kubernetes", "redis-data-integration", "redisvl"]:
         raise argparse.ArgumentTypeError(
-            "Product must be either 'rs' or 'kubernetes' or 'redis-data-integration'."
+            "Product must be either 'rs' or 'kubernetes' or 'redis-data-integration' or 'redisvl'. "
         )
     return value
 
@@ -204,16 +206,24 @@ def validate_version(value):
     parser.add_argument(
         "product",
         type=validate_product,
-        help="The name of the product (e.g., rs, kubernetes, redis-data-integration)",
+        help="The name of the product (e.g., rs, kubernetes, redis-data-integration, redisvl)",
     )
     parser.add_argument(
         "version",
         type=validate_version,
         help="The release version (e.g., 7, 7.1, 7.1.11)",
     )
+    parser.add_argument(
+        "--skip-archive",
+        action="store_true",
+        default=False,
+        help="Only update relrefs and inject URL frontmatter"
+    )
     args = parser.parse_args()
 
     r = VersionArchiver(args.product, args.version)
-    r.archive_version()
+    if not args.skip_archive:
+        r.archive_version()
+
     r.version_relrefs()
     r.inject_url_frontmatter()

config.toml

@@ -55,7 +55,7 @@ rdi_redis_gears_version = "1.2.6"
 rdi_debezium_server_version = "2.3.0.Final"
 rdi_db_types = "cassandra|mysql|oracle|postgresql|sqlserver"
 rdi_cli_latest = "latest"
-rdi_current_version = "1.12.3"
+rdi_current_version = "1.14.0"
 
 [params.clientsConfig]
 "Python"={quickstartSlug="redis-py"}

content/commands/info.md

@@ -551,14 +551,14 @@ _Redis Query Engine fields_
 *   `search_fields_geoshape_Sortable`: The total number of `SORTABLE GEOSHAPE` fields across all indexes in the shard. This field appears only if its value is larger than 0. <sup>[2](#tnote-2)</sup>
 *   `search_fields_geoshape_NoIndex`: The total number of `NOINDEX GEOSHAPE` fields across all indexes in the shard; i.e., used for sorting only but not indexed. This field appears only if its value is larger than 0. <sup>[2](#tnote-2)</sup>
 *   `search_fields_<field>_IndexErrors`: The total number of indexing failures caused by attempts to index a document containing <field> field. <sup>[1](#tnote-1)</sup>
-*   `search_used_memory_indexes`: The total memory allocated by all indexes in the shard in bytes. <sup>[1](#tnote-1)</sup>
-*   `search_used_memory_indexes_human`: The total memory allocated by all indexes in the shard in MB. <sup>[1](#tnote-1)</sup>
-*   `search_smallest_memory_index`: The memory usage of the index with the smallest memory usage in the shard in bytes. <sup>[1](#tnote-1)</sup>
-*   `search_smallest_memory_index_human`: The memory usage of the index with the smallest memory usage in the shard in MB. <sup>[1](#tnote-1)</sup>
-*   `search_largest_memory_index`: The memory usage of the index with the largest memory usage in the shard in bytes. <sup>[1](#tnote-1)</sup>
-*   `search_largest_memory_index_human`: The memory usage of the index with the largest memory usage in the shard in MB. <sup>[1](#tnote-1)</sup>
-*   `search_total_indexing_time`: The total time spent on indexing operations, excluding the background indexing of vectors in the HNSW graph. <sup>[1](#tnote-1)</sup>
 *   `search_used_memory_vector_index`: The total memory usage of all vector indexes in the shard. <sup>[1](#tnote-1)</sup>
+*   `search_used_memory_indexes`: The estimated total memory allocated by all indexes in the shard in bytes (including vector indexes memory accounted in `search_used_memory_vector_index`). <sup>[1](#tnote-1)</sup>
+*   `search_used_memory_indexes_human`: The estimated total memory allocated by all indexes in the shard in MB. <sup>[1](#tnote-1)</sup>
+*   `search_smallest_memory_index`: The estimated memory usage of the index with the smallest memory usage in the shard in bytes. <sup>[1](#tnote-1)</sup>
+*   `search_smallest_memory_index_human`: The estimated memory usage of the index with the smallest memory usage in the shard in MB. <sup>[1](#tnote-1)</sup>
+*   `search_largest_memory_index`: The estimated memory usage of the index with the largest memory usage in the shard in bytes. <sup>[1](#tnote-1)</sup>
+*   `search_largest_memory_index_human`: The estimated memory usage of the index with the largest memory usage in the shard in MB. <sup>[1](#tnote-1)</sup>
+*   `search_total_indexing_time`: The total time spent on indexing operations, excluding the background indexing of vectors in the HNSW graph. <sup>[1](#tnote-1)</sup>
 *   `search_bytes_collected`: The total amount of memory freed by the garbage collectors from indexes in the shard memory in bytes. <sup>[1](#tnote-1)</sup>
 *   `search_total_cycles`: The total number of garbage collection cycles executed. <sup>[1](#tnote-1)</sup>
 *   `search_total_ms_run`: The total duration of all garbage collection cycles in the shard, measured in milliseconds. <sup>[1](#tnote-1)</sup>

content/commands/set.md

@@ -180,18 +180,20 @@ The script should be called with `EVAL ...script... 1 resource-name token-value`
     tab1="RESP2" 
     tab2="RESP3" >}}
 
-Any of the following:
-* [Nil reply](../../develop/reference/protocol-spec#bulk-strings): `GET` not given: Operation was aborted (conflict with one of the `XX`/`NX` options).
-* [Simple string reply](../../develop/reference/protocol-spec#simple-strings): `OK`. `GET` not given: The key was set.
-* [Nil reply](../../develop/reference/protocol-spec#bulk-strings): `GET` given: The key didn't exist before the `SET`.
-* [Bulk string reply](../../develop/reference/protocol-spec#bulk-strings): `GET` given: The previous value of the key.
+* If `GET` was not specified, any of the following:
+  * [Nil reply](../../develop/reference/protocol-spec#bulk-strings): Operation was aborted (conflict with one of the `XX`/`NX` options). The key was not set.
+  * [Simple string reply](../../develop/reference/protocol-spec#simple-strings): `OK`: The key was set.
+* If `GET` was specified, any of the following:
+  * [Nil reply](../../develop/reference/protocol-spec#bulk-strings): The key didn't exist before the `SET`. If `XX` was specified, the key was not set. Otherwise, the key was set.
+  * [Bulk string reply](../../develop/reference/protocol-spec#bulk-strings): The previous value of the key. If `NX` was specified, the key was not set. Otherwise, the key was set.
 
 -tab-sep-
 
-Any of the following:
-* [Null reply](../../develop/reference/protocol-spec#nulls): `GET` not given: Operation was aborted (conflict with one of the `XX`/`NX` options).
-* [Simple string reply](../../develop/reference/protocol-spec#simple-strings): `OK`. `GET` not given: The key was set.
-* [Null reply](../../develop/reference/protocol-spec#nulls): `GET` given: The key didn't exist before the `SET`.
-* [Bulk string reply](../../develop/reference/protocol-spec#bulk-strings): `GET` given: The previous value of the key.
+* If `GET` was not specified, any of the following:
+  * [Null reply](../../develop/reference/protocol-spec#nulls): Operation was aborted (conflict with one of the `XX`/`NX` options). The key was not set.
+  * [Simple string reply](../../develop/reference/protocol-spec#simple-strings): `OK`: The key was set.
+* If `GET` was specified, any of the following:
+  * [Null reply](../../develop/reference/protocol-spec#nulls): The key didn't exist before the `SET`. If `XX` was specified, the key was not set. Otherwise, the key was set.
+  * [Bulk string reply](../../develop/reference/protocol-spec#bulk-strings): The previous value of the key. If `NX` was specified, the key was not set. Otherwise, the key was set.
 
 {{< /multitabs >}}

content/commands/vadd.md

@@ -38,7 +38,7 @@ is the name of the key that will hold the vector set data.
 <details open>
 <summary><code>FP32 vector or VALUES num vector</code></summary>
 
-either a 32-bit floating point (FP32) blob of values or `num` floating point numbers as strings.
+either a 32-bit floating point (FP32) blob of values or `num` floating point numbers as strings. When using the FP32 format, the blob must use little-endian encoding. On platforms with different endianness, you should either manually adjust the byte order or use the VALUES syntax instead.
 </details>
 
 <details open>

content/commands/vemb.md

@@ -82,7 +82,7 @@ One of the following:
 * [Array reply](../../develop/reference/protocol-spec#arrays): consisting of the following elements:
     1. The quantization type as a [simple string](../../develop/reference/protocol-spec#simple-strings): `fp32`, `bin`, or `q8`.
     1. A [bulk string](../../develop/reference/protocol-spec#bulk-strings) blob with the following raw data:
-        * 4-byte floats for fp32
+        * 4-byte floats for fp32 (little-endian encoding)
         * A bitmap for binary quantization
         * A byte array for q8
     1. The L2 norm, as a [simple string](../../develop/reference/protocol-spec#simple-strings), of the vector before normalization.
@@ -95,7 +95,7 @@ One of the following:
 * [Array reply](../../develop/reference/protocol-spec#arrays): consisting of the following elements:
     1. The quantization type as a [simple string](../../develop/reference/protocol-spec#simple-strings): `fp32`, `bin`, or `q8`.
     1. A [bulk string](../../develop/reference/protocol-spec#bulk-strings) blob with the following raw data:
-        * 4-byte floats for fp32
+        * 4-byte floats for fp32 (little-endian encoding)
         * A bitmap for binary quantization
         * A byte array for q8
     1. The [double](../../develop/reference/protocol-spec#doubles) L2 norm of the vector before normalization.

content/commands/vlinks.md

@@ -66,14 +66,16 @@ includes similarity scores for each neighbor.
     tab2="RESP3" >}}
 
 One of the following:
-* [Array reply](../../develop/reference/protocol-spec#arrays) containing the names of adjacent elements as [strings](../../develop/reference/protocol-spec#simple-strings); interleved with scores when using the WITHSCORES option.
+* An [array](../../develop/reference/protocol-spec#arrays) of [array replies](../../develop/reference/protocol-spec#arrays) containing the names of adjacent elements as [bulk strings](../../develop/reference/protocol-spec#bulk-strings); interleaved with scores as [bulk strings](../../develop/reference/protocol-spec#bulk-strings) when used with the `WITHSCORES` option.
+* [Simple error reply](../../develop/reference/protocol-spec/#simple-errors) for incorrect syntax.
 * [Bulk string reply](../../develop/reference/protocol-spec#bulk-strings) (null bulk string) for unknown keys and/or elements.
 
 -tab-sep-
 
 One of the following:
-* [Array reply](../../develop/reference/protocol-spec#arrays) containing the names of adjacent elements as [strings](../../develop/reference/protocol-spec#simple-strings) when used without the WITHSCORES option.
-* [Map reply](../../develop/reference/protocol-spec#maps) containing the names of adjecent elements as [strings](../../develop/reference/protocol-spec#simple-strings), together with their scores as [doubles](../../develop/reference/protocol-spec#doubles) when used with the WITHSCORES option.
+* An [array](../../develop/reference/protocol-spec#arrays) of [array replies](../../develop/reference/protocol-spec#arrays) containing the names of adjacent elements as [bulk strings](../../develop/reference/protocol-spec#bulk-strings) when used without the `WITHSCORES` option.
+* An [array](../../develop/reference/protocol-spec#arrays) of [map replies](../../develop/reference/protocol-spec#maps) containing the names of adjecent elements as [bulk strings](../../develop/reference/protocol-spec#bulk-strings), together with their scores as [doubles](../../develop/reference/protocol-spec#doubles) when used with the `WITHSCORES` option.
+* [Simple error reply](../../develop/reference/protocol-spec/#simple-errors) for incorrect syntax.
 * [Null reply](../../develop/reference/protocol-spec#nulls) for unknown keys and/or elements.
 
 {{< /multitabs >}}