Skip to content

Legacy kv api remove #10614

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Oct 24, 2024
Merged

Legacy kv api remove #10614

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
155a1a6
Removed legacy KV API
mregrock Aug 28, 2024
cfbc9a2
Merge branch 'main' into legacy_kv_api_remove
mregrock Sep 23, 2024
53c7e09
Merge branch 'main' into legacy_kv_api_remove
mregrock Oct 18, 2024
a0a13da
Update cli_cmds_admin.cpp
mregrock Oct 24, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions ydb/core/client/server/grpc_server.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -444,8 +444,6 @@ void TGRpcService::SetupIncomingRequests() {
// actor requests
ADD_ACTOR_REQUEST(BlobStorageConfig, TBlobStorageConfigRequest, MTYPE_CLIENT_BLOB_STORAGE_CONFIG_REQUEST)
ADD_ACTOR_REQUEST(HiveCreateTablet, THiveCreateTablet, MTYPE_CLIENT_HIVE_CREATE_TABLET)
ADD_ACTOR_REQUEST(LocalEnumerateTablets, TLocalEnumerateTablets, MTYPE_CLIENT_LOCAL_ENUMERATE_TABLETS)
ADD_ACTOR_REQUEST(KeyValue, TKeyValueRequest, MTYPE_CLIENT_KEYVALUE)
ADD_ACTOR_REQUEST(TabletStateRequest, TTabletStateRequest, MTYPE_CLIENT_TABLET_STATE_REQUEST)
ADD_ACTOR_REQUEST(LocalMKQL, TLocalMKQL, MTYPE_CLIENT_LOCAL_MINIKQL)
ADD_ACTOR_REQUEST(LocalSchemeTx, TLocalSchemeTx, MTYPE_CLIENT_LOCAL_SCHEME_TX)
Expand Down
12 changes: 0 additions & 12 deletions ydb/core/client/server/msgbus_server.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -103,12 +103,6 @@ class TBusMessageContext::TImplGRpc
MTYPE(TBusHiveCreateTablet)
MTYPE(TBusOldHiveCreateTablet)
MTYPE(TBusHiveCreateTabletResult)
MTYPE(TBusLocalEnumerateTablets)
MTYPE(TBusOldLocalEnumerateTablets)
MTYPE(TBusLocalEnumerateTabletsResult)
MTYPE(TBusKeyValue)
MTYPE(TBusOldKeyValue)
MTYPE(TBusKeyValueResponse)
MTYPE(TBusPersQueue)
MTYPE(TBusTabletKillRequest)
MTYPE(TBusTabletStateRequest)
Expand Down Expand Up @@ -511,12 +505,6 @@ void TMessageBusServer::OnMessage(TBusMessageContext &msg) {
case MTYPE_CLIENT_HIVE_CREATE_TABLET:
case MTYPE_CLIENT_OLD_HIVE_CREATE_TABLET:
return ClientActorRequest(CreateMessageBusHiveCreateTablet, msg);
case MTYPE_CLIENT_LOCAL_ENUMERATE_TABLETS:
case MTYPE_CLIENT_OLD_LOCAL_ENUMERATE_TABLETS:
return ClientActorRequest(CreateMessageBusLocalEnumerateTablets, msg);
case MTYPE_CLIENT_KEYVALUE:
case MTYPE_CLIENT_OLD_KEYVALUE:
return ClientActorRequest(CreateMessageBusKeyValue, msg);
case MTYPE_CLIENT_PERSQUEUE:
return ClientProxyRequest<TEvBusProxy::TEvPersQueue>(msg);
case MTYPE_CLIENT_CHOOSE_PROXY:
Expand Down
2 changes: 0 additions & 2 deletions ydb/core/client/server/msgbus_server.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -278,8 +278,6 @@ IActor* CreateMessageBusLocalSchemeTx(TBusMessageContext &msg);
IActor* CreateMessageBusSchemeInitRoot(TBusMessageContext &msg);
IActor* CreateMessageBusGetTypes(TBusMessageContext &msg);
IActor* CreateMessageBusHiveCreateTablet(TBusMessageContext &msg);
IActor* CreateMessageBusLocalEnumerateTablets(TBusMessageContext &msg);
IActor* CreateMessageBusKeyValue(TBusMessageContext &msg);
IActor* CreateMessageBusPersQueue(TBusMessageContext &msg);
IActor* CreateMessageBusChooseProxy(TBusMessageContext &msg);
IActor* CreateMessageBusTabletStateRequest(TBusMessageContext &msg);
Expand Down
98 changes: 0 additions & 98 deletions ydb/core/client/server/msgbus_server_keyvalue.cpp
View file
Open in desktop

This file was deleted.

140 changes: 0 additions & 140 deletions ydb/core/client/server/msgbus_server_local_enumerate_tablets.cpp
View file
Open in desktop

This file was deleted.

2 changes: 0 additions & 2 deletions ydb/core/client/server/ya.make
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ SRCS(
msgbus_server_drain_node.cpp
msgbus_server_fill_node.cpp
msgbus_server_hive_create_tablet.cpp
msgbus_server_keyvalue.cpp
msgbus_server_persqueue.cpp
msgbus_server_persqueue.h
msgbus_server_pq_metacache.h
Expand All @@ -25,7 +24,6 @@ SRCS(
msgbus_server_pq_read_session_info.cpp
msgbus_server_resolve_node.cpp
msgbus_server_ic_debug.cpp
msgbus_server_local_enumerate_tablets.cpp
msgbus_server_local_minikql.cpp
msgbus_server_local_scheme_tx.cpp
msgbus_server_node_registration.cpp
Expand Down
1 change: 0 additions & 1 deletion ydb/core/driver_lib/cli_utils/cli.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ namespace NDriverClient {

int SchemeInitRoot(TCommandConfig &cmdConf, int argc, char** argv);
int CompileAndExecMiniKQL(TCommandConfig &cmdConf, int argc, char **argv);
int KeyValueRequest(TCommandConfig &cmdConf, int argc, char **argv);
int PersQueueRequest(TCommandConfig &cmdConf, int argc, char **argv);
int PersQueueStress(TCommandConfig &cmdConf, int argc, char **argv);
int PersQueueDiscoverClustersRequest(TCommandConfig &cmdConf, int argc, char **argv);
Expand Down
Loading
Loading