Method CreateManagedServiceInstance

actor/v7action/service_instance.go:68–108

(params CreateManagedServiceInstanceParams)

}

func (actor Actor) CreateManagedServiceInstance(params CreateManagedServiceInstanceParams) (chan PollJobEvent, Warnings, error) {
	var (
		servicePlan resources.ServicePlan
		jobURL      ccv3.JobURL
	)

	warnings, err := railway.Sequentially(
		func() (warnings ccv3.Warnings, err error) {
			var v7Warnings Warnings
			servicePlan, v7Warnings, err = actor.GetServicePlanByNameOfferingAndBroker(
				params.ServicePlanName,
				params.ServiceOfferingName,
				params.ServiceBrokerName,
			)
			return ccv3.Warnings(v7Warnings), err
		},
		func() (warnings ccv3.Warnings, err error) {
			serviceInstance := resources.ServiceInstance{
				Type:            resources.ManagedServiceInstance,
				Name:            params.ServiceInstanceName,
				ServicePlanGUID: servicePlan.GUID,
				SpaceGUID:       params.SpaceGUID,
				Tags:            params.Tags,
				Parameters:      params.Parameters,
			}

			jobURL, warnings, err = actor.CloudControllerClient.CreateServiceInstance(serviceInstance)
			return
		},
	)
	switch e := err.(type) {
	case nil:
		return actor.PollJobToEventStream(jobURL), Warnings(warnings), nil
	case actionerror.DuplicateServicePlanError:
		return nil, Warnings(warnings), actionerror.ServiceBrokerNameRequiredError{
			ServiceOfferingName: e.ServiceOfferingName,
		}
	default:
		return nil, Warnings(warnings), err
	}
}

func (actor Actor) UpdateManagedServiceInstance(params UpdateManagedServiceInstanceParams) (chan PollJobEvent, Warnings, error) {
	var (