summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorBulat <[email protected]>2025-04-15 01:14:28 +0300
committerGitHub <[email protected]>2025-04-14 22:14:28 +0000
commit290ddc968805602f3ca49f12282ee6bef59462ca (patch)
tree3bd174254fad2454946dd361119c42d795cb39a7
parent5eed854386cd5d71eb2bf411106aeb6bf231d4d8 (diff)
[C++ SDK] Fixed register of GZIP and ZSTD codecs in topic client (#17192)
-rw-r--r--ydb/public/sdk/cpp/src/client/topic/codecs/codecs.cpp12
-rw-r--r--ydb/public/sdk/cpp/src/client/topic/codecs/ya.make2
-rw-r--r--ydb/public/sdk/cpp/src/client/topic/impl/topic.cpp9
-rw-r--r--ydb/public/sdk/cpp/src/client/topic/impl/ya.make1
4 files changed, 14 insertions, 10 deletions
diff --git a/ydb/public/sdk/cpp/src/client/topic/codecs/codecs.cpp b/ydb/public/sdk/cpp/src/client/topic/codecs/codecs.cpp
index 8bcda570494..d35238c4669 100644
--- a/ydb/public/sdk/cpp/src/client/topic/codecs/codecs.cpp
+++ b/ydb/public/sdk/cpp/src/client/topic/codecs/codecs.cpp
@@ -63,4 +63,16 @@ std::unique_ptr<IOutputStream> TUnsupportedCodec::CreateCoder(TBuffer&, int) con
throw yexception() << "use of unsupported codec";
}
+class TCommonCodecsProvider {
+public:
+ TCommonCodecsProvider() {
+ TCodecMap::GetTheCodecMap().Set((uint32_t)ECodec::GZIP, std::make_unique<TGzipCodec>());
+ TCodecMap::GetTheCodecMap().Set((uint32_t)ECodec::ZSTD, std::make_unique<TZstdCodec>());
+ }
+};
+
+namespace {
+TCommonCodecsProvider COMMON_CODECS_PROVIDER;
+}
+
}; // namespace NYdb::NTopic
diff --git a/ydb/public/sdk/cpp/src/client/topic/codecs/ya.make b/ydb/public/sdk/cpp/src/client/topic/codecs/ya.make
index 81dda3914b8..6e1cf573cf2 100644
--- a/ydb/public/sdk/cpp/src/client/topic/codecs/ya.make
+++ b/ydb/public/sdk/cpp/src/client/topic/codecs/ya.make
@@ -1,7 +1,7 @@
LIBRARY()
SRCS(
- codecs.cpp
+ GLOBAL codecs.cpp
)
PEERDIR(
diff --git a/ydb/public/sdk/cpp/src/client/topic/impl/topic.cpp b/ydb/public/sdk/cpp/src/client/topic/impl/topic.cpp
index 1717f29cd7e..7471c12276f 100644
--- a/ydb/public/sdk/cpp/src/client/topic/impl/topic.cpp
+++ b/ydb/public/sdk/cpp/src/client/topic/impl/topic.cpp
@@ -11,15 +11,6 @@
namespace NYdb::inline Dev::NTopic {
-class TCommonCodecsProvider {
-public:
- TCommonCodecsProvider() {
- TCodecMap::GetTheCodecMap().Set((uint32_t)ECodec::GZIP, std::make_unique<TGzipCodec>());
- TCodecMap::GetTheCodecMap().Set((uint32_t)ECodec::ZSTD, std::make_unique<TZstdCodec>());
- }
-};
-TCommonCodecsProvider COMMON_CODECS_PROVIDER;
-
TDescribeTopicResult::TDescribeTopicResult(TStatus&& status, Ydb::Topic::DescribeTopicResult&& result)
: TStatus(std::move(status))
, TopicDescription_(std::move(result))
diff --git a/ydb/public/sdk/cpp/src/client/topic/impl/ya.make b/ydb/public/sdk/cpp/src/client/topic/impl/ya.make
index 597b5f4abe2..01dcf5631ff 100644
--- a/ydb/public/sdk/cpp/src/client/topic/impl/ya.make
+++ b/ydb/public/sdk/cpp/src/client/topic/impl/ya.make
@@ -33,6 +33,7 @@ PEERDIR(
ydb/public/sdk/cpp/src/client/impl/ydb_internal/make_request
ydb/public/sdk/cpp/src/client/common_client/impl
ydb/public/sdk/cpp/src/client/driver
+ ydb/public/sdk/cpp/src/client/topic/codecs
ydb/public/sdk/cpp/src/client/topic/common
ydb/public/sdk/cpp/include/ydb-cpp-sdk/client/topic
ydb/public/sdk/cpp/src/client/proto