Function actionMigrateWithPostMigrationEvent

cli/migrate.go:144–154

(subcmd string)

}

func actionMigrateWithPostMigrationEvent(subcmd string) func(context *cli.Context) {
	return withinLockedMigration(func(context *cli.Context) {
		if err := migration.Run(subcmd, context.Args()); err != nil {
			log.Fatalf("Migrate run failed: %s", err)
		}
		if !context.Bool(FlagEmitPostMigrationEvent) {
			return
		}
		emitPostMigrateEvent(context.String(FlagForcedSchemas), context.Bool(FlagSyncETCDEvent), context.Duration(FlagPostMigrationEventTimeout))
	})
}

func actionMigrateHelp() func(context *cli.Context) {
	return func(context *cli.Context) {