HTTPHeaderPropagationClientInterceptor allows for propagation of HTTP Request headers across gRPC calls - works alongside HTTPHeaderPropagationServerInterceptor
(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption)
| 67 | // HTTPHeaderPropagationClientInterceptor allows for propagation of HTTP Request headers across gRPC calls - works |
| 68 | // alongside HTTPHeaderPropagationServerInterceptor |
| 69 | func HTTPHeaderPropagationClientInterceptor(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, |
| 70 | invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error { |
| 71 | ctx = injectForwardedRequestMetadata(ctx) |
| 72 | return invoker(ctx, method, req, reply, cc, opts...) |
| 73 | } |
| 74 | |
| 75 | // HTTPHeaderPropagationStreamClientInterceptor does the same as HTTPHeaderPropagationClientInterceptor but for streams |
| 76 | func HTTPHeaderPropagationStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, |
nothing calls this directly
no test coverage detected