diff --git a/cmd/main.go b/cmd/main.go index 8dd5630..830fbd7 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -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 { diff --git a/pkg/utils/utils.go b/pkg/utils/utils.go index ecad37a..49903d5 100644 --- a/pkg/utils/utils.go +++ b/pkg/utils/utils.go @@ -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 }