diff options
| author | Martin Polden <mpolden@mpolden.no> | 2023-08-21 15:31:44 +0200 |
|---|---|---|
| committer | Martin Polden <mpolden@mpolden.no> | 2023-08-21 15:49:17 +0200 |
| commit | 5d6cf5d65fc06341d1127d5de586276fb3a1659e (patch) | |
| tree | 0ed1002ba1b55f8bc47ed0818370197971aa0796 /client/go/internal/cli/cmd/feed.go | |
| parent | ed2099510c7b46a4d8fa643c0469c85c4018a7da (diff) | |
Extract Waiter
Diffstat (limited to 'client/go/internal/cli/cmd/feed.go')
| -rw-r--r-- | client/go/internal/cli/cmd/feed.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/client/go/internal/cli/cmd/feed.go b/client/go/internal/cli/cmd/feed.go index 8a2bdf04ce3..8b8589baec3 100644 --- a/client/go/internal/cli/cmd/feed.go +++ b/client/go/internal/cli/cmd/feed.go @@ -107,8 +107,9 @@ func createServices(n int, timeout time.Duration, waitSecs int, cli *CLI) ([]uti } services := make([]util.HTTPClient, 0, n) baseURL := "" + waiter := cli.waiter(false, time.Duration(waitSecs)*time.Second) for i := 0; i < n; i++ { - service, err := cli.service(target, cli.config.cluster(), time.Duration(waitSecs)*time.Second) + service, err := waiter.Service(target, cli.config.cluster()) if err != nil { return nil, "", err } |