intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 36 insertions, 0 deletions

diff --git a/library/cpp/messagebus/message_counter.h b/library/cpp/messagebus/message_counter.h
new file mode 100644
index 0000000000..e4be1180b0
--- /dev/null
+++ b/library/cpp/messagebus/message_counter.h
@@ -0,0 +1,36 @@
+#pragma once
+
+#include <util/generic/string.h>
+
+#include <cstddef>
+
+namespace NBus {
+    namespace NPrivate {
+        struct TMessageCounter {
+            size_t BytesData;
+            size_t BytesNetwork;
+            size_t Count;
+            size_t CountCompressed;
+            size_t CountCompressionRequests; // reader only
+
+            void AddMessage(size_t bytesData, size_t bytesCompressed, bool Compressed, bool compressionRequested) {
+                BytesData += bytesData;
+                BytesNetwork += bytesCompressed;
+                Count += 1;
+                if (Compressed) {
+                    CountCompressed += 1;
+                }
+                if (compressionRequested) {
+                    CountCompressionRequests += 1;
+                }
+            }
+
+            TMessageCounter& operator+=(const TMessageCounter& that);
+
+            TString ToString(bool reader) const;
+
+            TMessageCounter();
+        };
+
+    }
+}