(params UpdateManagedServiceInstanceParams)
| 108 | } |
| 109 | |
| 110 | func (actor Actor) UpdateManagedServiceInstance(params UpdateManagedServiceInstanceParams) (chan PollJobEvent, Warnings, error) { |
| 111 | var ( |
| 112 | serviceInstance resources.ServiceInstance |
| 113 | serviceOffering resources.ServiceOffering |
| 114 | serviceBroker resources.ServiceBroker |
| 115 | newPlanGUID string |
| 116 | jobURL ccv3.JobURL |
| 117 | stream chan PollJobEvent |
| 118 | ) |
| 119 | |
| 120 | planChangeRequested := params.ServicePlanName != "" |
| 121 | |
| 122 | warnings, err := railway.Sequentially( |
| 123 | func() (warnings ccv3.Warnings, err error) { |
| 124 | serviceInstance, serviceOffering, serviceBroker, warnings, err = actor.getServiceInstanceForUpdate( |
| 125 | params.ServiceInstanceName, |
| 126 | params.SpaceGUID, |
| 127 | planChangeRequested, |
| 128 | ) |
| 129 | return |
| 130 | }, |
| 131 | func() (warnings ccv3.Warnings, err error) { |
| 132 | err = assertServiceInstanceType(resources.ManagedServiceInstance, serviceInstance) |
| 133 | return |
| 134 | }, |
| 135 | func() (warnings ccv3.Warnings, err error) { |
| 136 | if planChangeRequested { |
| 137 | newPlanGUID, warnings, err = actor.getPlanForInstanceUpdate(params.ServicePlanName, serviceOffering, serviceBroker) |
| 138 | } |
| 139 | return |
| 140 | }, |
| 141 | func() (warnings ccv3.Warnings, err error) { |
| 142 | jobURL, warnings, err = actor.updateManagedServiceInstance(serviceInstance, newPlanGUID, params) |
| 143 | return |
| 144 | }, |
| 145 | func() (warnings ccv3.Warnings, err error) { |
| 146 | stream = actor.PollJobToEventStream(jobURL) |
| 147 | return |
| 148 | }, |
| 149 | ) |
| 150 | |
| 151 | return stream, Warnings(warnings), err |
| 152 | } |
| 153 | |
| 154 | func (actor Actor) UpgradeManagedServiceInstance(serviceInstanceName string, spaceGUID string) (chan PollJobEvent, Warnings, error) { |
| 155 | var ( |
nothing calls this directly
no test coverage detected