Method SetConfig

driver/driver.go:382–462

(c *base.Config)

}

func (d *Driver) SetConfig(c *base.Config) (err error) {
	if c != nil && c.AgentConfig != nil {
		d.nomadConfig = c.AgentConfig.Driver
		d.logger.Info("SetConfig 1", "DriverConfig", c.AgentConfig.Driver)
	}

	d.config = new(DriverConfig)
	if len(c.PluginConfig) != 0 {
		if err := base.MsgPackDecode(c.PluginConfig, d.config); err != nil {
			return err
		}
	}

	d.logger.Info("SetConfig 2", "config", d.config)

	err = d.setupLogger()
	if err != nil {
		return errors.Wrap(err, "setupLogger")
	}

	//if dconfig.Memory != "" {
	//	g.MemAvailable = TODO
	//}
	if d.config.BigTxMaxJobs != 0 {
		g.BigTxMaxJobs = d.config.BigTxMaxJobs
	}
	d.logger.Info("BigTxMaxJobs is set", "value", g.BigTxMaxJobs)

	if "" != d.config.RsaPrivateKeyPath {
		b, err := ioutil.ReadFile(d.config.RsaPrivateKeyPath)
		if nil != err {
			return fmt.Errorf("read rsa private key file failed: %v", err)
		}
		g.RsaPrivateKey = string(b)
	}

	if d.storeManager != nil {
		// PluginLoader.validatePluginConfig() will call SetConfig() twice.
		// This test avoids extra setup.
		return nil
	} else {
		d.storeManager, err = common.NewStoreManager([]string{d.config.Consul}, d.logger)
		if err != nil {
			return err
		}

		go func() {
			if d.config.ApiAddr == "" {
				d.logger.Info("ApiAddr is empty in config. Will not start api_compat server.")
			} else {
				if d.config.NomadAddr == "" {
					d.logger.Info("NomadAddr is empty in config. Will not handle api_compat request.")
					go func() {
						// for pprof
						err := http.ListenAndServe(d.config.ApiAddr, http.DefaultServeMux)
						if err != nil {
							d.logger.Error("ListenAndServe error", "err", err, "addr", d.config.ApiAddr)
						}