Merge pull request #5220 from VadimPlh/move_feature_table

Move feature_table outside from controller

src/v/cluster/controller.cc

@@ -58,6 +58,7 @@ controller::controller(
   ss::sharded<storage::node_api>& storage_node,
   ss::sharded<raft::group_manager>& raft_manager,
   ss::sharded<v8_engine::data_policy_table>& data_policy_table,
+  ss::sharded<feature_table>& feature_table,
   ss::sharded<cloud_storage::remote>& cloud_storage_api)
   : _config_preload(std::move(config_preload))
   , _connections(ccache)
@@ -69,12 +70,12 @@ controller::controller(
   , _security_manager(_credentials, _authorizer)
   , _data_policy_manager(data_policy_table)
   , _raft_manager(raft_manager)
+  , _feature_table(feature_table)
   , _cloud_storage_api(cloud_storage_api) {}
 
 ss::future<> controller::wire_up() {
     return _as.start()
       .then([this] { return _members_table.start(); })
-      .then([this] { return _feature_table.start(); })
       .then([this] {
           return _partition_allocator.start_single(
             std::ref(_members_table),
@@ -374,7 +375,6 @@ ss::future<> controller::stop() {
           .then([this] { return _drain_manager.stop(); })
           .then([this] { return _partition_allocator.stop(); })
           .then([this] { return _partition_leaders.stop(); })
-          .then([this] { return _feature_table.stop(); })
           .then([this] { return _members_table.stop(); })
           .then([this] { return _as.stop(); });
     });

src/v/cluster/controller.h

@@ -38,6 +38,7 @@ class controller {
       ss::sharded<storage::node_api>& storage_node,
       ss::sharded<raft::group_manager>&,
       ss::sharded<v8_engine::data_policy_table>&,
+      ss::sharded<feature_table>&,
       ss::sharded<cloud_storage::remote>&);
 
     model::node_id self() { return _raft0->self().id(); }
@@ -152,7 +153,7 @@ class controller {
     ss::sharded<metrics_reporter> _metrics_reporter;
     ss::sharded<feature_manager> _feature_manager; // single instance
     ss::sharded<feature_backend> _feature_backend; // instance per core
-    ss::sharded<feature_table> _feature_table;     // instance per core
+    ss::sharded<feature_table>& _feature_table;    // instance per core
     std::unique_ptr<leader_balancer> _leader_balancer;
     consensus_ptr _raft0;
     ss::sharded<cloud_storage::remote>& _cloud_storage_api;

src/v/redpanda/application.cc

@@ -708,6 +708,9 @@ void application::wire_up_redpanda_services() {
         cloud_configs.stop().get();
     }
 
+    syschecks::systemd_message("Creating feature table").get();
+    construct_service(_feature_table).get();
+
     syschecks::systemd_message("Adding partition manager").get();
     construct_service(
       partition_manager,
@@ -738,6 +741,7 @@ void application::wire_up_redpanda_services() {
       storage_node,
       std::ref(raft_group_manager),
       data_policies,
+      std::ref(_feature_table),
       std::ref(cloud_storage_api));
 
     controller->wire_up().get0();
@@ -847,6 +851,7 @@ void application::wire_up_redpanda_services() {
           make_upload_controller_config(_scheduling_groups.archival_upload()))
           .get();
     }
+
     // group membership
     syschecks::systemd_message("Creating partition manager").get();
     construct_service(

src/v/redpanda/application.h

@@ -157,6 +157,7 @@ class application {
     ss::logger _log;
 
     ss::sharded<rpc::connection_cache> _connection_cache;
+    ss::sharded<cluster::feature_table> _feature_table;
     ss::sharded<kafka::group_manager> _group_manager;
     ss::sharded<kafka::group_manager> _co_group_manager;
     ss::sharded<net::server> _rpc;