- fmd-ed all

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

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