Import YDB C++ SDK 50

.github/import_generation.txt

@@ -1 +1 @@
-50
+51

.github/last_commit.txt

@@ -1 +1 @@
-4b757a14e7269921b351fec8dff5af2e088a89ae
+c7fb4a28d8e03aaa9e42859b6f7c199c6e7ef203

CHANGELOG.md

@@ -1,3 +1,19 @@
+## v3.24.0
+
+* Added `NValueHelpers::Embedding` to create FloatVector `Bytes` query parameters from numeric ranges.
+
+* Topic and PersQueue writers now respect the driver's outbound gRPC message size limit when batching writes.
+
+* Added a draft UDF client (`client/draft/ydb_udf.h`) with manifest-based uploads, separate module type/code kind, per-platform compile state and optional timestamps, and incremental `UploadModuleFromFile` on a dedicated I/O executor. Upload futures include the final gRPC status.
+
+* Added an optional S3 object key prefix to TTL eviction settings for column tables.
+
+* Added `TTopicClient::ResetOffset` / `TResetOffsetSettings` to rewind a consumer's committed offsets on all topic partitions.
+
+* Added OIDC/OAuth authentication via `NOidc::CreateOidcProviderFactory`, supporting static access tokens, Client Credentials Grant, and Device Authorization Grant, with token refresh and interfaces for token caching and interactive sign-in.
+
+* Added `Float16` and `BFloat16` vector index types.
+
 ## v3.23.0
 
 * Added optional `TRetryOperationSettings::StopToken` for cooperative cancellation between retry attempts.

examples/auth/oidc/main.cpp

@@ -0,0 +1,93 @@
+#include <ydb-cpp-sdk/client/query/client.h>
+#include <ydb-cpp-sdk/client/types/credentials/oidc/credentials.h>
+
+#include <util/system/mutex.h>
+
+#include <iostream>
+
+class TConsoleAcceptor final: public NYdb::NOidc::IAuthAcceptor {
+public:
+    void Accept(const NYdb::NOidc::TDeviceAuthInfo& info) override;
+
+private:
+    static void Print(const std::string& value);
+};
+
+class TMemoryTokenCacher final: public NYdb::NOidc::ITokenCacher {
+public:
+    std::optional<NYdb::NOidc::TTokenCache> Read() const override;
+    void Write(const NYdb::NOidc::TTokenCache& tokens) override;
+
+private:
+    mutable TMutex Mutex;
+    std::optional<NYdb::NOidc::TTokenCache> Tokens;
+};
+
+void TConsoleAcceptor::Accept(const NYdb::NOidc::TDeviceAuthInfo& info) {
+    static TMutex outputMutex;
+    with_lock (outputMutex) {
+        std::cerr << "Open ";
+        Print(info.VerificationUrl);
+        std::cerr << " and enter code ";
+        Print(info.UserCode);
+        std::cerr << std::endl;
+        if (info.VerificationUrlComplete.has_value()) {
+            std::cerr << "Or open ";
+            Print(*info.VerificationUrlComplete);
+            std::cerr << std::endl;
+        }
+    }
+}
+
+void TConsoleAcceptor::Print(const std::string& value) {
+    for (const unsigned char ch : value) {
+        std::cerr << (ch >= 0x20 && ch < 0x7f ? static_cast<char>(ch) : '?');
+    }
+}
+
+std::optional<NYdb::NOidc::TTokenCache> TMemoryTokenCacher::Read() const {
+    with_lock (Mutex) {
+        return Tokens;
+    }
+}
+
+void TMemoryTokenCacher::Write(const NYdb::NOidc::TTokenCache& tokens) {
+    with_lock (Mutex) {
+        Tokens = tokens;
+    }
+}
+
+int main(int argc, char** argv) {
+    if (argc != 5) {
+        std::cerr << "Usage: oidc <grpc[s]://endpoint:port> <database> <issuer> <client-id>" << std::endl;
+        return 1;
+    }
+    try {
+        NYdb::NOidc::TOidcConfig oidcConfig{
+            .Issuer = argv[3],
+            .FlowConfig = NYdb::NOidc::TDeviceOidcConfig{
+                .ClientId = argv[4],
+                .Scopes = {"openid", "user-context"},
+            },
+        };
+        oidcConfig
+            .Cacher(std::make_shared<TMemoryTokenCacher>())
+            .Acceptor(std::make_shared<TConsoleAcceptor>());
+
+        auto config = NYdb::TDriverConfig(argv[1])
+            .SetDatabase(argv[2])
+            .SetDiscoveryMode(NYdb::EDiscoveryMode::Async)
+            .SetCredentialsProviderFactory(NYdb::NOidc::CreateOidcProviderFactory(oidcConfig));
+        NYdb::TDriver driver(config);
+        NYdb::NQuery::TQueryClient client(driver);
+        auto result = client.ExecuteQuery("SELECT 1", NYdb::NQuery::TTxControl::NoTx()).ExtractValueSync();
+        if (!result.IsSuccess()) {
+            std::cerr << result.GetIssues().ToString() << std::endl;
+            return 1;
+        }
+        std::cout << "Query succeeded" << std::endl;
+    } catch (const std::exception& error) {
+        std::cerr << error.what() << std::endl;
+        return 1;
+    }
+}

examples/vector_index/README.md

@@ -42,7 +42,7 @@ It uses scalar quantization to speedup ANN search:
 
 #### Create Flat Bit Index
 
-It creates index table, with two columns: `primary_key` and `embedding`, `embedding` will be trasformed from `<table>` `<embedding>`
+It creates index table, with two columns: `primary_key` and `embedding`, `embedding` will be transformed from `<table>` `<embedding>`
 
 ```
 ./vector_index --endpoint=<endpoint> --database=<database> --command=RecreateIndex --table=<table> --index_type=flat --index_quantizer=bit --primary_key=<primary_key> --embedding=<embedding> --distance=CosineDistance --rows=490000 --top_k=0 --data="" --target=""