Move default ratelimit to init
This commit is contained in:
parent
5b52bd076f
commit
9aebad4a72
|
@ -120,8 +120,6 @@ func (c *CloudWatch) Description() string {
|
|||
}
|
||||
|
||||
func (c *CloudWatch) Gather(acc telegraf.Accumulator) error {
|
||||
c.setDefaultValues()
|
||||
|
||||
if c.client == nil {
|
||||
c.initializeCloudWatch()
|
||||
}
|
||||
|
@ -199,17 +197,12 @@ func (c *CloudWatch) Gather(acc telegraf.Accumulator) error {
|
|||
return errChan.Error()
|
||||
}
|
||||
|
||||
func (c *CloudWatch) setDefaultValues() {
|
||||
if c.RateLimit == 0 {
|
||||
c.RateLimit = 10
|
||||
}
|
||||
}
|
||||
|
||||
func init() {
|
||||
inputs.Add("cloudwatch", func() telegraf.Input {
|
||||
ttl, _ := time.ParseDuration("1hr")
|
||||
return &CloudWatch{
|
||||
CacheTTL: internal.Duration{Duration: ttl},
|
||||
RateLimit: 10,
|
||||
}
|
||||
})
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue