(params DeleteRouteBindingParams)
| 69 | } |
| 70 | |
| 71 | func (actor Actor) DeleteRouteBinding(params DeleteRouteBindingParams) (chan PollJobEvent, Warnings, error) { |
| 72 | var ( |
| 73 | serviceInstance resources.ServiceInstance |
| 74 | route resources.Route |
| 75 | binding resources.RouteBinding |
| 76 | jobURL ccv3.JobURL |
| 77 | stream chan PollJobEvent |
| 78 | ) |
| 79 | |
| 80 | warnings, err := railway.Sequentially( |
| 81 | func() (warnings ccv3.Warnings, err error) { |
| 82 | serviceInstance, _, warnings, err = actor.getServiceInstanceByNameAndSpace(params.ServiceInstanceName, params.SpaceGUID) |
| 83 | return |
| 84 | }, |
| 85 | func() (warnings ccv3.Warnings, err error) { |
| 86 | route, warnings, err = actor.getRouteForBinding(getRouteForBindingParams{ |
| 87 | SpaceGUID: params.SpaceGUID, |
| 88 | DomainName: params.DomainName, |
| 89 | Hostname: params.Hostname, |
| 90 | Path: params.Path, |
| 91 | }) |
| 92 | return |
| 93 | }, |
| 94 | func() (warnings ccv3.Warnings, err error) { |
| 95 | binding, warnings, err = actor.getRouteBinding(serviceInstance.GUID, route.GUID) |
| 96 | return |
| 97 | }, |
| 98 | func() (warnings ccv3.Warnings, err error) { |
| 99 | jobURL, warnings, err = actor.CloudControllerClient.DeleteRouteBinding(binding.GUID) |
| 100 | return |
| 101 | }, |
| 102 | func() (warnings ccv3.Warnings, err error) { |
| 103 | stream = actor.PollJobToEventStream(jobURL) |
| 104 | return |
| 105 | }, |
| 106 | ) |
| 107 | |
| 108 | return stream, Warnings(warnings), err |
| 109 | } |
| 110 | |
| 111 | func (actor Actor) createRouteBinding(serviceInstanceGUID, routeGUID string, parameters types.OptionalObject) (ccv3.JobURL, ccv3.Warnings, error) { |
| 112 | jobURL, warnings, err := actor.CloudControllerClient.CreateRouteBinding(resources.RouteBinding{ |
nothing calls this directly
no test coverage detected