Function main

main.go:50–128

()

	conf.Name = "IceFireDB"
	conf.Version = "1.0.0-rc.1"
	conf.GitSHA = BuildVersion
	conf.Flag.Custom = true
	confInit(&conf)
	conf.DataDirReady = func(dir string) {
		cfg, l, d, err := openStorage(dir, storageBackend)
		if err != nil {
			log.Fatalf("failed to initialize storage backend %q: %v", storageBackend, err)
		}
		ldsCfg, le, ldb = cfg, l, d
		storageReady.Store(true)

		// Register backend-specific metrics with the INFO endpoint.
		switch storageBackend {
		case hybriddb.StorageName:
			serverInfo.RegisterExtInfo(ldb.GetSDB().GetDriver().(*hybriddb.DB).Metrics)
		case ipfs.StorageName:
			serverInfo.RegisterExtInfo(ldb.GetSDB().GetDriver().(*ipfs.DB).Metrics)
		case ipfs_synckv.StorageName:
			serverInfo.RegisterExtInfo(ldb.GetSDB().GetDriver().(*ipfs_synckv.DB).Metrics)
		}
	}
	if enablePprof {
		// pprof for profiling — opt-in, loopback by default.
		go func() {
			log.Printf("pprof listening on %s", pprofAddr)
			if err := http.ListenAndServe(pprofAddr, nil); err != nil {
				log.Printf("pprof server stopped: %v", err)
			}
		}()
	}
	if enableMetrics {
		startObservabilityServer(metricsAddr, func() bool { return storageReady.Load() })
	}
	conf.Snapshot = snapshot
	conf.Restore = restore
	conf.ConnOpened = connOpened
	conf.ConnClosed = connClosed
	//conf.CmdRewriteFunc = utils.RedisCmdRewrite

	fmt.Printf("start with Storage Engine: %s\n", storageBackend)
	rafthub.Main(conf)
}

// openStorage opens the ledis database for the given data dir and storage
// backend, returning the config and handles. It returns an error instead of
// aborting so callers (and tests) can decide how to handle failure.
func openStorage(dir, backend string) (*lediscfg.Config, *ledis.Ledis, *ledis.DB, error) {
	cfg := lediscfg.NewConfigDefault()
	cfg.DataDir = filepath.Join(dir, "main.db")
	cfg.Databases = 1
	cfg.DBName = backend

	l, err := ledis.Open(cfg)
	if err != nil {
		return nil, nil, nil, err
	}
	d, err := l.Select(0)
	if err != nil {