- Update arch diagramm

- Update config

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 8 insertions, 8 deletions

diff --git a/plugins/broadcast/interface.go b/plugins/broadcast/interface.go
index 923c8105..093943af 100644
--- a/plugins/broadcast/interface.go
+++ b/plugins/broadcast/interface.go
@@ -2,14 +2,8 @@ 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()
-
+// Subscriber defines the ability to operate as message passing broker.
+type Subscriber interface {
 	// Subscribe broker to one or multiple topics.
 	Subscribe(upstream chan *Message, topics ...string) error
 
@@ -21,7 +15,13 @@ type Broker interface {
 
 	// UnsubscribePattern broker from pattern.
 	UnsubscribePattern(upstream chan *Message, pattern string) error
+}
+
+type Storage interface {
+
+}
 
+type Publisher interface {
 	// Publish one or multiple Channel.
 	Publish(messages ...*Message) error
 }