Function getResyncCommand

cli/cli.go:317–365

()

}

func getResyncCommand() cli.Command {
	return cli.Command{
		Name:  "resync",
		Usage: "Resync all syncable resources to sync (etcd) backend",
		Flags: []cli.Flag{
			cli.StringFlag{Name: "config-file", Value: defaultConfigFile, Usage: "Server config File"},
		},
		Action: func(c *cli.Context) {
			configFile := c.String("config-file")

			config := util.GetConfig()
			if configFile == "" {
				log.Fatal("Need to provide server config file")
			}
			if err := config.ReadConfig(configFile); err != nil {
				log.Fatalf("Error while loading server config file: %s", err)
			}
			if err := os.Chdir(path.Dir(configFile)); err != nil {
				log.Fatalf("Chdir error: %s", err)
			}

			dbConn, err := db.CreateFromConfig(config)
			if err != nil {
				log.Fatalf("Failed to create db conn, err: %s", err)
			}

			sync, err := sync_util.CreateFromConfig(config)
			if err != nil {
				log.Fatalf("Failed to create sync, err: %s", err)

			}

			schemaManager := schema.GetManager()

			schemaFiles := config.GetStringList("schemas", nil)
			if schemaFiles == nil {
				log.Fatal("No schema specified in configuration")
			} else {
				log.Info("Loading schemas %s", schemaFiles)
				err = schemaManager.LoadSchemasFromFiles(schemaFiles...)
				if err != nil {
					log.Fatalf("Error when loading schemas: %s", err)
				}
			}

			server.Resync(dbConn, sync)
		},
	}
}

func getServerCommand() cli.Command {
	return cli.Command{