add WIP filer.replicate

1 files changed, 18 insertions, 0 deletions

diff --git a/weed/replication/notifications.go b/weed/replication/notifications.go
new file mode 100644
index 000000000..ff40c3aad
--- /dev/null
+++ b/weed/replication/notifications.go
@@ -0,0 +1,18 @@
+package replication
+
+import (
+	"github.com/chrislusf/seaweedfs/weed/util"
+	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+)
+
+type NotificationInput interface {
+	// GetName gets the name to locate the configuration in sync.toml file
+	GetName() string
+	// Initialize initializes the file store
+	Initialize(configuration util.Configuration) error
+	ReceiveMessage() (key string, message *filer_pb.EventNotification, err error)
+}
+
+var (
+	NotificationInputs []NotificationInput
+)