(params CreateRouteBindingParams)
| 34 | } |
| 35 | |
| 36 | func (actor Actor) CreateRouteBinding(params CreateRouteBindingParams) (chan PollJobEvent, Warnings, error) { |
| 37 | var ( |
| 38 | serviceInstance resources.ServiceInstance |
| 39 | route resources.Route |
| 40 | jobURL ccv3.JobURL |
| 41 | stream chan PollJobEvent |
| 42 | ) |
| 43 | |
| 44 | warnings, err := railway.Sequentially( |
| 45 | func() (warnings ccv3.Warnings, err error) { |
| 46 | serviceInstance, _, warnings, err = actor.getServiceInstanceByNameAndSpace(params.ServiceInstanceName, params.SpaceGUID) |
| 47 | return |
| 48 | }, |
| 49 | func() (warnings ccv3.Warnings, err error) { |
| 50 | route, warnings, err = actor.getRouteForBinding(getRouteForBindingParams{ |
| 51 | SpaceGUID: params.SpaceGUID, |
| 52 | DomainName: params.DomainName, |
| 53 | Hostname: params.Hostname, |
| 54 | Path: params.Path, |
| 55 | }) |
| 56 | return |
| 57 | }, |
| 58 | func() (warnings ccv3.Warnings, err error) { |
| 59 | jobURL, warnings, err = actor.createRouteBinding(serviceInstance.GUID, route.GUID, params.Parameters) |
| 60 | return |
| 61 | }, |
| 62 | func() (warnings ccv3.Warnings, err error) { |
| 63 | stream = actor.PollJobToEventStream(jobURL) |
| 64 | return |
| 65 | }, |
| 66 | ) |
| 67 | |
| 68 | return stream, Warnings(warnings), err |
| 69 | } |
| 70 | |
| 71 | func (actor Actor) DeleteRouteBinding(params DeleteRouteBindingParams) (chan PollJobEvent, Warnings, error) { |
| 72 | var ( |
nothing calls this directly
no test coverage detected