From f036ef8a3c50af3c933dcd96026ca70dc5fd0da3 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Mon, 13 Aug 2018 01:20:49 -0700 Subject: add filer notification --- weed/msgqueue/message_queue.go | 11 +++++++++++ 1 file changed, 11 insertions(+) create mode 100644 weed/msgqueue/message_queue.go (limited to 'weed/msgqueue/message_queue.go') diff --git a/weed/msgqueue/message_queue.go b/weed/msgqueue/message_queue.go new file mode 100644 index 000000000..6d57b9b3b --- /dev/null +++ b/weed/msgqueue/message_queue.go @@ -0,0 +1,11 @@ +package msgqueue + +import "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 Configuration) error + SendMessage(key string, message proto.Message) error +} -- cgit v1.2.3