diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-09-16 01:18:30 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-09-16 01:18:30 -0700 |
| commit | d923ba2206a8238977e740f98f061242d61ed5e6 (patch) | |
| tree | a2fcaf40d5f2398b2b8ad3c2a77a22579597cc1c /weed/notification/message_queue.go | |
| parent | bea4f6ca14615de23ba81a84cf61ba0f2a28b7f6 (diff) | |
| download | seaweedfs-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.go | 14 |
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 +} |
