Fix GRPC client not honouring call options

harry671003 · harry671003 · commit 64be40394b10 · 2024-03-04T19:39:50.000-08:00
Signed-off-by: 🌲 Harry 🌊 John 🏔 &lt;johrry@amazon.com&gt;
diff --git a/pkg/util/grpcutil/util.go b/pkg/util/grpcutil/util.go
@@ -69,7 +69,7 @@ func HTTPHeaderPropagationClientInterceptor(ctx context.Context, method string,
 func HTTPHeaderPropagationStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string,
 	streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
 	ctx = injectForwardedHeadersIntoMetadata(ctx)
-	return streamer(ctx, desc, cc, method)
+	return streamer(ctx, desc, cc, method, opts...)
 }
 
 // injectForwardedHeadersIntoMetadata implements HTTPHeaderPropagationClientInterceptor and HTTPHeaderPropagationStreamClientInterceptor

Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,7 @@ func HTTPHeaderPropagationClientInterceptor(ctx context.Context, method string,`
`69`	`69`	`func HTTPHeaderPropagationStreamClientInterceptor(ctx context.Context, desc grpc.StreamDesc, cc grpc.ClientConn, method string,`
`70`	`70`	`streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {`
`71`	`71`	`ctx = injectForwardedHeadersIntoMetadata(ctx)`
`72`		`- return streamer(ctx, desc, cc, method)`
	`72`	`+ return streamer(ctx, desc, cc, method, opts...)`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`// injectForwardedHeadersIntoMetadata implements HTTPHeaderPropagationClientInterceptor and HTTPHeaderPropagationStreamClientInterceptor`