Beanstalk initial commit

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

1 files changed, 20 insertions, 2 deletions

diff --git a/plugins/jobs/drivers/beanstalk/plugin.go b/plugins/jobs/drivers/beanstalk/plugin.go
index 2fea1c31..529d1474 100644
--- a/plugins/jobs/drivers/beanstalk/plugin.go
+++ b/plugins/jobs/drivers/beanstalk/plugin.go
@@ -9,6 +9,10 @@ import (
 	"github.com/spiral/roadrunner/v2/plugins/logger"
 )
 
+const (
+	pluginName string = "beanstalk"
+)
+
 type Plugin struct {
 	log logger.Logger
 	cfg config.Configurer
@@ -20,10 +24,24 @@ func (p *Plugin) Init(log logger.Logger, cfg config.Configurer) error {
 	return nil
 }
 
+func (p *Plugin) Serve() chan error {
+	return make(chan error)
+}
+
+func (p *Plugin) Stop() error {
+	return nil
+}
+
+func (p *Plugin) Name() string {
+	return pluginName
+}
+
+func (p *Plugin) Available() {}
+
 func (p *Plugin) JobsConstruct(configKey string, eh events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error) {
-	return nil, nil
+	return NewBeanstalkConsumer(configKey, p.log, p.cfg, eh, pq)
 }
 
 func (p *Plugin) FromPipeline(pipe *pipeline.Pipeline, eh events.Handler, pq priorityqueue.Queue) (jobs.Consumer, error) {
-	return nil, nil
+	return FromPipeline(pipe, p.log, p.cfg, eh, pq)
 }