Add admin cluster config generate command (#14711)

Author: mregrock

include/ydb-cpp-sdk/client/draft/ydb_dynamic_config.h

@@ -160,6 +160,21 @@ struct TVerboseResolveConfigResult : public TStatus {
 
 using TAsyncVerboseResolveConfigResult = NThreading::TFuture<TVerboseResolveConfigResult>;
 
+struct TFetchStartupConfigResult : public TStatus {
+    TFetchStartupConfigResult(TStatus&& status, std::string&& config)
+        : TStatus(std::move(status))
+        , Config_(std::move(config))
+    {}
+
+    const std::string& GetConfig() const {
+        return Config_;
+    }
+
+private:
+    std::string Config_;
+};
+
+using TAsyncFetchStartupConfigResult = NThreading::TFuture<TFetchStartupConfigResult>;
 
 struct TDynamicConfigClientSettings : public TCommonClientSettingsBase<TDynamicConfigClientSettings> {
     using TSelf = TDynamicConfigClientSettings;
@@ -240,6 +255,9 @@ class TDynamicConfigClient {
         const std::map<uint64_t, std::string>& volatileConfigs,
         const TClusterConfigSettings& settings = {});
 
+    // Fetch startup config
+    TAsyncFetchStartupConfigResult FetchStartupConfig(const TClusterConfigSettings& settings = {});
+
 private:
     std::shared_ptr<TImpl> Impl_;
 };

src/api/grpc/draft/ydb_dynamic_config_v1.proto

@@ -46,4 +46,7 @@ service DynamicConfigService {
 
     // Resolve config for all possible labels combinations.
     rpc ResolveAllConfig(DynamicConfig.ResolveAllConfigRequest) returns (DynamicConfig.ResolveAllConfigResponse);
+
+    // Generate dynamic config based on cluster's static config.
+    rpc FetchStartupConfig(DynamicConfig.FetchStartupConfigRequest) returns (DynamicConfig.FetchStartupConfigResponse);
 }

src/api/protos/draft/ydb_dynamic_config.proto

@@ -228,3 +228,17 @@ message ResolveAllConfigResult {
     // Verbose resolved configs
     repeated ResolvedConfig configs = 2;
 }
+
+message FetchStartupConfigRequest {
+    Ydb.Operations.OperationParams operation_params = 1;
+}
+
+message FetchStartupConfigResponse {
+    // Result of request will be inside operation.
+    Ydb.Operations.Operation operation = 1;
+}
+
+message FetchStartupConfigResult {
+    // YAML document with generated dynamic config
+    string config = 1;
+}

src/client/draft/ydb_dynamic_config.cpp

@@ -339,6 +339,32 @@ class TDynamicConfigClient::TImpl : public TClientImplCommon<TDynamicConfigClien
 
         return promise.GetFuture();
     }
+
+    TAsyncFetchStartupConfigResult FetchStartupConfig(const TClusterConfigSettings& settings = {}) {
+        auto request = MakeOperationRequest<Ydb::DynamicConfig::FetchStartupConfigRequest>(settings);
+
+        auto promise = NThreading::NewPromise<TFetchStartupConfigResult>();
+
+        auto extractor = [promise] (google::protobuf::Any* any, TPlainStatus status) mutable {
+                std::string config;
+                if (Ydb::DynamicConfig::FetchStartupConfigResult result; any && any->UnpackTo(&result)) {
+                    config = result.config();
+                }
+
+                TFetchStartupConfigResult val(TStatus(std::move(status)), std::move(config));
+                promise.SetValue(std::move(val));
+            };
+
+        Connections_->RunDeferred<Ydb::DynamicConfig::V1::DynamicConfigService, Ydb::DynamicConfig::FetchStartupConfigRequest, Ydb::DynamicConfig::FetchStartupConfigResponse>(
+            std::move(request),
+            extractor,
+            &Ydb::DynamicConfig::V1::DynamicConfigService::Stub::AsyncFetchStartupConfig,
+            DbDriverState_,
+            INITIAL_DEFERRED_CALL_DELAY,
+            TRpcRequestSettings::Make(settings));
+
+        return promise.GetFuture();
+    }
 };
 
 TDynamicConfigClient::TDynamicConfigClient(const TDriver& driver)
@@ -434,4 +460,8 @@ TAsyncVerboseResolveConfigResult TDynamicConfigClient::VerboseResolveConfig(
     return Impl_->VerboseResolveConfig(config, volatileConfigs, settings);
 }
 
+TAsyncFetchStartupConfigResult TDynamicConfigClient::FetchStartupConfig(const TClusterConfigSettings& settings) {
+    return Impl_->FetchStartupConfig(settings);
+}
+
 } // namespace NYdb::V3::NDynamicConfig