summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/config.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/config.go')
-rw-r--r--plugins/jobs/oooold/config.go91
1 files changed, 0 insertions, 91 deletions
diff --git a/plugins/jobs/oooold/config.go b/plugins/jobs/oooold/config.go
deleted file mode 100644
index cf40b6fb..00000000
--- a/plugins/jobs/oooold/config.go
+++ /dev/null
@@ -1,91 +0,0 @@
-package oooold
-
-import (
- "fmt"
- "github.com/spiral/roadrunner"
- "github.com/spiral/roadrunner/service"
-)
-
-// Config defines settings for job broker, workers and job-pipeline mapping.
-type Config struct {
- // Workers configures roadrunner server and worker busy.
- Workers *roadrunner.ServerConfig
-
- // Dispatch defines where and how to match jobs.
- Dispatch map[string]*Options
-
- // Pipelines defines mapping between PHP job pipeline and associated job broker.
- Pipelines map[string]*Pipeline
-
- // Consuming specifies names of pipelines to be consumed on service start.
- Consume []string
-
- // parent config for broken options.
- parent service.Config
- pipelines Pipelines
- route Dispatcher
-}
-
-// Hydrate populates config values.
-func (c *Config) Hydrate(cfg service.Config) (err error) {
- c.Workers = &roadrunner.ServerConfig{}
- c.Workers.InitDefaults()
-
- if err := cfg.Unmarshal(&c); err != nil {
- return err
- }
-
- c.pipelines, err = initPipelines(c.Pipelines)
- if err != nil {
- return err
- }
-
- if c.Workers.Command != "" {
- if err := c.Workers.Pool.Valid(); err != nil {
- return c.Workers.Pool.Valid()
- }
- }
-
- c.parent = cfg
- c.route = initDispatcher(c.Dispatch)
-
- return nil
-}
-
-// MatchPipeline locates the pipeline associated with the job.
-func (c *Config) MatchPipeline(job *Job) (*Pipeline, *Options, error) {
- opt := c.route.match(job)
-
- pipe := ""
- if job.Options != nil {
- pipe = job.Options.Pipeline
- }
-
- if pipe == "" && opt != nil {
- pipe = opt.Pipeline
- }
-
- if pipe == "" {
- return nil, nil, fmt.Errorf("unable to locate pipeline for `%s`", job.Job)
- }
-
- if p := c.pipelines.Get(pipe); p != nil {
- return p, opt, nil
- }
-
- return nil, nil, fmt.Errorf("undefined pipeline `%s`", pipe)
-}
-
-// Get underlying broker config.
-func (c *Config) Get(service string) service.Config {
- if c.parent == nil {
- return nil
- }
-
- return c.parent.Get(service)
-}
-
-// Unmarshal is doing nothing.
-func (c *Config) Unmarshal(out interface{}) error {
- return nil
-}