CM functionaluty for AaDB

Draft

4 files changed, 11 insertions, 2 deletions

diff --git a/ydb/core/protos/services.proto b/ydb/core/protos/services.proto
index 49a3e11dd14..4580254df60 100644
--- a/ydb/core/protos/services.proto
+++ b/ydb/core/protos/services.proto
@@ -906,5 +906,7 @@ message TActivity {
         PQ_META_CACHE = 575;
         BS_GROUP_ASSIMILATE = 576;
         ACTOR_COROUTINE = 577;
+        LB_CM_ABC_ACTOR = 578;
+        LB_CM_FOLDER_ACTOR = 579;
     };
 };
diff --git a/ydb/library/persqueue/topic_parser/topic_parser.h b/ydb/library/persqueue/topic_parser/topic_parser.h
index 04099477f7b..7bc937ff4b7 100644
--- a/ydb/library/persqueue/topic_parser/topic_parser.h
+++ b/ydb/library/persqueue/topic_parser/topic_parser.h
@@ -118,6 +118,12 @@ public:
         PrimaryPath = path;
     }
 
+    // Only for control plane
+    const TString& GetFullModernName() const {
+        Y_VERIFY(!FullModernName.empty());
+        return FullModernName;
+    }
+
 protected:
     /** Account will be set for federation topics without database only;
      * Generally used only for discovery purposes
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h b/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h
index 5aa2e953860..7a9151c0bef 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h
@@ -124,6 +124,7 @@ struct TDescribeTopicResult : public TStatus {
         GETTER(TMaybe<ui32>, PartitionsPerTablet);
         GETTER(TMaybe<ui32>, AbcId);
         GETTER(TMaybe<TString>, AbcSlug);
+        GETTER(TMaybe<TString>, FederationAccount);
 
         const TVector<TReadRule>& ReadRules() const {
             return ReadRules_;
@@ -270,7 +271,7 @@ struct TTopicSettings : public TOperationRequestSettings<TDerived> {
         PartitionsPerTablet_ = settings.PartitionsPerTablet();
         AbcId_ = settings.AbcId();
         AbcSlug_ = settings.AbcSlug();
-
+        FederationAccount_ = settings.FederationAccount();
         ReadRules_.clear();
         for (const auto& readRule : settings.ReadRules()) {
             ReadRules_.push_back({});
diff --git a/ydb/services/lib/actors/pq_schema_actor.cpp b/ydb/services/lib/actors/pq_schema_actor.cpp
index 1579e566ffc..6b75fdbd141 100644
--- a/ydb/services/lib/actors/pq_schema_actor.cpp
+++ b/ydb/services/lib/actors/pq_schema_actor.cpp
@@ -585,7 +585,7 @@ namespace NKikimr::NGRpcProxy::V1 {
 
         pqDescr->SetTotalGroupCount(settings.partitions_count());
 
-        auto config = pqDescr->MutablePQTabletConfig();
+        auto* config = pqDescr->MutablePQTabletConfig();
 
         config->SetRequireAuthWrite(true);
         config->SetRequireAuthRead(true);