Function publishEvent

cli/migrate.go:284–313

(envName string, modifiedSchemas []string, eventName string, syncETCDEvent bool, eventTimeout time.Duration)

}

func publishEvent(envName string, modifiedSchemas []string, eventName string, syncETCDEvent bool, eventTimeout time.Duration) error {
	config := util.GetConfig()

	rawDB, err := db.CreateFromConfig(config)

	if err != nil {
		log.Fatal(err)
	}

	db := &server.DbSyncWrapper{DB: rawDB}

	sync, err := sync_util.CreateFromConfig(config)

	if err != nil {
		log.Fatal(err)
	}

	ident, err := middleware.CreateIdentityServiceFromConfig(config)

	if err != nil {
		log.Fatal(err)
	}

	envManager := extension.GetManager()
	manager := schema.GetManager()

	publishEventWithOptions(envName, modifiedSchemas, eventName, syncETCDEvent, eventTimeout, db, manager, envManager, sync, ident)

	return nil
}