Function EsNodeMain

cmd/es-node/main.go:152–215

(ctx *cli.Context)

}

func EsNodeMain(ctx *cli.Context) error {
	lg.Info("Configuring EthStorage Node")
	lgCfg := log.ReadCLIConfig(ctx)
	lg.Info("Loading log config", "config", lgCfg)
	clog := log.NewLogger(lgCfg)
	cfg, err := NewConfig(ctx, clog)
	if err != nil {
		lg.Error("Unable to create the rollup node config", "error", err)
		return err
	}

	var m metrics.Metricer = metrics.NoopMetrics
	if cfg.Metrics.Enabled {
		m = metrics.NewMetrics("default")
	}
	n, err := node.New(context.Background(), cfg, clog, VersionWithMeta, m)
	if err != nil {
		clog.Error("Unable to create the storage node", "error", err)
		return err
	}
	clog.Info("Starting storage node", "version", VersionWithMeta)

	if err := n.Start(context.Background(), cfg); err != nil {
		clog.Error("Unable to start rollup node", "error", err)
		return err
	}
	defer n.Close()

	m.RecordInfo(VersionWithMeta)
	m.RecordUp()
	// TODO: heartbeat
	if cfg.Pprof.Enabled {
		pprofCtx, pprofCancel := context.WithCancel(context.Background())
		go func() {
			clog.Info("pprof server started", "addr", net.JoinHostPort(cfg.Pprof.ListenAddr, strconv.Itoa(cfg.Pprof.ListenPort)))
			if err := oppprof.ListenAndServe(pprofCtx, cfg.Pprof.ListenAddr, cfg.Pprof.ListenPort); err != nil {
				clog.Error("error starting pprof", "err", err)
			}
		}()
		defer pprofCancel()
	}

	clog.Info("Storage node started")

	// Run simple sync test
	start := ctx.GlobalUint64(flags.TestSimpleSyncStartFlag.Name)
	end := ctx.GlobalUint64(flags.TestSimpleSyncEndFlag.Name)
	if end > start {
		lg.Info("Start force sync", "start", start, "end", end)
		n.RequestL2Range(context.Background(), start, end)
	}

	interruptChannel := make(chan os.Signal, 1)
	signal.Notify(interruptChannel, []os.Signal{
		os.Interrupt,
		os.Kill,
		syscall.SIGTERM,
		syscall.SIGQUIT,