(dp deployer)
| 332 | } |
| 333 | |
| 334 | func getKubectlVersion(dp deployer) error { |
| 335 | cmd, err := dp.KubectlCommand() |
| 336 | if err != nil { |
| 337 | return err |
| 338 | } |
| 339 | if cmd == nil { |
| 340 | cmd = exec.Command("./cluster/kubectl.sh") |
| 341 | } |
| 342 | cmd.Args = append(cmd.Args, "--match-server-version=false", "version") |
| 343 | copied := *cmd |
| 344 | retries := 5 |
| 345 | for { |
| 346 | _, err := control.Output(&copied) |
| 347 | if err == nil { |
| 348 | return nil |
| 349 | } |
| 350 | retries-- |
| 351 | if retries == 0 { |
| 352 | return err |
| 353 | } |
| 354 | log.Printf("Failed to reach api. Sleeping for 10 seconds before retrying... (%v)", copied.Args) |
| 355 | time.Sleep(10 * time.Second) |
| 356 | } |
| 357 | } |
| 358 | |
| 359 | func dumpRemoteLogs(deploy deployer, o options, path, reason string) []error { |
| 360 | if o.kubemark { |
no test coverage detected