common_init_finish(g_ceph_context);
std::unique_ptr<rgw::sal::ConfigStore> cfgstore;
+ std::unique_ptr<rgw::SiteConfig> site;
if (args.empty()) {
usage();
return EIO;
}
- std::unique_ptr<rgw::SiteConfig> site;
-
if (raw_storage_op) {
site = rgw::SiteConfig::make_fake();
driver = DriverManager::get_raw_storage(dpp(), g_ceph_context,
}
if (opt_cmd == OPT::PUBSUB_TOPIC_LIST) {
- auto site = std::make_unique<rgw::SiteConfig>();
- ret = site->load(dpp(), null_yield, cfgstore.get());
- if (ret < 0) {
- std::cerr << "Unable to initialize site config." << std::endl;
- exit(1);
- }
RGWPubSub ps(driver, tenant, &site->get_period()->get_map().zonegroups);
rgw_pubsub_topics result;
ret = ps.get_topics(dpp(), result, null_yield);
cerr << "ERROR: topic name was not provided (via --topic)" << std::endl;
return EINVAL;
}
- auto site = std::make_unique<rgw::SiteConfig>();
- ret = site->load(dpp(), null_yield, cfgstore.get());
- if (ret < 0) {
- std::cerr << "Unable to initialize site config." << std::endl;
- exit(1);
- }
RGWPubSub ps(driver, tenant, &site->get_period()->get_map().zonegroups);
rgw_pubsub_topic topic;
return -ret;
}
- auto site = std::make_unique<rgw::SiteConfig>();
- ret = site->load(dpp(), null_yield, cfgstore.get());
- if (ret < 0) {
- std::cerr << "Unable to initialize site config." << std::endl;
- exit(1);
- }
RGWPubSub ps(driver, tenant, &site->get_period()->get_map().zonegroups);
ret = ps.remove_topic(dpp(), topic_name, null_yield);