diff options
author | shmel1k <shmel1k@ydb.tech> | 2022-08-04 17:23:04 +0300 |
---|---|---|
committer | shmel1k <shmel1k@ydb.tech> | 2022-08-04 17:23:04 +0300 |
commit | 7b45065f0189d96608d9f7e7f8495a17b43b81e3 (patch) | |
tree | 30630709c38c84590f9f1718dd309a216c8cb53a | |
parent | 6de758f15f8df28b4f991c4084937d71cdefa20d (diff) | |
download | ydb-7b45065f0189d96608d9f7e7f8495a17b43b81e3.tar.gz |
[] added missing tconsumer definitions
-rw-r--r-- | ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp | 46 |
1 files changed, 33 insertions, 13 deletions
diff --git a/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp b/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp index e96e7bd1483..eddde390ca0 100644 --- a/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp +++ b/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp @@ -53,6 +53,39 @@ TTopicDescription::TTopicDescription(Ydb::Topic::DescribeTopicResult&& result) } } +TConsumer::TConsumer(const Ydb::Topic::Consumer& consumer) + : ConsumerName_(consumer.name()) + , Important_(consumer.important()) + , ReadFrom_(TInstant::Seconds(consumer.read_from().seconds())) +{ + for (const auto& codec : consumer.supported_codecs().codecs()) { + SupportedCodecs_.push_back((ECodec)codec); + } + for (const auto& pair : consumer.attributes()) { + Attributes_[pair.first] = pair.second; + } +} + +const TString& TConsumer::GetConsumerName() const { + return ConsumerName_; +} + +bool TConsumer::GetImportant() const { + return Important_; +} + +const TInstant& TConsumer::GetReadFrom() const { + return ReadFrom_; +} + +const TVector<ECodec>& TConsumer::GetSupportedCodecs() const { + return SupportedCodecs_; +} + +const TMap<TString, TString>& TConsumer::GetAttributes() const { + return Attributes_; +} + const TPartitioningSettings& TTopicDescription::GetPartitioningSettings() const { return PartitioningSettings_; } @@ -127,19 +160,6 @@ ui64 TPartitioningSettings::GetPartitionCountLimit() const { return PartitionCountLimit_; } -TConsumer::TConsumer(const Ydb::Topic::Consumer& consumer) - : ConsumerName_(consumer.name()) - , Important_(consumer.important()) - , ReadFrom_(TInstant::Seconds(consumer.read_from().seconds())) -{ - for (const auto& codec : consumer.supported_codecs().codecs()) { - SupportedCodecs_.push_back((ECodec)codec); - } - for (const auto& pair : consumer.attributes()) { - Attributes_[pair.first] = pair.second; - } -} - TPartitionInfo::TPartitionInfo(const Ydb::Topic::DescribeTopicResult::PartitionInfo& partitionInfo) : PartitionId_(partitionInfo.partition_id()) , Active_(partitionInfo.active()) |