summaryrefslogtreecommitdiff
path: root/plugins/jobs/config.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-05 18:44:29 +0300
committerValery Piashchynski <[email protected]>2021-07-05 18:44:29 +0300
commit207739f7346c98e16087547bc510e1f909671260 (patch)
tree5c6eac27beb4eb5e127c7d8dae3464edb3359be9 /plugins/jobs/config.go
parent300166eda7b138847008a7653f90753bd8397b9e (diff)
- Update PQ
- Update ephemeral plugin, complete Push - Add Jobs full configuration Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/config.go')
-rw-r--r--plugins/jobs/config.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/plugins/jobs/config.go b/plugins/jobs/config.go
index 87e36ecb..1cb2c2a2 100644
--- a/plugins/jobs/config.go
+++ b/plugins/jobs/config.go
@@ -9,19 +9,19 @@ import (
type Config struct {
// Workers configures roadrunner server and worker busy.
// Workers *roadrunner.ServerConfig
- poolCfg *poolImpl.Config
+ Pool *poolImpl.Config `mapstructure:"Pool"`
// Pipelines defines mapping between PHP job pipeline and associated job broker.
- Pipelines map[string]*pipeline.Pipeline
+ Pipelines map[string]*pipeline.Pipeline `mapstructure:"pipelines"`
// Consuming specifies names of pipelines to be consumed on service start.
- Consume []string
+ Consume []string `mapstructure:"consume"`
}
func (c *Config) InitDefaults() {
- if c.poolCfg == nil {
- c.poolCfg = &poolImpl.Config{}
+ if c.Pool == nil {
+ c.Pool = &poolImpl.Config{}
}
- c.poolCfg.InitDefaults()
+ c.Pool.InitDefaults()
}