代码拉取完成,页面将自动刷新
package config
import (
"fmt"
"log"
"gitee.com/linxing_3/youye-core/config"
"gitee.com/linxing_3/youye-core/config/source"
)
var (
ExtendConfig interface{}
_cfg *Settings
)
// Settings 兼容原先的配置结构
type Settings struct {
Settings Config `yaml:"settings"`
callbacks []func()
}
func (e *Settings) runCallback() {
for i := range e.callbacks {
e.callbacks[i]()
}
}
func (e *Settings) OnChange() {
e.init()
log.Println("config change and reload")
}
func (e *Settings) Init() {
e.init()
log.Println("config init")
}
func (e *Settings) init() {
e.Settings.Logger.Setup()
e.Settings.multiDatabase()
e.runCallback()
}
// Config 配置集合
type Config struct {
Application *Application `yaml:"application"`
Ssl *Ssl `yaml:"ssl"`
Logger *Logger `yaml:"logger"`
Jwt *Jwt `yaml:"jwt"`
Registry *Etcd `yaml:"registry"`
Database *Database `yaml:"database"`
Databases *map[string]*Database `yaml:"databases"`
Gen *Gen `yaml:"gen"`
Cache *Cache `yaml:"cache"`
Locker *Locker `yaml:"locker"`
Extend interface{} `yaml:"extend"`
}
// 多db改造
func (e *Config) multiDatabase() {
if len(*e.Databases) == 0 {
*e.Databases = map[string]*Database{
"*": e.Database,
}
}
}
// Setup 载入配置文件
func Setup(s []source.Source,
fs ...func()) error {
_cfg = &Settings{
Settings: Config{
Application: ApplicationConfig,
Ssl: SslConfig,
Logger: LoggerConfig,
Jwt: JwtConfig,
Database: DatabaseConfig,
Registry: EtcdConfig,
Databases: &DatabasesConfig,
Gen: GenConfig,
Cache: CacheConfig,
Locker: LockerConfig,
Extend: ExtendConfig,
},
callbacks: fs,
}
var err error
config.DefaultConfig, err = config.NewConfig(
config.WithSource(s...),
config.WithEntity(_cfg),
)
if err != nil {
log.Fatal(fmt.Sprintf("New config object fail: %s", err.Error()))
return err
}
_cfg.Init()
return nil
}
func GetConfig() *Config {
return &_cfg.Settings
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。