aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorshmel1k <shmel1k@ydb.tech>2022-08-04 17:23:04 +0300
committershmel1k <shmel1k@ydb.tech>2022-08-04 17:23:04 +0300
commit7b45065f0189d96608d9f7e7f8495a17b43b81e3 (patch)
tree30630709c38c84590f9f1718dd309a216c8cb53a
parent6de758f15f8df28b4f991c4084937d71cdefa20d (diff)
downloadydb-7b45065f0189d96608d9f7e7f8495a17b43b81e3.tar.gz
[] added missing tconsumer definitions
-rw-r--r--ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp46
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())