mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-05 06:23:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

migration_manager: add prepare_new_function_announcement() function

Browse Source 
The function only generates mutations for the announcement, but does not
send them out. Will be used by the later patches.
This commit is contained in:
Gleb Natapov
2021-11-24 10:13:27 +02:00
parent 9ec0db660c
commit 10c14cd044
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
service/migration_manager.cc
View File

@@ -767,11 +767,15 @@ future<> migration_manager::announce_type_update(user_type updated_type) {
return do_announce_new_type(updated_type);
}
future<> migration_manager::announce_new_function(shared_ptr<cql3::functions::user_function> func) {
future<std::vector<mutation>> migration_manager::prepare_new_function_announcement(shared_ptr<cql3::functions::user_function> func) {
auto& db = get_local_storage_proxy().get_db().local();
auto&& keyspace = db.find_keyspace(func->name().keyspace);
auto mutations = db::schema_tables::make_create_function_mutations(func, api::new_timestamp());
return include_keyspace_and_announce(*keyspace.metadata(), std::move(mutations));
return include_keyspace(*keyspace.metadata(), std::move(mutations));
}
future<> migration_manager::announce_new_function(shared_ptr<cql3::functions::user_function> func) {
co_return co_await announce(co_await prepare_new_function_announcement(std::move(func)));
}
future<> migration_manager::announce_function_drop(

1
service/migration_manager.hh
View File

@@ -150,6 +150,7 @@ public:
future<> announce_new_type(user_type new_type);
future<> announce_new_function(shared_ptr<cql3::functions::user_function> func);
future<std::vector<mutation>> prepare_new_function_announcement(shared_ptr<cql3::functions::user_function> func);
future<> announce_new_aggregate(shared_ptr<cql3::functions::user_aggregate> aggregate);