blob: dcd317773f40e194cec61e452f2abea03f45f419 (
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
|
package watcher
import (
"fmt"
"github.com/spiral/roadrunner"
"github.com/spiral/roadrunner/service"
"time"
)
// Configures set of Services.
type Config struct {
// Interval defines the update duration for underlying watchers, default 1s.
Interval time.Duration
// Services declares list of services to be watched.
Services map[string]*watcherConfig
}
// Hydrate must populate Config values using given Config source. Must return error if Config is not valid.
func (c *Config) Hydrate(cfg service.Config) error {
if err := cfg.Unmarshal(c); err != nil {
return err
}
// Always use second based definition for time durations
if c.Interval < time.Microsecond {
c.Interval = time.Second * time.Duration(c.Interval.Nanoseconds())
}
for name, cfg := range c.Services {
if err := cfg.Normalize(); err != nil {
return fmt.Errorf("invalid watcher `%s`: %s", name, err.Error())
}
}
return nil
}
// InitDefaults sets missing values to their default values.
func (c *Config) InitDefaults() error {
c.Interval = time.Second
return nil
}
// Watchers returns list of defined Services
func (c *Config) Watchers(l listener) (watchers map[string]roadrunner.Watcher) {
watchers = make(map[string]roadrunner.Watcher)
for name, cfg := range c.Services {
watchers[name] = &watcher{lsn: l, interval: c.Interval, cfg: cfg}
}
return watchers
}
|
