1234567891011121314151617181920212223242526272829303132333435363738 |
- package main
- import (
- commonConfig "cicv-data-closedloop/pji/common/cfg"
- commonInit "cicv-data-closedloop/pji/common/init"
- commonService "cicv-data-closedloop/pji/common/svc"
- masterConfig "cicv-data-closedloop/pji/master/pkg/cfg"
- masterService "cicv-data-closedloop/pji/master/pkg/svc"
- "runtime"
- "time"
- )
- func init() {
- runtime.GOMAXPROCS(1)
- commonInit.Init()
- masterConfig.InitTriggerConfig()
- commonConfig.InitKillSignalListener(commonConfig.CloudConfig.Hosts[0].Ip)
-
- go commonService.WaitKillSelf()
- masterConfig.InitNacos()
- }
- func main() {
-
- go commonService.BagRecord(commonConfig.CloudConfig.Hosts[0].Name)
- time.Sleep(time.Duration(10) * time.Second)
-
- go masterService.PrepareTimeWindowProducerQueue()
-
- go masterService.RunTimeWindowProducerQueue()
-
- go commonService.RunTimeWindowConsumerQueue(commonConfig.CloudConfig.Hosts[0].Name)
-
- select {}
- }
|