package main
|
|
import (
|
"basic.com/valib/logger.git"
|
_ "basic.com/valib/version.git"
|
"context"
|
"flag"
|
"vamicro/config"
|
"vamicro/serf-daemon/models"
|
"vamicro/serf-daemon/service"
|
)
|
|
var (
|
procName = "serf-daemon"
|
//proc = &bhomeclient.ProcInfo{
|
// Name: procName, //进程名称
|
// ID: procName, //进程id
|
// Info: "", //进程的描述信息，用于区分同一进程名称下多个进程
|
//}
|
env = flag.String("e", "pro", "")
|
)
|
|
func init() {
|
flag.Parse()
|
config.Init(*env)
|
// 日志初始化
|
var logFile = config.LogConf.Path + "vamicro-"+procName+".log"
|
logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
|
logger.Info("log init success !")
|
}
|
|
// serf1进程，集群内漂移ip的主节点才会启动此进程
|
// 多个集群之间通过此进程连接到一起组成二级集群,做数据统计和管理
|
// 内部包含有各个进程中的设备-应用-算法等数据
|
// 设备管理进程通过rpc调用此进程获取业务数据
|
// 此进程也可通过rpc获取serf0(system-service)中的数据
|
func main() {
|
flag.Parse()
|
models.Init()
|
defer models.CloseDB()
|
|
ctx := context.Background()
|
if err := service.Start(ctx);err != nil {
|
logger.Debug("err:", err)
|
return
|
}
|
select {
|
|
}
|
}
|
