Skip to content

Commit

Permalink
Performance tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
lxcode committed Nov 16, 2024
1 parent 2d06f73 commit b358b11
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion cmd/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ func streamCmd(cctx *cli.Context) error {
return err
}

outputChannel := make(chan map[string]interface{}, 10000)
outputChannel := make(chan map[string]interface{}, 512)

output, err := output.NewOutput(cctx, outputChannel)
if err != nil {
Expand Down
6 changes: 3 additions & 3 deletions pkg/utils/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,12 +49,12 @@ func GetLastLine(filepath string) (string, error) {

func RetryingHTTPClient() *http.Client {
retryClient := retryablehttp.NewClient()
retryClient.RetryMax = 15
retryClient.RetryMax = 5
retryClient.RetryWaitMin = 1 * time.Second
retryClient.RetryWaitMax = 120 * time.Minute
retryClient.RetryWaitMax = 5 * time.Minute
retryClient.CheckRetry = XRPCRetryPolicy
client := retryClient.StandardClient()
client.Timeout = 30 * time.Second
client.Timeout = 10 * time.Second

return client
}
Expand Down

0 comments on commit b358b11

Please sign in to comment.