Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
niksaveliev committed Jul 2, 2024
1 parent 1115b5f commit 262817a
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
4 changes: 2 additions & 2 deletions ydb/public/api/protos/ydb_topic.proto
Original file line number Diff line number Diff line change
Expand Up @@ -1089,9 +1089,9 @@ message DescribeTopicResult {
PartitionLocation partition_location = 6;

// Inclusive left border. Emptiness means -inf.
optional bytes FromBound = 7;
optional bytes from_bound = 7;
// Exclusive right border. Emptiness means +inf.
optional bytes ToBound = 8;
optional bytes to_bound = 8;
}

message TopicStats {
Expand Down
8 changes: 4 additions & 4 deletions ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -404,12 +404,12 @@ TPartitionInfo::TPartitionInfo(const Ydb::Topic::DescribeTopicResult::PartitionI
PartitionLocation_ = TPartitionLocation{partitionInfo.partition_location()};
}

if (partitionInfo.HasFromBound()) {
FromBound_ = TString(partitionInfo.GetFromBound());
if (partitionInfo.has_from_bound()) {
FromBound_ = TString(partitionInfo.from_bound());
}

if (partitionInfo.HasToBound()) {
ToBound_ = TString(partitionInfo.GetToBound());
if (partitionInfo.has_to_bound()) {
ToBound_ = TString(partitionInfo.to_bound());
}
}

Expand Down
4 changes: 2 additions & 2 deletions ydb/services/persqueue_v1/actors/schema_actors.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1076,10 +1076,10 @@ void TDescribeTopicActor::HandleCacheNavigateResponse(TEvTxProxySchemeCache::TEv
destPart->set_active(sourcePart.GetStatus() == ::NKikimrPQ::ETopicPartitionStatus::Active);
if (sourcePart.HasKeyRange()) {
if (sourcePart.GetKeyRange().HasFromBound()) {
destPart->set_frombound(sourcePart.GetKeyRange().GetFromBound());
destPart->set_from_bound(sourcePart.GetKeyRange().GetFromBound());
}
if (sourcePart.GetKeyRange().HasToBound()) {
destPart->set_tobound(sourcePart.GetKeyRange().GetToBound());
destPart->set_to_bound(sourcePart.GetKeyRange().GetToBound());
}
}

Expand Down

0 comments on commit 262817a

Please sign in to comment.