aboutsummaryrefslogtreecommitdiff
path: root/weed/notification/message_queue.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-16 01:18:30 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-16 01:18:30 -0700
commitd923ba2206a8238977e740f98f061242d61ed5e6 (patch)
treea2fcaf40d5f2398b2b8ad3c2a77a22579597cc1c /weed/notification/message_queue.go
parentbea4f6ca14615de23ba81a84cf61ba0f2a28b7f6 (diff)
downloadseaweedfs-d923ba2206a8238977e740f98f061242d61ed5e6.tar.xz
seaweedfs-d923ba2206a8238977e740f98f061242d61ed5e6.zip
renaming msgqueue to notification
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
+}