(endpointSource, port string)
| 222 | } |
| 223 | |
| 224 | func requestEndpointFromSource(endpointSource, port string) *string { |
| 225 | t := http.DefaultTransport |
| 226 | c := http.DefaultClient |
| 227 | if tr, ok := t.(*http.Transport); ok { |
| 228 | tr.DisableKeepAlives = true |
| 229 | c = &http.Client{Transport: tr} |
| 230 | } |
| 231 | resp, err := c.Get(endpointSource) |
| 232 | if err != nil { |
| 233 | tracelog.ErrorLogger.Printf("Endpoint source error: %v ", err) |
| 234 | return nil |
| 235 | } |
| 236 | defer func() { _ = resp.Body.Close() }() |
| 237 | if resp.StatusCode != 200 { |
| 238 | tracelog.ErrorLogger.Printf("Endpoint source bad status code: %v ", resp.StatusCode) |
| 239 | return nil |
| 240 | } |
| 241 | bytes, err := io.ReadAll(resp.Body) |
| 242 | if err == nil { |
| 243 | return aws.String(net.JoinHostPort(string(bytes), port)) |
| 244 | } |
| 245 | tracelog.ErrorLogger.Println("Endpoint source reading error:", err) |
| 246 | return nil |
| 247 | } |
| 248 | |
| 249 | func decodeHeaders(encodedHeaders string) (map[string]string, error) { |
| 250 | var data interface{} |
no test coverage detected