aboutsummaryrefslogtreecommitdiff
path: root/weed/notification/message_queue.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/notification/message_queue.go')
-rw-r--r--weed/notification/message_queue.go14
1 files changed, 14 insertions, 0 deletions
diff --git a/weed/notification/message_queue.go b/weed/notification/message_queue.go
new file mode 100644
index 000000000..18c4a8830
--- /dev/null
+++ b/weed/notification/message_queue.go
@@ -0,0 +1,14 @@
+package notification
+
+import (
+ "github.com/chrislusf/seaweedfs/weed/util"
+ "github.com/golang/protobuf/proto"
+)
+
+type MessageQueue interface {
+ // GetName gets the name to locate the configuration in message_queue.toml file
+ GetName() string
+ // Initialize initializes the file store
+ Initialize(configuration util.Configuration) error
+ SendMessage(key string, message proto.Message) error
+}