Method newGraphJinReloadingConfigDatabases

core/api.go:1067–1223

(base *graphjinEngine, nextConf *Config, reloadSet map[string]struct{}, opts ...Option)

}

func (g *GraphJin) newGraphJinReloadingConfigDatabases(base *graphjinEngine, nextConf *Config, reloadSet map[string]struct{}, opts ...Option) error {
	if base == nil {
		return errors.New("graphjin engine is not initialized")
	}
	conf := nextConf.clone()
	if conf.IsSourcesUsed() {
		for i := range conf.Tables {
			if conf.Tables[i].Source == "" && conf.Tables[i].Database != "" {
				conf.Tables[i].Source = conf.Tables[i].Database
			}
		}
	}
	if err := conf.NormalizeMode(); err != nil {
		return err
	}

	log := base.log
	if log == nil {
		log = _log.New(os.Stderr, "", 0)
	}
	trace := base.trace
	if trace == nil {
		trace = &tracer{}
	}
	printFormat := append([]byte(nil), base.printFormat...)
	if len(printFormat) == 0 {
		printFormat = []byte(fmt.Sprintf("gj-%x:", time.Now().UnixNano()))
	}

	gj := &graphjinEngine{
		conf:        conf,
		log:         log,
		prod:        conf.Production,
		prodSec:     conf.Production,
		printFormat: printFormat,
		opts:        opts,
		fs:          base.fs,
		trace:       trace,
		namespace:   base.namespace,
		done:        g.done,
	}
	if gj.conf.DisableProdSecurity {
		gj.prodSec = false
	}
	if err := gj.initCache(); err != nil {
		return err
	}
	if err := gj.initConfig(); err != nil {
		return err
	}
	names := make([]string, 0, len(gj.conf.Databases))
	for name := range gj.conf.Databases {
		names = append(names, name)
	}
	sort.Strings(names)
	if len(names) != 0 {
		gj.defaultDB = names[0]
	}