INNER CODE UNIT · Go
func
Edgio/vflow · disc/disc.go:169
func (d *Discovery) Nodes() []string {
var servers []string
now := time.Now().Unix()
d.mu.Lock()
for ip, server := range d.vFlowServers {
if now-server.timestamp < 300 {
servers = append(servers, ip)
} else {
delete(d.vFlowServers, ip)
}
}
d.mu.Unlock()
return servers