(c *upstream.Config)
| 57 | } |
| 58 | |
| 59 | func FromClusterConfig(c *upstream.Config) *Upstream { |
| 60 | nodes := make([]*NodeConfig, 0, len(c.Nodes)) |
| 61 | for _, node := range c.Nodes { |
| 62 | nodes = append(nodes, &NodeConfig{ |
| 63 | Address: node.Address, |
| 64 | Weight: node.Weight, |
| 65 | }) |
| 66 | } |
| 67 | discover := &DiscoverConfig{} |
| 68 | if c.Discover != nil { |
| 69 | discover.Discover = c.Discover.Discover |
| 70 | discover.Service = c.Discover.Service |
| 71 | } |
| 72 | return &Upstream{ |
| 73 | Type: c.Type, |
| 74 | Balance: c.Balance, |
| 75 | Timeout: c.Timeout, |
| 76 | Retry: c.Retry, |
| 77 | LimitPeerSecond: c.LimitPeerSecond, |
| 78 | ProxyHeaders: FromProxyHeaders(c.ProxyHeaders), |
| 79 | Scheme: c.Scheme, |
| 80 | PassHost: c.PassHost, |
| 81 | UpstreamHost: c.UpstreamHost, |
| 82 | Nodes: nodes, |
| 83 | Discover: discover, |
| 84 | } |
| 85 | } |
nothing calls this directly
no test coverage detected