fix(options): pass retryBackoff and retryPredicate options to transport

aslafy-z · web-flow · commit a138e4deb893 · 2024-09-30T07:31:09.000Z
Signed-off-by: GitHub &lt;noreply@github.com&gt;
diff --git a/pkg/v1/remote/options.go b/pkg/v1/remote/options.go
@@ -163,8 +163,7 @@ func makeOptions(opts ...Option) (*options, error) {
 		}
 
 		// Wrap the transport in something that can retry network flakes.
-		o.transport = transport.NewRetry(o.transport, transport.WithRetryPredicate(defaultRetryPredicate), transport.WithRetryStatusCodes(o.retryStatusCodes...))
-
+		o.transport = transport.NewRetry(o.transport, transport.WithRetryBackoff(o.retryBackoff), transport.WithRetryPredicate(o.retryPredicate), transport.WithRetryStatusCodes(o.retryStatusCodes...))
 		// Wrap this last to prevent transport.New from double-wrapping.
 		if o.userAgent != "" {
 			o.transport = transport.NewUserAgent(o.transport, o.userAgent)

Original file line number	Diff line number	Diff line change
`@@ -163,8 +163,7 @@ func makeOptions(opts ...Option) (*options, error) {`
`163`	`163`	`}`
`164`	`164`
`165`	`165`	`// Wrap the transport in something that can retry network flakes.`
`166`		`- o.transport = transport.NewRetry(o.transport, transport.WithRetryPredicate(defaultRetryPredicate), transport.WithRetryStatusCodes(o.retryStatusCodes...))`
`167`		`-`
	`166`	`+ o.transport = transport.NewRetry(o.transport, transport.WithRetryBackoff(o.retryBackoff), transport.WithRetryPredicate(o.retryPredicate), transport.WithRetryStatusCodes(o.retryStatusCodes...))`
`168`	`167`	`// Wrap this last to prevent transport.New from double-wrapping.`
`169`	`168`	`if o.userAgent != "" {`
`170`	`169`	`o.transport = transport.NewUserAgent(o.transport, o.userAgent)`