- Update all main abstractions

- Desighn a new interfaces responsible for the whole PubSub
- New plugin - websockets

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

1 files changed, 0 insertions, 105 deletions

diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go
deleted file mode 100644
index 156bea80..00000000
--- a/plugins/broadcast/plugin.go
+++ /dev/null
@@ -1,105 +0,0 @@
-package broadcast
-
-import (
-	endure "github.com/spiral/endure/pkg/container"
-	"github.com/spiral/errors"
-	"github.com/spiral/roadrunner/v2/plugins/config"
-	"github.com/spiral/roadrunner/v2/plugins/logger"
-)
-
-const (
-	PluginName string = "broadcast"
-)
-
-type Plugin struct {
-	broker Subscriber
-	driver Storage
-
-	log logger.Logger
-	cfg *Config
-}
-
-func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
-	const op = errors.Op("broadcast_plugin_init")
-
-	if !cfg.Has(PluginName) {
-		return errors.E(op, errors.Disabled)
-	}
-
-	err := cfg.UnmarshalKey(PluginName, &p.cfg)
-	if err != nil {
-		return errors.E(op, errors.Disabled, err)
-	}
-
-	p.cfg.InitDefaults()
-
-	p.log = log
-	return nil
-}
-
-func (p *Plugin) Serve() chan error {
-	const op = errors.Op("broadcast_plugin_serve")
-	errCh := make(chan error)
-
-	// if there are no brokers, return nil
-	if p.broker == nil {
-		errCh <- errors.E(op, errors.Str("no broker detected"))
-		return errCh
-	}
-
-	if p.driver == nil {
-		// Or if no storage detected, use in-memory storage
-		errCh <- errors.E(op, errors.Str("no storage detected"))
-		return errCh
-	}
-
-	// start the underlying broker
-	go func() {
-		// err := p.broker.Serve()
-		// if err != nil {
-		// 	errCh <- errors.E(op, err)
-		// }
-	}()
-
-	return errCh
-}
-
-func (p *Plugin) Stop() error {
-	return nil
-}
-
-// Available interface implementation for the plugin
-func (p *Plugin) Available() {}
-
-// Name is endure.Named interface implementation
-func (p *Plugin) Name() string {
-	return PluginName
-}
-
-func (p *Plugin) Collects() []interface{} {
-	return []interface{}{
-		p.CollectSubscriber,
-	}
-}
-
-func (p *Plugin) CollectSubscriber(name endure.Named, subscriber Subscriber) {
-	p.broker = subscriber
-}
-
-func (p *Plugin) CollectStorage(name endure.Named, storage Storage) {
-	p.driver = storage
-}
-
-func (p *Plugin) RPC() interface{} {
-	// create an RPC service for the collects
-	r := &rpc{
-		log: p.log,
-		svc: p,
-	}
-	return r
-}
-
-func (p *Plugin) Publish(msg []*Message) error {
-	const op = errors.Op("broadcast_plugin_publish")
-	return nil
-}