Function emitPostMigrateEvent

cli/migrate.go:102–134

(forcedSchemas string, syncETCDEvent bool, postMigrationEventTimeout time.Duration)

}

func emitPostMigrateEvent(forcedSchemas string, syncETCDEvent bool, postMigrationEventTimeout time.Duration) {
	config := util.GetConfig()

	log.Info("Emit post-migrate event")

	modifiedSchemas := selectModifiedSchemas(forcedSchemas)

	if len(modifiedSchemas) == 0 {
		log.Info("No modified schemas, skipping post-migration event")
		return
	}

	log.Debug("Modified schemas: %s", strings.Join(modifiedSchemas, ", "))

	schemaFiles := config.GetStringList("schemas", nil)

	if schemaFiles == nil {
		log.Fatal("No schema specified in configuration")
	}

	manager := schema.GetManager()
	if err := manager.LoadSchemasFromFiles(schemaFiles...); err != nil {
		log.Fatal(err)
	}

	if err := publishEvent(postMigrationEnvName, modifiedSchemas, eventPostMigration, syncETCDEvent, postMigrationEventTimeout); err != nil {
		log.Fatal("Publish post-migrate event failed: %s", err)
	}

	schema.ClearManager()

	log.Info("Published post-migrate event: %s", strings.Join(modifiedSchemas, ", "))
}

func actionMigrate(subcmd string) func(context *cli.Context) {
	return withinLockedMigration(func(context *cli.Context) {