blob: 454256b9b491cd3a5d3c0bd67382845935641850 (
plain)
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
package jobs
import (
"runtime"
poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
"github.com/spiral/roadrunner/v2/plugins/jobs/pipeline"
)
const (
// name used to set pipeline name
pipelineName string = "name"
)
// Config defines settings for job broker, workers and job-pipeline mapping.
type Config struct {
// NumPollers configures number of priority queue pollers
// Should be no more than 255
// Default - num logical cores
NumPollers uint8 `mapstructure:"num_pollers"`
// PipelineSize is the limit of a main jobs queue which consume Items from the drivers pipeline
// Driver pipeline might be much larger than a main jobs queue
PipelineSize uint64 `mapstructure:"pipeline_size"`
// Timeout in seconds is the per-push limit to put the job into queue
Timeout int `mapstructure:"timeout"`
// Pool configures roadrunner workers pool.
Pool *poolImpl.Config `mapstructure:"Pool"`
// Pipelines defines mapping between PHP job pipeline and associated job broker.
Pipelines map[string]*pipeline.Pipeline `mapstructure:"pipelines"`
// Consuming specifies names of pipelines to be consumed on service start.
Consume []string `mapstructure:"consume"`
}
func (c *Config) InitDefaults() {
if c.Pool == nil {
c.Pool = &poolImpl.Config{}
}
if c.PipelineSize == 0 {
c.PipelineSize = 1_000_000
}
if c.NumPollers == 0 {
c.NumPollers = uint8(runtime.NumCPU())
}
for k := range c.Pipelines {
// set the pipeline name
c.Pipelines[k].With(pipelineName, k)
}
if c.Timeout == 0 {
c.Timeout = 60
}
c.Pool.InitDefaults()
}
|
