diff options
Diffstat (limited to 'msb2pilot/src/msb2pilot/main.go')
-rw-r--r-- | msb2pilot/src/msb2pilot/main.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/msb2pilot/src/msb2pilot/main.go b/msb2pilot/src/msb2pilot/main.go index 7ed762c..708e88c 100644 --- a/msb2pilot/src/msb2pilot/main.go +++ b/msb2pilot/src/msb2pilot/main.go @@ -12,10 +12,10 @@ package main import ( - "fmt" "msb2pilot/consul" "msb2pilot/log" "msb2pilot/models" + "msb2pilot/pilot" _ "msb2pilot/routers" "time" @@ -37,5 +37,7 @@ func syncConsulData() { } func syncMsbData(newServices []*models.MsbService) { - fmt.Println(len(newServices), "services updated", time.Now()) + stop := make(chan struct{}) + monitor := consul.NewConsulMonitor(nil, 20*time.Second, pilot.SyncMsbData) + monitor.Start(stop) } |