summaryrefslogtreecommitdiffstats
path: root/client/go/internal/cli/cmd/feed.go
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2023-03-23 12:03:42 +0100
committerMartin Polden <mpolden@mpolden.no>2023-03-23 15:05:37 +0100
commit8780612685274a5c40f0f9537bbc6872bf8c7748 (patch)
treed449a7caf7eeaf3205860a890214d3387c7ec008 /client/go/internal/cli/cmd/feed.go
parentd402dd4a6d999fb82aa335f7f316e58f5b5bf556 (diff)
Always use HTTP/2 transport when using TLS
Diffstat (limited to 'client/go/internal/cli/cmd/feed.go')
-rw-r--r--client/go/internal/cli/cmd/feed.go15
1 files changed, 6 insertions, 9 deletions
diff --git a/client/go/internal/cli/cmd/feed.go b/client/go/internal/cli/cmd/feed.go
index 621676d0353..f273c5aa826 100644
--- a/client/go/internal/cli/cmd/feed.go
+++ b/client/go/internal/cli/cmd/feed.go
@@ -12,15 +12,13 @@ import (
"github.com/vespa-engine/vespa/client/go/internal/vespa/document"
)
-func addFeedFlags(cmd *cobra.Command, maxConnections *int, concurrency *int) {
- cmd.PersistentFlags().IntVarP(maxConnections, "max-connections", "N", 8, "Maximum number of HTTP connections to use")
+func addFeedFlags(cmd *cobra.Command, concurrency *int) {
cmd.PersistentFlags().IntVarP(concurrency, "concurrency", "T", 64, "Number of goroutines to use for dispatching")
}
func newFeedCmd(cli *CLI) *cobra.Command {
var (
- maxConnections int
- concurrency int
+ concurrency int
)
cmd := &cobra.Command{
Use: "feed FILE",
@@ -45,21 +43,20 @@ newline (JSONL).
return err
}
defer f.Close()
- return feed(f, cli, maxConnections, concurrency)
+ return feed(f, cli, concurrency)
},
}
- addFeedFlags(cmd, &maxConnections, &concurrency)
+ addFeedFlags(cmd, &concurrency)
return cmd
}
-func feed(r io.Reader, cli *CLI, maxConnections, concurrency int) error {
+func feed(r io.Reader, cli *CLI, concurrency int) error {
service, err := documentService(cli)
if err != nil {
return err
}
client := document.NewClient(document.ClientOptions{
- BaseURL: service.BaseURL,
- MaxConnsPerHost: maxConnections,
+ BaseURL: service.BaseURL,
}, service)
dispatcher := document.NewDispatcher(client, concurrency)
dec := document.NewDecoder(r)