Method Start

authnode/server.go:187–234

Start starts a server

(cfg *config.Config)

// Start starts a server
func (m *Server) Start(cfg *config.Config) (err error) {
	m.config = newClusterConfig()
	m.leaderInfo = &LeaderInfo{}
	if err = m.checkConfig(cfg); err != nil {
		log.LogError(errors.Stack(err))
		return
	}
	if m.rocksDBStore, err = raftstore_db.NewRocksDBStore(m.storeDir, LRUCacheSize, WriteBufferSize); err != nil {
		log.LogErrorf("Start: init RocksDB fail: err(%v)", err)
		return
	}

	if err = m.createRaftServer(cfg); err != nil {
		log.LogError(errors.Stack(err))
		return
	}
	m.initCluster()
	m.cluster.partition = m.partition

	AuthSecretKey := cfg.GetString(AuthSecretKey)
	if m.cluster.AuthSecretKey, err = cryptoutil.Base64Decode(AuthSecretKey); err != nil {
		return fmt.Errorf("action[Start] failed %v,err: auth service Key invalid=%s", proto.ErrInvalidCfg, AuthSecretKey)
	}

	AuthRootKey := cfg.GetString(AuthRootKey)
	if m.cluster.AuthRootKey, err = cryptoutil.Base64Decode(AuthRootKey); err != nil {
		return fmt.Errorf("action[Start] failed %v,err: auth root Key invalid=%s", proto.ErrInvalidCfg, AuthRootKey)
	}

	if cfg.GetBool(EnableHTTPS) {
		m.cluster.PKIKey.EnableHTTPS = true
		if m.cluster.PKIKey.AuthRootPublicKey, err = os.ReadFile("/app/server.crt"); err != nil {
			return fmt.Errorf("action[Start] failed,err[%v]", err)
		}
		if m.cluster.PKIKey.AuthRootPrivateKey, err = os.ReadFile("/app/server.key"); err != nil {
			return fmt.Errorf("action[Start] failed,err[%v]", err)
		}
		// TODO: verify cert
	} else {
		m.cluster.PKIKey.EnableHTTPS = false
	}
	m.authProxy = m.newAuthProxy()
	exporter.RegistConsul(m.clusterName, cfg.GetString("role"), cfg)
	m.cluster.scheduleTask()
	m.startHTTPService()
	m.wg.Add(1)
	return nil
}

// Shutdown closes the server
func (m *Server) Shutdown() {