#726: feat(plugin): new `jobs` plugin

#726: feat(plugin): new `jobs` plugin 

8 files changed, 25 insertions, 57 deletions

diff --git a/plugins/kv/drivers/boltdb/driver.go b/plugins/kv/drivers/boltdb/driver.go
index 47d37cc2..15a5674f 100644
--- a/plugins/kv/drivers/boltdb/driver.go
+++ b/plugins/kv/drivers/boltdb/driver.go
@@ -10,7 +10,6 @@ import (
 
 	"github.com/spiral/errors"
 	"github.com/spiral/roadrunner/v2/plugins/config"
-	"github.com/spiral/roadrunner/v2/plugins/kv"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 	kvv1 "github.com/spiral/roadrunner/v2/proto/kv/v1beta"
 	"github.com/spiral/roadrunner/v2/utils"
@@ -34,7 +33,7 @@ type Driver struct {
 	stop chan struct{}
 }
 
-func NewBoltDBDriver(log logger.Logger, key string, cfgPlugin config.Configurer, stop chan struct{}) (kv.Storage, error) {
+func NewBoltDBDriver(log logger.Logger, key string, cfgPlugin config.Configurer, stop chan struct{}) (*Driver, error) {
 	const op = errors.Op("new_boltdb_driver")
 
 	d := &Driver{
diff --git a/plugins/kv/drivers/boltdb/plugin.go b/plugins/kv/drivers/boltdb/plugin.go
index 6ae1a1f6..c839130f 100644
--- a/plugins/kv/drivers/boltdb/plugin.go
+++ b/plugins/kv/drivers/boltdb/plugin.go
@@ -2,12 +2,15 @@ package boltdb
 
 import (
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/common/kv"
 	"github.com/spiral/roadrunner/v2/plugins/config"
-	"github.com/spiral/roadrunner/v2/plugins/kv"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 )
 
-const PluginName = "boltdb"
+const (
+	PluginName     string = "boltdb"
+	RootPluginName string = "kv"
+)
 
 // Plugin BoltDB K/V storage.
 type Plugin struct {
@@ -21,7 +24,7 @@ type Plugin struct {
 }
 
 func (s *Plugin) Init(log logger.Logger, cfg config.Configurer) error {
-	if !cfg.Has(kv.PluginName) {
+	if !cfg.Has(RootPluginName) {
 		return errors.E(errors.Disabled)
 	}
 
diff --git a/plugins/kv/drivers/memcached/config.go b/plugins/kv/drivers/memcached/config.go
index 7aad53b6..6d413790 100644
--- a/plugins/kv/drivers/memcached/config.go
+++ b/plugins/kv/drivers/memcached/config.go
@@ -7,6 +7,6 @@ type Config struct {
 
 func (s *Config) InitDefaults() {
 	if s.Addr == nil {
-		s.Addr = []string{"localhost:11211"} // default url for memcached
+		s.Addr = []string{"127.0.0.1:11211"} // default url for memcached
 	}
 }
diff --git a/plugins/kv/drivers/memcached/driver.go b/plugins/kv/drivers/memcached/driver.go
index 14e7c078..e24747fe 100644
--- a/plugins/kv/drivers/memcached/driver.go
+++ b/plugins/kv/drivers/memcached/driver.go
@@ -7,7 +7,6 @@ import (
 	"github.com/bradfitz/gomemcache/memcache"
 	"github.com/spiral/errors"
 	"github.com/spiral/roadrunner/v2/plugins/config"
-	"github.com/spiral/roadrunner/v2/plugins/kv"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 	kvv1 "github.com/spiral/roadrunner/v2/proto/kv/v1beta"
 )
@@ -21,7 +20,7 @@ type Driver struct {
 // NewMemcachedDriver returns a memcache client using the provided server(s)
 // with equal weight. If a server is listed multiple times,
 // it gets a proportional amount of weight.
-func NewMemcachedDriver(log logger.Logger, key string, cfgPlugin config.Configurer) (kv.Storage, error) {
+func NewMemcachedDriver(log logger.Logger, key string, cfgPlugin config.Configurer) (*Driver, error) {
 	const op = errors.Op("new_memcached_driver")
 
 	s := &Driver{
diff --git a/plugins/kv/drivers/memcached/plugin.go b/plugins/kv/drivers/memcached/plugin.go
index 22ea5cca..59a2b7cb 100644
--- a/plugins/kv/drivers/memcached/plugin.go
+++ b/plugins/kv/drivers/memcached/plugin.go
@@ -2,12 +2,15 @@ package memcached
 
 import (
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/common/kv"
 	"github.com/spiral/roadrunner/v2/plugins/config"
-	"github.com/spiral/roadrunner/v2/plugins/kv"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 )
 
-const PluginName = "memcached"
+const (
+	PluginName     string = "memcached"
+	RootPluginName string = "kv"
+)
 
 type Plugin struct {
 	// config plugin
@@ -17,7 +20,7 @@ type Plugin struct {
 }
 
 func (s *Plugin) Init(log logger.Logger, cfg config.Configurer) error {
-	if !cfg.Has(kv.PluginName) {
+	if !cfg.Has(RootPluginName) {
 		return errors.E(errors.Disabled)
 	}
 
diff --git a/plugins/kv/interface.go b/plugins/kv/interface.go
deleted file mode 100644
index 5736a6a7..00000000
--- a/plugins/kv/interface.go
+++ /dev/null
@@ -1,39 +0,0 @@
-package kv
-
-import kvv1 "github.com/spiral/roadrunner/v2/proto/kv/v1beta"
-
-// Storage represents single abstract storage.
-type Storage interface {
-	// Has checks if value exists.
-	Has(keys ...string) (map[string]bool, error)
-
-	// Get loads value content into a byte slice.
-	Get(key string) ([]byte, error)
-
-	// MGet loads content of multiple values
-	// Returns the map with existing keys and associated values
-	MGet(keys ...string) (map[string][]byte, error)
-
-	// Set used to upload item to KV with TTL
-	// 0 value in TTL means no TTL
-	Set(items ...*kvv1.Item) error
-
-	// MExpire sets the TTL for multiply keys
-	MExpire(items ...*kvv1.Item) error
-
-	// TTL return the rest time to live for provided keys
-	// Not supported for the memcached
-	TTL(keys ...string) (map[string]string, error)
-
-	// Clear clean the entire storage
-	Clear() error
-
-	// Delete one or multiple keys.
-	Delete(keys ...string) error
-}
-
-// Constructor provides storage based on the config
-type Constructor interface {
-	// KVConstruct provides Storage based on the config key
-	KVConstruct(key string) (Storage, error)
-}
diff --git a/plugins/kv/plugin.go b/plugins/kv/plugin.go
index 03dbaed6..53fade97 100644
--- a/plugins/kv/plugin.go
+++ b/plugins/kv/plugin.go
@@ -5,10 +5,12 @@ import (
 
 	endure "github.com/spiral/endure/pkg/container"
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/common/kv"
 	"github.com/spiral/roadrunner/v2/plugins/config"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 )
 
+// PluginName linked to the memory, boltdb, memcached, redis plugins. DO NOT change w/o sync.
 const PluginName string = "kv"
 
 const (
@@ -25,9 +27,9 @@ const (
 type Plugin struct {
 	log logger.Logger
 	// constructors contains general storage constructors, such as boltdb, memory, memcached, redis.
-	constructors map[string]Constructor
+	constructors map[string]kv.Constructor
 	// storages contains user-defined storages, such as boltdb-north, memcached-us and so on.
-	storages map[string]Storage
+	storages map[string]kv.Storage
 	// KV configuration
 	cfg       Config
 	cfgPlugin config.Configurer
@@ -43,8 +45,8 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
 	if err != nil {
 		return errors.E(op, err)
 	}
-	p.constructors = make(map[string]Constructor, 5)
-	p.storages = make(map[string]Storage, 5)
+	p.constructors = make(map[string]kv.Constructor, 5)
+	p.storages = make(map[string]kv.Storage, 5)
 	p.log = log
 	p.cfgPlugin = cfg
 	return nil
@@ -78,7 +80,7 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit
 
 				  memcached:
 				    driver: memcached
-				    addr: [ "localhost:11211" ]
+				    addr: [ "127.0.0.1:11211" ]
 
 
 		For this config we should have 3 constructors: memory, boltdb and memcached but 4 KVs: default, boltdb-south, boltdb-north and memcached
@@ -203,7 +205,7 @@ func (p *Plugin) Collects() []interface{} {
 	}
 }
 
-func (p *Plugin) GetAllStorageDrivers(name endure.Named, constructor Constructor) {
+func (p *Plugin) GetAllStorageDrivers(name endure.Named, constructor kv.Constructor) {
 	// save the storage constructor
 	p.constructors[name.Name()] = constructor
 }
diff --git a/plugins/kv/rpc.go b/plugins/kv/rpc.go
index 3f7ba97c..ad4aefa9 100644
--- a/plugins/kv/rpc.go
+++ b/plugins/kv/rpc.go
@@ -2,6 +2,7 @@ package kv
 
 import (
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/common/kv"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 	kvv1 "github.com/spiral/roadrunner/v2/proto/kv/v1beta"
 )
@@ -9,7 +10,7 @@ import (
 // Wrapper for the plugin
 type rpc struct {
 	// all available storages
-	storages map[string]Storage
+	storages map[string]kv.Storage
 	// svc is a plugin implementing Storage interface
 	srv *Plugin
 	// Logger