1 files changed, 36 insertions, 0 deletions
diff --git a/plugins/broadcast/root/broker.go b/plugins/broadcast/root/broker.go
new file mode 100644
index 00000000..923c8105
--- /dev/null
+++ b/plugins/broadcast/root/broker.go
@@ -0,0 +1,36 @@
+package broadcast
+
+import "encoding/json"
+
+// Broker defines the ability to operate as message passing broker.
+type Broker interface {
+	// Serve serves broker.
+	Serve() error
+
+	// Stop closes the consumption and disconnects broker.
+	Stop()
+
+	// Subscribe broker to one or multiple topics.
+	Subscribe(upstream chan *Message, topics ...string) error
+
+	// SubscribePattern broker to pattern.
+	SubscribePattern(upstream chan *Message, pattern string) error
+
+	// Unsubscribe broker from one or multiple topics.
+	Unsubscribe(upstream chan *Message, topics ...string) error
+
+	// UnsubscribePattern broker from pattern.
+	UnsubscribePattern(upstream chan *Message, pattern string) error
+
+	// Publish one or multiple Channel.
+	Publish(messages ...*Message) error
+}
+
+// Message represent single message.
+type Message struct {
+	// Topic message been pushed into.
+	Topic string `json:"topic"`
+
+	// Payload to be broadcasted. Must be valid json when transferred over RPC.
+	Payload json.RawMessage `json:"payload"`
+}