update sources to v12.1.0

[ceph.git] / ceph / src / rgw / rgw_sync_module_es.h

diff --git a/ceph/src/rgw/rgw_sync_module_es.h b/ceph/src/rgw/rgw_sync_module_es.h
index 73c8368571d8d52d5a86a2e876dbeeab937718cd..43e591e42fc361b32fd1a9a09223caf0a3ce39f2 100644 (file)
--- a/ceph/src/rgw/rgw_sync_module_es.h
+++ b/ceph/src/rgw/rgw_sync_module_es.h
@@ -9,7 +9,20 @@ public:
   bool supports_data_export() override {
     return false;
   }
-  int create_instance(CephContext *cct, map<string, string>& config, RGWSyncModuleInstanceRef *instance) override;
+  int create_instance(CephContext *cct, map<string, string, ltstr_nocase>& config, RGWSyncModuleInstanceRef *instance) override;
+};
+
+class RGWElasticDataSyncModule;
+class RGWRESTConn;
+
+class RGWElasticSyncModuleInstance : public RGWSyncModuleInstance {
+  std::unique_ptr<RGWElasticDataSyncModule> data_handler;
+public:
+  RGWElasticSyncModuleInstance(CephContext *cct, const std::map<std::string, std::string, ltstr_nocase>& config);
+  RGWDataSyncModule *get_data_handler() override;
+  RGWRESTMgr *get_rest_filter(int dialect, RGWRESTMgr *orig) override;
+  RGWRESTConn *get_rest_conn();
+  std::string get_index_path();
 };
 
 #endif