dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix interval estimation in vsphere input (#5726)

This commit is contained in:
Pontus Rydin 2019-05-07 14:52:24 -04:00 committed by Daniel Nelson
parent c2643d5f7e
commit aac4c29dc6
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
plugins/inputs/vsphere/endpoint.go
View File

@ -806,9 +806,17 @@ func (e *Endpoint) collectResource(ctx context.Context, resourceType string, acc
localNow := time.Now() localNow := time.Now()
estInterval := time.Duration(time.Minute) estInterval := time.Duration(time.Minute)
if !res.lastColl.IsZero() { if !res.lastColl.IsZero() {
estInterval = localNow.Sub(res.lastColl).Truncate(time.Duration(res.sampling) * time.Second) s := time.Duration(res.sampling) * time.Second
rawInterval := localNow.Sub(res.lastColl)
paddedInterval := rawInterval + time.Duration(res.sampling/2)*time.Second
estInterval = paddedInterval.Truncate(s)
if estInterval < s {
estInterval = s
}
log.Printf("D! [inputs.vsphere] Raw interval %s, padded: %s, estimated: %s", rawInterval, paddedInterval, estInterval)
} }
log.Printf("D! [inputs.vsphere] Interval estimated to %s", estInterval) log.Printf("D! [inputs.vsphere] Interval estimated to %s", estInterval)
res.lastColl = localNow
latest := res.latestSample latest := res.latestSample
if !latest.IsZero() { if !latest.IsZero() {