cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

monitor config: make threshold optional in the configuration

Browse Source 
takes default when not set.
This commit is contained in:
Hector Sanjuan 2019-05-16 12:52:40 +02:00
parent 2f6a839642
commit 6caf78a57b
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
monitor/pubsubmon/config.go
View File

@ -30,8 +30,8 @@ type Config struct {
}
type jsonConfig struct {
CheckInterval string `json:"check_interval"`
FailureThreshold float64 `json:"failure_threshold"`
CheckInterval string `json:"check_interval"`
FailureThreshold *float64 `json:"failure_threshold"`
}
// ConfigKey provides a human-friendly identifier for this type of Config.
@ -91,7 +91,9 @@ func (cfg *Config) LoadJSON(raw []byte) error {
func (cfg *Config) applyJSONConfig(jcfg *jsonConfig) error {
interval, _ := time.ParseDuration(jcfg.CheckInterval)
cfg.CheckInterval = interval
cfg.FailureThreshold = jcfg.FailureThreshold
if jcfg.FailureThreshold != nil {
cfg.FailureThreshold = *jcfg.FailureThreshold
}
return cfg.Validate()
}
@ -106,6 +108,6 @@ func (cfg *Config) ToJSON() ([]byte, error) {
func (cfg *Config) toJSONConfig() *jsonConfig {
return &jsonConfig{
CheckInterval: cfg.CheckInterval.String(),
FailureThreshold: cfg.FailureThreshold,
FailureThreshold: &cfg.FailureThreshold,
}
}