1 files changed, 43 insertions, 0 deletions
diff --git a/src/rgw/rgw_sync_module_pubsub.h b/src/rgw/rgw_sync_module_pubsub.h
new file mode 100644
index 000000000..8acc1a626
--- /dev/null
+++ b/src/rgw/rgw_sync_module_pubsub.h
@@ -0,0 +1,43 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab ft=cpp
+
+#ifndef CEPH_RGW_SYNC_MODULE_PUBSUB_H
+#define CEPH_RGW_SYNC_MODULE_PUBSUB_H
+
+#include "rgw_sync_module.h"
+
+class RGWPSSyncModule : public RGWSyncModule {
+public:
+  RGWPSSyncModule() {}
+  bool supports_data_export() override {
+    return false;
+  }
+  bool supports_writes() override {
+    return true;
+  }
+  int create_instance(CephContext *cct, const JSONFormattable& config, RGWSyncModuleInstanceRef *instance) override;
+};
+
+class RGWPSDataSyncModule;
+class RGWRESTConn;
+
+class RGWPSSyncModuleInstance : public RGWSyncModuleInstance {
+  std::unique_ptr<RGWPSDataSyncModule> data_handler;
+  JSONFormattable effective_conf;
+public:
+  RGWPSSyncModuleInstance(CephContext *cct, const JSONFormattable& config);
+  ~RGWPSSyncModuleInstance() = default;
+  RGWDataSyncModule *get_data_handler() override;
+  RGWRESTMgr *get_rest_filter(int dialect, RGWRESTMgr *orig) override;
+  bool supports_user_writes() override {
+    return true;
+  }
+  const JSONFormattable& get_effective_conf() {
+    return effective_conf;
+  }
+  // start with full sync based on configuration
+  // default to incremental only
+  virtual bool should_full_sync() const override;
+};
+
+#endif