ref: 1fb480ce72eacc96d9f7495d67b9b0ec0313fd41
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 35 36 |
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) for i := range metrics { db.MetricToParquet(metrics[i], "/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) } |