Ydb stable 23-1-1923.1.19

x-stable-origin-commit: c5d5a396e89d0a72e0267a55e93d8404d4fb54fe

1 files changed, 75 insertions, 0 deletions

diff --git a/library/cpp/unified_agent_client/client_proto_weighing.h b/library/cpp/unified_agent_client/client_proto_weighing.h
new file mode 100644
index 0000000000..728792e49f
--- /dev/null
+++ b/library/cpp/unified_agent_client/client_proto_weighing.h
@@ -0,0 +1,75 @@
+#pragma once
+
+#include <library/cpp/unified_agent_client/f_maybe.h>
+#include <library/cpp/unified_agent_client/proto_weighing.h>
+
+namespace NUnifiedAgent::NPW {
+    struct TMessageMetaItem: public TMessage {
+        TMessageMetaItem()
+            : TMessage()
+            , Key(this)
+            , Value(this)
+            , SkipStart(this)
+            , SkipLength(this)
+        {
+        }
+
+        explicit TMessageMetaItem(TMessage* parent)
+            : TMessage(parent)
+            , Key(this)
+            , Value(this)
+            , SkipStart(this)
+            , SkipLength(this)
+        {
+        }
+
+        explicit TMessageMetaItem(const NUnifiedAgent::TFMaybe<TFieldLink>& link)
+            : TMessage(link)
+            , Key(this)
+            , Value(this)
+            , SkipStart(this)
+            , SkipLength(this)
+        {
+        }
+
+        TStringField Key;
+        TRepeatedPtrField<TStringField> Value;
+        TRepeatedField<ui32> SkipStart;
+        TRepeatedField<ui32> SkipLength;
+    };
+
+    struct TDataBatch: public TMessage {
+        TDataBatch()
+            : TMessage()
+            , SeqNo(this)
+            , Timestamp(this)
+            , Payload(this, 2)
+            , Meta(this, 2)
+        {
+        }
+
+        TDataBatch(TMessage* parent)
+            : TMessage(parent)
+            , SeqNo(this)
+            , Timestamp(this)
+            , Payload(this, 2)
+            , Meta(this, 2)
+        {
+        }
+
+        TRepeatedField<ui64> SeqNo;  // 1
+        TRepeatedField<ui64> Timestamp; // 2
+        TRepeatedPtrField<TStringField> Payload; // 100
+        TRepeatedPtrField<TMessageMetaItem> Meta; // 101
+    };
+
+    struct TRequest: public TMessage {
+        TRequest()
+            : TMessage()
+            , DataBatch(this)
+        {
+        }
+
+        TDataBatch DataBatch;
+    };
+}