diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-04-27 09:23:25 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-04-27 10:14:34 +0200 |
commit | 2ca44073203f87b8258a632f44567710d75be4f1 (patch) | |
tree | b3ba4dc05059716432c48764f297c95a1af9e08d /client/go/internal/cli | |
parent | b572b1c2c7726d86b18554c6adfad51924e6945d (diff) |
Parse base URL once
Diffstat (limited to 'client/go/internal/cli')
-rw-r--r-- | client/go/internal/cli/cmd/feed.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/client/go/internal/cli/cmd/feed.go b/client/go/internal/cli/cmd/feed.go index d50a12d8884..7cedc39bad8 100644 --- a/client/go/internal/cli/cmd/feed.go +++ b/client/go/internal/cli/cmd/feed.go @@ -139,7 +139,7 @@ func feed(files []string, options feedOptions, cli *CLI) error { if err != nil { return err } - client := document.NewClient(document.ClientOptions{ + client, err := document.NewClient(document.ClientOptions{ Compression: compression, Timeout: time.Duration(options.timeoutSecs) * time.Second, Route: options.route, @@ -147,6 +147,9 @@ func feed(files []string, options feedOptions, cli *CLI) error { BaseURL: service.BaseURL, NowFunc: cli.now, }, clients) + if err != nil { + return err + } throttler := document.NewThrottler(options.connections) circuitBreaker := document.NewCircuitBreaker(10*time.Second, time.Duration(options.doomSecs)*time.Second) dispatcher := document.NewDispatcher(client, throttler, circuitBreaker, cli.Stderr, options.verbose) |