|
|
|
@ -2479,6 +2479,11 @@ func (a *Agent) DisableNodeMaintenance() {
|
|
|
|
|
a.logger.Printf("[INFO] agent: Node left maintenance mode")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (a *Agent) loadLimits(conf *config.RuntimeConfig) {
|
|
|
|
|
a.config.RPCRateLimit = conf.RPCRateLimit
|
|
|
|
|
a.config.RPCMaxBurst = conf.RPCMaxBurst
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (a *Agent) ReloadConfig(newCfg *config.RuntimeConfig) error {
|
|
|
|
|
// Bulk update the services and checks
|
|
|
|
|
a.PauseSync()
|
|
|
|
@ -2513,6 +2518,8 @@ func (a *Agent) ReloadConfig(newCfg *config.RuntimeConfig) error {
|
|
|
|
|
return fmt.Errorf("Failed reloading watches: %v", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
a.loadLimits(newCfg)
|
|
|
|
|
|
|
|
|
|
// Update filtered metrics
|
|
|
|
|
metrics.UpdateFilter(newCfg.TelemetryAllowedPrefixes, newCfg.TelemetryBlockedPrefixes)
|
|
|
|
|
|
|
|
|
|