ref: a87c1c994f12dc502708a4722f5887ca802a16b2
server/yats.go
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 |
package main import ( "fmt" "os" "time" "yats-server/config" "yats-server/db" ) func main() { go maintenanceThread() startServer() } func maintenanceThread() { var sleeptime, _ = time.ParseDuration("60s") for { time.Sleep(sleeptime) metrics := db.LoadMetrics(db.Session) db.MetricToParquet(metrics, "/tmp/allmetrics.parquet") fmt.Printf("Maintenance Thread\n") } } func startServer() { configuration := config.GetConfig(os.Getenv("HOME") + "/.yats.json") db.Session = db.InitializeDb(configuration) RestService(configuration) } |