diff options
| author | Bulat <[email protected]> | 2025-04-15 01:14:28 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-04-14 22:14:28 +0000 |
| commit | 290ddc968805602f3ca49f12282ee6bef59462ca (patch) | |
| tree | 3bd174254fad2454946dd361119c42d795cb39a7 | |
| parent | 5eed854386cd5d71eb2bf411106aeb6bf231d4d8 (diff) | |
[C++ SDK] Fixed register of GZIP and ZSTD codecs in topic client (#17192)
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 |
