diff options
| author | shmel1k <shmel1k@ydb.tech> | 2023-01-16 16:17:42 +0300 |
|---|---|---|
| committer | shmel1k <shmel1k@ydb.tech> | 2023-01-16 16:17:42 +0300 |
| commit | b0d7a976293e8d341d99987992f1ee2d35555821 (patch) | |
| tree | 47c6b7891cf441bc46690a739061ee3507c1b67e | |
| parent | 4a928ef858041e897b5943782f8873ba1c8f56bd (diff) | |
| download | ydb-b0d7a976293e8d341d99987992f1ee2d35555821.tar.gz | |
[misc] add codec tests for persqueue codecs
| -rw-r--r-- | ydb/core/persqueue/codecs/ut/codecs_ut.cpp | 60 |
1 files changed, 60 insertions, 0 deletions
diff --git a/ydb/core/persqueue/codecs/ut/codecs_ut.cpp b/ydb/core/persqueue/codecs/ut/codecs_ut.cpp new file mode 100644 index 00000000000..160093a4aa2 --- /dev/null +++ b/ydb/core/persqueue/codecs/ut/codecs_ut.cpp @@ -0,0 +1,60 @@ +#include <library/cpp/testing/unittest/registar.h> +#include <ydb/core/persqueue/codecs/pqv1.h> + +Y_UNIT_TEST_SUITE(PersQueueCodecs) { + Y_UNIT_TEST(ToV1Codec) { + { + NPersQueueCommon::ECodec codec = NPersQueueCommon::ECodec::RAW; + Ydb::PersQueue::V1::Codec got = NKikimr::NPQ::ToV1Codec(codec); + UNIT_ASSERT_EQUAL(got, Ydb::PersQueue::V1::Codec::CODEC_RAW); + } + { + NPersQueueCommon::ECodec codec = NPersQueueCommon::ECodec::GZIP; + Ydb::PersQueue::V1::Codec got = NKikimr::NPQ::ToV1Codec(codec); + UNIT_ASSERT_EQUAL(got, Ydb::PersQueue::V1::Codec::CODEC_GZIP); + } + { + NPersQueueCommon::ECodec codec = NPersQueueCommon::ECodec::LZOP; + Ydb::PersQueue::V1::Codec got = NKikimr::NPQ::ToV1Codec(codec); + UNIT_ASSERT_EQUAL(got, Ydb::PersQueue::V1::Codec::CODEC_LZOP); + } + { + NPersQueueCommon::ECodec codec = NPersQueueCommon::ECodec::ZSTD; + Ydb::PersQueue::V1::Codec got = NKikimr::NPQ::ToV1Codec(codec); + UNIT_ASSERT_EQUAL(got, Ydb::PersQueue::V1::Codec::CODEC_ZSTD); + } + { + NPersQueueCommon::ECodec codec = NPersQueueCommon::ECodec::DEFAULT; + Ydb::PersQueue::V1::Codec got = NKikimr::NPQ::ToV1Codec(codec); + UNIT_ASSERT_EQUAL(got, Ydb::PersQueue::V1::Codec::CODEC_UNSPECIFIED); + } + } + + Y_UNIT_TEST(FromV1Codec) { + { + NYdb::NPersQueue::ECodec codec = NYdb::NPersQueue::ECodec::RAW; + std::optional<NPersQueueCommon::ECodec> got = NKikimr::NPQ::FromV1Codec(codec); + UNIT_ASSERT_VALUES_EQUAL(got.value(), NPersQueueCommon::ECodec::RAW); + } + { + NYdb::NPersQueue::ECodec codec = NYdb::NPersQueue::ECodec::GZIP; + std::optional<NPersQueueCommon::ECodec> got = NKikimr::NPQ::FromV1Codec(codec); + UNIT_ASSERT_VALUES_EQUAL(got.value(), NPersQueueCommon::ECodec::GZIP); + } + { + NYdb::NPersQueue::ECodec codec = NYdb::NPersQueue::ECodec::LZOP; + std::optional<NPersQueueCommon::ECodec> got = NKikimr::NPQ::FromV1Codec(codec); + UNIT_ASSERT_VALUES_EQUAL(got.value(), NPersQueueCommon::ECodec::LZOP); + } + { + NYdb::NPersQueue::ECodec codec = NYdb::NPersQueue::ECodec::ZSTD; + std::optional<NPersQueueCommon::ECodec> got = NKikimr::NPQ::FromV1Codec(codec); + UNIT_ASSERT_VALUES_EQUAL(got.value(), NPersQueueCommon::ECodec::ZSTD); + } + { + NYdb::NPersQueue::ECodec codec = NYdb::NPersQueue::ECodec(42); + std::optional<NPersQueueCommon::ECodec> got = NKikimr::NPQ::FromV1Codec(codec); + UNIT_ASSERT_EQUAL(got, std::nullopt); + } + } +} |