From 1a2a1f4735e40675abf6cd9767c99374359ec2bb Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Tue, 22 Jun 2021 11:44:22 +0300 Subject: - Remove all old code, reformat, fix linters, return GA Signed-off-by: Valery Piashchynski --- plugins/jobs/plugin.go | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'plugins/jobs/plugin.go') diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index 42203871..cda2a711 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -1,10 +1,14 @@ package jobs import ( + "context" + endure "github.com/spiral/endure/pkg/container" "github.com/spiral/errors" + "github.com/spiral/roadrunner/v2/pkg/pool" "github.com/spiral/roadrunner/v2/plugins/config" "github.com/spiral/roadrunner/v2/plugins/logger" + "github.com/spiral/roadrunner/v2/plugins/server" ) const ( @@ -15,10 +19,12 @@ type Plugin struct { cfg *Config log logger.Logger + workersPool pool.Pool + consumers map[string]Consumer } -func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error { +func (p *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Server) error { const op = errors.Op("jobs_plugin_init") if !cfg.Has(PluginName) { return errors.E(op, errors.Disabled) @@ -29,6 +35,11 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error { return errors.E(op, err) } + p.workersPool, err = server.NewWorkerPool(context.Background(), p.cfg.poolCfg, nil, nil) + if err != nil { + return errors.E(op, err) + } + p.consumers = make(map[string]Consumer) p.log = log return nil -- cgit v1.2.3