plugins/jobs/config.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

package jobs

import (
	poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
	"github.com/spiral/roadrunner/v2/plugins/jobs/pipeline"
)

// Config defines settings for job broker, workers and job-pipeline mapping.
type Config struct {
	// Workers configures roadrunner server and worker busy.
	// Workers *roadrunner.ServerConfig
	poolCfg *poolImpl.Config

	// Pipelines defines mapping between PHP job pipeline and associated job broker.
	Pipelines map[string]*pipeline.Pipeline

	// Consuming specifies names of pipelines to be consumed on service start.
	Consume []string
}

func (c *Config) InitDefaults() {
	if c.poolCfg == nil {
		c.poolCfg = &poolImpl.Config{}
	}

	c.poolCfg.InitDefaults()
}