Skip to content

Commit 59fa8b6

Browse files
authored
Initial Object Storage Listing internal handler (#2695)
1 parent 5f12295 commit 59fa8b6

26 files changed

+2642
-3
lines changed

ydb/core/client/object_storage_listing_ut.cpp

Lines changed: 837 additions & 0 deletions
Large diffs are not rendered by default.

ydb/core/client/ut/ya.make

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ SRCS(
4040
flat_ut.cpp
4141
locks_ut.cpp
4242
query_stats_ut.cpp
43+
object_storage_listing_ut.cpp
4344
)
4445

4546
END()

ydb/core/driver_lib/run/run.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,7 @@
116116
#include <ydb/services/ydb/ydb_scheme.h>
117117
#include <ydb/services/ydb/ydb_scripting.h>
118118
#include <ydb/services/ydb/ydb_table.h>
119+
#include <ydb/services/ydb/ydb_object_storage.h>
119120

120121
#include <ydb/core/fq/libs/init/init.h>
121122

@@ -559,6 +560,8 @@ void TKikimrRunner::InitializeGRpc(const TKikimrRunConfig& runConfig) {
559560
names["topic"] = &hasTopic;
560561
TServiceCfg hasPQCD = services.empty();
561562
names["pqcd"] = &hasPQCD;
563+
TServiceCfg hasObjectStorage = true;
564+
names["object_storage"] = &hasObjectStorage;
562565
TServiceCfg hasClickhouseInternal = services.empty();
563566
names["clickhouse_internal"] = &hasClickhouseInternal;
564567
TServiceCfg hasRateLimiter = false;
@@ -717,6 +720,11 @@ void TKikimrRunner::InitializeGRpc(const TKikimrRunConfig& runConfig) {
717720
AppData->InFlightLimiterRegistry, grpcRequestProxies[0], hasClickhouseInternal.IsRlAllowed()));
718721
}
719722

723+
if (hasObjectStorage) {
724+
server.AddService(new NGRpcService::TGRpcYdbObjectStorageService(ActorSystem.Get(), Counters,
725+
grpcRequestProxies[0], hasObjectStorage.IsRlAllowed()));
726+
}
727+
720728
if (hasScripting) {
721729
server.AddService(new NGRpcService::TGRpcYdbScriptingService(ActorSystem.Get(), Counters,
722730
grpcRequestProxies[0], hasScripting.IsRlAllowed()));

ydb/core/grpc_services/rpc_calls.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@
1313
#include <ydb/public/api/protos/ydb_discovery.pb.h>
1414
#include <ydb/public/api/protos/ydb_monitoring.pb.h>
1515
#include <ydb/public/api/protos/ydb_status_codes.pb.h>
16+
#include <ydb/public/api/protos/ydb_table.pb.h>
17+
#include <ydb/public/api/protos/draft/ydb_object_storage.pb.h>
1618
#include <ydb/public/api/protos/ydb_persqueue_cluster_discovery.pb.h>
1719
#include <ydb/public/api/protos/ydb_persqueue_v1.pb.h>
1820
#include <ydb/public/api/protos/ydb_federation_discovery.pb.h>

0 commit comments

Comments
 (0)