mirror of https://github.com/shunfei/cronsun
commit
503f8b9a79
11
common.go
11
common.go
|
@ -1,6 +1,7 @@
|
||||||
package cronsun
|
package cronsun
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
"github.com/shunfei/cronsun/conf"
|
"github.com/shunfei/cronsun/conf"
|
||||||
|
@ -20,22 +21,24 @@ func Init() (err error) {
|
||||||
|
|
||||||
// init id creator
|
// init id creator
|
||||||
if err = initID(); err != nil {
|
if err = initID(); err != nil {
|
||||||
return
|
return fmt.Errorf("Init UUID Generator failed: %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// init config
|
// init config
|
||||||
if err = conf.Init(); err != nil {
|
if err = conf.Init(); err != nil {
|
||||||
return
|
return fmt.Errorf("Init Config failed: %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// init etcd client
|
// init etcd client
|
||||||
if DefalutClient, err = NewClient(conf.Config); err != nil {
|
if DefalutClient, err = NewClient(conf.Config); err != nil {
|
||||||
return
|
return fmt.Errorf("Connect to ETCD %s failed: %s",
|
||||||
|
conf.Config.Etcd.Endpoints, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// init mongoDB
|
// init mongoDB
|
||||||
if mgoDB, err = db.NewMdb(conf.Config.Mgo); err != nil {
|
if mgoDB, err = db.NewMdb(conf.Config.Mgo); err != nil {
|
||||||
return
|
return fmt.Errorf("Connect to MongoDB %s failed: %s",
|
||||||
|
conf.Config.Mgo.Hosts, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
_Uid = os.Getuid()
|
_Uid = os.Getuid()
|
||||||
|
|
Loading…
Reference in New Issue