YT-21453: Add request proxing

a89e46aed68565a4410b7f1354505ffaeb92536d

3 files changed, 17 insertions, 0 deletions

diff --git a/yt/yt/client/ypath/rich.cpp b/yt/yt/client/ypath/rich.cpp
index 03484638e1..ab78d81171 100644
--- a/yt/yt/client/ypath/rich.cpp
+++ b/yt/yt/client/ypath/rich.cpp
@@ -206,6 +206,16 @@ void TRichYPath::SetForeign(bool value)
     Attributes().Set("foreign", value);
 }
 
+bool TRichYPath::GetReadViaExecNode() const
+{
+    return GetAttribute(*this, "read_via_exec_node", false);
+}
+
+void TRichYPath::SetReadViaExecNode(bool value)
+{
+    Attributes().Set("read_via_exec_node", value);
+}
+
 std::optional<std::vector<TString>> TRichYPath::GetColumns() const
 {
     if (Attributes().Contains("channel")) {
@@ -768,6 +778,7 @@ const std::vector<TString>& GetWellKnownRichYPathAttributes()
         "cluster",
         "clusters",
         "create",
+        "read_via_exec_node",
     };
     return WellKnownAttributes;
 }
diff --git a/yt/yt/client/ypath/rich.h b/yt/yt/client/ypath/rich.h
index fa53d6a568..d74f0609c6 100644
--- a/yt/yt/client/ypath/rich.h
+++ b/yt/yt/client/ypath/rich.h
@@ -62,6 +62,10 @@ public:
     bool GetForeign() const;
     void SetForeign(bool value);
 
+    // "read_via_exec_node"
+    bool GetReadViaExecNode() const;
+    void SetReadViaExecNode(bool value);
+
     // "columns"
     std::optional<std::vector<TString>> GetColumns() const;
     void SetColumns(const std::vector<TString>& columns);
diff --git a/yt/yt_proto/yt/client/chunk_client/proto/chunk_spec.proto b/yt/yt_proto/yt/client/chunk_client/proto/chunk_spec.proto
index a7626b4b35..51c1dbf45d 100644
--- a/yt/yt_proto/yt/client/chunk_client/proto/chunk_spec.proto
+++ b/yt/yt_proto/yt/client/chunk_client/proto/chunk_spec.proto
@@ -83,6 +83,8 @@ message TChunkSpec
 
     optional bool striped_erasure = 24;
 
+    optional bool use_proxying_data_node_service = 26 [default = false];
+
     reserved 5, 6, 8;
 }