Remove fetch server, add monitor callback
parent
36e5b39529
commit
b5ff055505
10
main.go
10
main.go
|
|
@ -65,12 +65,12 @@ func main() {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
if err := fetcher.Start(); err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
defer fetcher.Stop()
|
|
||||||
|
|
||||||
mon, err := monitor.New(config.MonitorPort)
|
mon, err := monitor.New(config.MonitorPort, func(url string) {
|
||||||
|
if err := fetcher.FetchProcess(url); err != nil {
|
||||||
|
logger.Logf("error fetching %q: %v", url, err)
|
||||||
|
}
|
||||||
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue