summaryrefslogtreecommitdiffstats
path: root/client/go/internal/cli
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2023-04-27 09:23:25 +0200
committerMartin Polden <mpolden@mpolden.no>2023-04-27 10:14:34 +0200
commit2ca44073203f87b8258a632f44567710d75be4f1 (patch)
treeb3ba4dc05059716432c48764f297c95a1af9e08d /client/go/internal/cli
parentb572b1c2c7726d86b18554c6adfad51924e6945d (diff)
Parse base URL once
Diffstat (limited to 'client/go/internal/cli')
-rw-r--r--client/go/internal/cli/cmd/feed.go5
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)