Skip to content

Commit a926349

Browse files
jepett0Gazizonoki
authored andcommitted
TOPIC: enable ydb tools dump (local backup) (#14053)
1 parent a3e8ed9 commit a926349

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

src/api/protos/ydb_rate_limiter.proto

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,9 @@ message MeteringConfig {
6363
// Default value is inherited from parent or equals 60 seconds for root.
6464
uint64 billing_period_sec = 2;
6565

66+
// User-defined labels.
67+
map<string, string> labels = 3 [(map_key).length.le = 256, (length).le = 10240, (size).le = 100];
68+
6669
// Billing metric JSON fields (inherited from parent if not set)
6770
google.protobuf.Struct metric_fields = 10;
6871
}

src/client/topic/impl/topic.cpp

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -184,8 +184,15 @@ const std::vector<TConsumer>& TTopicDescription::GetConsumers() const {
184184
}
185185

186186
void TTopicDescription::SerializeTo(Ydb::Topic::CreateTopicRequest& request) const {
187-
Y_UNUSED(request);
188-
Y_ABORT("Not implemented");
187+
*request.mutable_partitioning_settings() = Proto_.partitioning_settings();
188+
*request.mutable_retention_period() = Proto_.retention_period();
189+
request.set_retention_storage_mb(Proto_.retention_storage_mb());
190+
*request.mutable_supported_codecs() = Proto_.supported_codecs();
191+
request.set_partition_write_speed_bytes_per_second(Proto_.partition_write_speed_bytes_per_second());
192+
request.set_partition_write_burst_bytes(Proto_.partition_write_burst_bytes());
193+
*request.mutable_attributes() = Proto_.attributes();
194+
*request.mutable_consumers() = Proto_.consumers();
195+
request.set_metering_mode(Proto_.metering_mode());
189196
}
190197

191198
const Ydb::Topic::DescribeTopicResult& TTopicDescription::GetProto() const {

0 commit comments

Comments
 (0)