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
56
57
58
59
60
|
// SPDX-License-Identifier: GPL-3.0-or-later
package discover
import (
"time"
rs "github.com/netdata/netdata/go/go.d.plugin/modules/vsphere/resources"
)
func (d Discoverer) matchHost(host *rs.Host) bool {
if d.HostMatcher == nil {
return true
}
return d.HostMatcher.Match(host)
}
func (d Discoverer) matchVM(vm *rs.VM) bool {
if d.VMMatcher == nil {
return true
}
return d.VMMatcher.Match(vm)
}
func (d Discoverer) removeUnmatched(res *rs.Resources) (removed int) {
d.Debug("discovering : filtering : starting filtering resources process")
t := time.Now()
numH, numV := len(res.Hosts), len(res.VMs)
removed += d.removeUnmatchedHosts(res.Hosts)
removed += d.removeUnmatchedVMs(res.VMs)
d.Infof("discovering : filtering : filtered %d/%d hosts, %d/%d vms, process took %s",
numH-len(res.Hosts),
numH,
numV-len(res.VMs),
numV,
time.Since(t))
return
}
func (d Discoverer) removeUnmatchedHosts(hosts rs.Hosts) (removed int) {
for _, v := range hosts {
if !d.matchHost(v) {
removed++
hosts.Remove(v.ID)
}
}
d.Debugf("discovering : filtering : removed %d unmatched hosts", removed)
return removed
}
func (d Discoverer) removeUnmatchedVMs(vms rs.VMs) (removed int) {
for _, v := range vms {
if !d.matchVM(v) {
removed++
vms.Remove(v.ID)
}
}
d.Debugf("discovering : filtering : removed %d unmatched vms", removed)
return removed
}
|
