Skip to content

Commit ebf87a5

Browse files
committed
kesus resources: dump (#14330)
1 parent 093e5d7 commit ebf87a5

File tree

2 files changed

+19
-0
lines changed

2 files changed

+19
-0
lines changed

include/ydb-cpp-sdk/client/rate_limiter/rate_limiter.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,7 @@ using TAsyncListResourcesResult = NThreading::TFuture<TListResourcesResult>;
9191
struct TDescribeResourceResult : public TStatus {
9292
struct THierarchicalDrrProps {
9393
THierarchicalDrrProps(const Ydb::RateLimiter::HierarchicalDrrSettings&);
94+
void SerializeTo(Ydb::RateLimiter::HierarchicalDrrSettings&) const;
9495

9596
// Resource consumption speed limit.
9697
std::optional<double> GetMaxUnitsPerSecond() const {

src/client/rate_limiter/rate_limiter.cpp

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,24 @@ TDescribeResourceResult::THierarchicalDrrProps::THierarchicalDrrProps(const Ydb:
4040
}
4141
}
4242

43+
void TDescribeResourceResult::THierarchicalDrrProps::THierarchicalDrrProps::SerializeTo(Ydb::RateLimiter::HierarchicalDrrSettings& settings) const {
44+
if (MaxUnitsPerSecond_) {
45+
settings.set_max_units_per_second(*MaxUnitsPerSecond_);
46+
}
47+
48+
if (MaxBurstSizeCoefficient_) {
49+
settings.set_max_burst_size_coefficient(*MaxBurstSizeCoefficient_);
50+
}
51+
52+
if (PrefetchCoefficient_) {
53+
settings.set_prefetch_coefficient(*PrefetchCoefficient_);
54+
}
55+
56+
if (PrefetchWatermark_) {
57+
settings.set_prefetch_watermark(*PrefetchWatermark_);
58+
}
59+
}
60+
4361
class TRateLimiterClient::TImpl : public TClientImplCommon<TRateLimiterClient::TImpl> {
4462
public:
4563
TImpl(std::shared_ptr<TGRpcConnectionsImpl> connections, const TCommonClientSettings& settings)

0 commit comments

Comments
 (0)