Method Execute

command/v7/upgrade_service_command.go:20–72

(args []string)

}

func (cmd UpgradeServiceCommand) Execute(args []string) error {
	if err := cmd.SharedActor.CheckTarget(true, true); err != nil {
		return err
	}

	if !cmd.Force {
		upgrade, err := cmd.displayPrompt()
		if err != nil {
			return err
		}

		if !upgrade {
			cmd.UI.DisplayText("Upgrade cancelled")
			return nil
		}
	}

	if err := cmd.displayEvent(); err != nil {
		return err
	}

	serviceInstanceName := string(cmd.RequiredArgs.ServiceInstance)

	stream, warnings, actorError := cmd.Actor.UpgradeManagedServiceInstance(
		serviceInstanceName,
		cmd.Config.TargetedSpace().GUID,
	)
	cmd.UI.DisplayWarnings(warnings)

	switch actorError.(type) {
	case nil:
	case actionerror.ServiceInstanceUpgradeNotAvailableError:
		cmd.UI.DisplayText(actorError.Error())
		cmd.UI.DisplayOK()
	case actionerror.ServiceInstanceNotFoundError:
		return translatableerror.ServiceInstanceNotFoundError{Name: serviceInstanceName}
	default:
		return actorError
	}

	complete, err := shared.WaitForResult(stream, cmd.UI, cmd.Wait)
	switch {
	case err != nil:
		return err
	case complete:
		cmd.UI.DisplayTextWithFlavor("Upgrade of service instance {{.ServiceInstanceName}} complete.", cmd.serviceInstanceName())
	default:
		cmd.UI.DisplayTextWithFlavor("Upgrade in progress. Use 'cf services' or 'cf service {{.ServiceInstanceName}}' to check operation status.", cmd.serviceInstanceName())
	}

	cmd.UI.DisplayOK()
	return nil
}

func (cmd UpgradeServiceCommand) Usage() string {
	return "CF_NAME upgrade-service SERVICE_INSTANCE"