This commit is contained in:
9
main.go
9
main.go
@@ -166,6 +166,15 @@ func main() {
|
|||||||
}
|
}
|
||||||
go rpcHandler.Serve()
|
go rpcHandler.Serve()
|
||||||
|
|
||||||
|
saveTimer := time.NewTicker(time.Second * 5)
|
||||||
|
go func() {
|
||||||
|
<-saveTimer.C
|
||||||
|
err := app.Save()
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("Error saving: %v\n", err)
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
syncedServer := NewPoolServer(syncedPool)
|
syncedServer := NewPoolServer(syncedPool)
|
||||||
mux := http.NewServeMux()
|
mux := http.NewServeMux()
|
||||||
mux.Handle("/api/", http.StripPrefix("/api", syncedServer.Serve()))
|
mux.Handle("/api/", http.StripPrefix("/api", syncedServer.Serve()))
|
||||||
|
|||||||
Reference in New Issue
Block a user