(u *url.URL, stateBag map[string]interface{})
| 617 | } |
| 618 | |
| 619 | func setRequestURLForDynamicBackend(u *url.URL, stateBag map[string]interface{}) { |
| 620 | dbu, ok := stateBag[filters.DynamicBackendURLKey].(string) |
| 621 | if ok && dbu != "" { |
| 622 | bu, err := url.ParseRequestURI(dbu) |
| 623 | if err == nil { |
| 624 | u.Host = bu.Host |
| 625 | u.Scheme = bu.Scheme |
| 626 | } |
| 627 | } else { |
| 628 | host, ok := stateBag[filters.DynamicBackendHostKey].(string) |
| 629 | if ok && host != "" { |
| 630 | u.Host = host |
| 631 | } |
| 632 | |
| 633 | scheme, ok := stateBag[filters.DynamicBackendSchemeKey].(string) |
| 634 | if ok && scheme != "" { |
| 635 | u.Scheme = scheme |
| 636 | } |
| 637 | } |
| 638 | } |
| 639 | |
| 640 | func (p *Proxy) selectEndpoint(ctx *context) *routing.LBEndpoint { |
| 641 | rt := ctx.route |
no outgoing calls
searching dependent graphs…