diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-09-16 01:37:35 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-09-16 01:37:35 -0700 |
| commit | bc03233364484653228066d9ea27b6e78ba640f6 (patch) | |
| tree | d0766aade4630dc9785d70cca22d4674af7b44a1 /weed/notification/configuration.go | |
| parent | d923ba2206a8238977e740f98f061242d61ed5e6 (diff) | |
| download | seaweedfs-bc03233364484653228066d9ea27b6e78ba640f6.tar.xz seaweedfs-bc03233364484653228066d9ea27b6e78ba640f6.zip | |
refactoring
Diffstat (limited to 'weed/notification/configuration.go')
| -rw-r--r-- | weed/notification/configuration.go | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/weed/notification/configuration.go b/weed/notification/configuration.go index 6ac693ad8..96087987d 100644 --- a/weed/notification/configuration.go +++ b/weed/notification/configuration.go @@ -3,8 +3,18 @@ package notification import ( "github.com/chrislusf/seaweedfs/weed/glog" "github.com/spf13/viper" + "github.com/chrislusf/seaweedfs/weed/util" + "github.com/golang/protobuf/proto" ) +type MessageQueue interface { + // GetName gets the name to locate the configuration in filer.toml file + GetName() string + // Initialize initializes the file store + Initialize(configuration util.Configuration) error + SendMessage(key string, message proto.Message) error +} + var ( MessageQueues []MessageQueue |