package conf import ( "errors" "flag" "go-common/library/conf" "go-common/library/database/sql" "go-common/library/log" bm "go-common/library/net/http/blademaster" "go-common/library/net/http/blademaster/middleware/verify" "go-common/library/net/rpc" "go-common/library/net/rpc/warden" "go-common/library/net/trace" "go-common/library/queue/databus" xtime "go-common/library/time" "github.com/BurntSushi/toml" ) // Conf global variable. var ( Conf = &Config{} client *conf.Client confPath string ) // Config struct of conf. type Config struct { App *bm.App Xlog *log.Config Verify *verify.Config HTTPServer *bm.ServerConfig HTTPClient *bm.ClientConfig RPCServer *rpc.ServerConfig GRPC *warden.ServerConfig MySQL *sql.Config Tracer *trace.Config Databus *databus.Config Sms *sms } type sms struct { PickUpTask bool LoadTaskInteval xtime.Duration TaskWorker int BatchSize int } func init() { flag.StringVar(&confPath, "conf", "", "default config path") } // Init create config instance. func Init() (err error) { if confPath != "" { return local() } return remote() } func local() (err error) { _, err = toml.DecodeFile(confPath, &Conf) return } func remote() (err error) { if client, err = conf.New(); err != nil { return } err = load() return } func load() (err error) { var ( s string ok bool tmpConf *Config ) if s, ok = client.Toml2(); !ok { return errors.New("load config center error") } if _, err = toml.Decode(s, &tmpConf); err != nil { return errors.New("could not decode config") } *Conf = *tmpConf return }