diff options
Diffstat (limited to 'plugins/broadcast/plugin.go')
-rw-r--r-- | plugins/broadcast/plugin.go | 105 |
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 -} |