diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-03-23 12:03:42 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-03-23 15:05:37 +0100 |
commit | 8780612685274a5c40f0f9537bbc6872bf8c7748 (patch) | |
tree | d449a7caf7eeaf3205860a890214d3387c7ec008 /client/go/internal/cli/cmd/feed.go | |
parent | d402dd4a6d999fb82aa335f7f316e58f5b5bf556 (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.go | 15 |
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) |