func initServer()

in cmd/engine/main.go [61:88]

26 lines of code
6 McCabe index (conditional complexity)


func initServer() (*Server, error) {
	plugin.Register(constants.LogSchedule, log.DefaultLogFactory)
	plugin.Register(constants.LogQueue, log.DefaultLogFactory)

	var s Server
	if err := s.setupConfig(); err != nil {
		return nil, err
	}
	reg := registry.Get(config.GlobalConfig().Server.Name)
	if reg == nil {
		return nil, errors.New("service name=" + config.GlobalConfig().Server.Name + " not find registry")
	}
	if err := reg.Register(config.GlobalConfig().Server.Name); err != nil {
		return nil, err
	}
	scheduler, err := schedule.NewScheduler()
	if err != nil {
		return nil, err
	}
	s.schedule = scheduler
	if err = dal.Open(); err != nil {
		return nil, err
	}
	s.queue = queue.GetQueue(config.GlobalConfig().Flow.Queue.Store)

	s.server = grpc.NewServer()
	return &s, nil
}