summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--plugins/broadcast/config.go1
-rw-r--r--plugins/broadcast/memory/config.go2
-rw-r--r--plugins/broadcast/memory/driver.go5
-rw-r--r--plugins/broadcast/memory/plugin.go6
-rw-r--r--plugins/broadcast/plugin.go4
-rw-r--r--plugins/broadcast/rpc.go1
-rw-r--r--plugins/broadcast/ws/config.go2
7 files changed, 5 insertions, 16 deletions
diff --git a/plugins/broadcast/config.go b/plugins/broadcast/config.go
index 47dab4f9..92f7951d 100644
--- a/plugins/broadcast/config.go
+++ b/plugins/broadcast/config.go
@@ -1,7 +1,6 @@
package broadcast
type Config struct {
-
}
func (c *Config) InitDefaults() {
diff --git a/plugins/broadcast/memory/config.go b/plugins/broadcast/memory/config.go
index 840dbb96..e80695bc 100644
--- a/plugins/broadcast/memory/config.go
+++ b/plugins/broadcast/memory/config.go
@@ -1,6 +1,6 @@
package memory
// Config for the memory driver is empty, it's just a placeholder
-type Config struct {}
+type Config struct{}
func (c *Config) InitDefaults() {}
diff --git a/plugins/broadcast/memory/driver.go b/plugins/broadcast/memory/driver.go
index 29d67771..2eb45c8e 100644
--- a/plugins/broadcast/memory/driver.go
+++ b/plugins/broadcast/memory/driver.go
@@ -3,13 +3,10 @@ package memory
import "github.com/spiral/roadrunner/v2/plugins/broadcast"
type Driver struct {
-
}
func NewInMemoryDriver() broadcast.Subscriber {
- b := &Driver{
-
- }
+ b := &Driver{}
return b
}
diff --git a/plugins/broadcast/memory/plugin.go b/plugins/broadcast/memory/plugin.go
index 4ebeb4c8..2bd894a0 100644
--- a/plugins/broadcast/memory/plugin.go
+++ b/plugins/broadcast/memory/plugin.go
@@ -10,14 +10,13 @@ import (
)
const (
- PluginName string = "broadcast"
+ PluginName string = "broadcast"
SectionName string = "memory"
)
type Plugin struct {
log logger.Logger
cfg *Config
-
}
func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
@@ -46,7 +45,6 @@ func (p *Plugin) Serve() chan error {
const op = errors.Op("memory_plugin_serve")
errCh := make(chan error)
-
return errCh
}
@@ -64,8 +62,6 @@ func (p *Plugin) Name() string {
return fmt.Sprintf("%s.%s", PluginName, SectionName)
}
-
-
func (p *Plugin) Publish(msg []*broadcast.Message) error {
return nil
}
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go
index ec7c2587..7ad9e2ae 100644
--- a/plugins/broadcast/plugin.go
+++ b/plugins/broadcast/plugin.go
@@ -63,14 +63,13 @@ func (p *Plugin) Stop() error {
}
// Available interface implementation for the plugin
-func (p * Plugin) Available() {}
+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.CollectBroker,
@@ -94,4 +93,3 @@ func (p *Plugin) Publish(msg []*Message) error {
const op = errors.Op("broadcast_plugin_publish")
return nil
}
-
diff --git a/plugins/broadcast/rpc.go b/plugins/broadcast/rpc.go
index 92a2f368..948fd7ae 100644
--- a/plugins/broadcast/rpc.go
+++ b/plugins/broadcast/rpc.go
@@ -10,7 +10,6 @@ type rpc struct {
svc *Plugin
}
-
func (r *rpc) Publish(msg []*Message, ok *bool) error {
const op = errors.Op("broadcast_publish")
err := r.svc.Publish(msg)
diff --git a/plugins/broadcast/ws/config.go b/plugins/broadcast/ws/config.go
index 33da2485..98592950 100644
--- a/plugins/broadcast/ws/config.go
+++ b/plugins/broadcast/ws/config.go
@@ -1 +1 @@
-package ws \ No newline at end of file
+package ws