unistack-org/micro-client-grpc
4
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 40 Wiki Activity

send metadata as lowercase
Some checks failed
coverage / build (push) Successful in 1m58s
Details
test / test (push) Successful in 4m45s
Details
sync / sync (push) Has been cancelled
Details

Browse Source 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов
2025-05-02 17:48:26 +03:00
parent b23469853f
commit be904bc534
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
grpc.go
View File

@@ -77,13 +77,13 @@ func (g *grpcClient) call(ctx context.Context, addr string, req client.Request,
var header map[string][]string var header map[string][]string
if md, ok := metadata.FromOutgoingContext(ctx); ok { if md, ok := metadata.FromOutgoingContext(ctx); ok {
header = metadata.Copy(md) header = metadata.Copy(md).AsHTTP2()
} else { } else {
header = make(map[string][]string, 2) header = make(map[string][]string, 2)
} }
if opts.RequestMetadata != nil { if opts.RequestMetadata != nil {
for k, v := range opts.RequestMetadata { for k, v := range opts.RequestMetadata {
header[k] = v header[strings.ToLower(k)] = v
} }
} }
// set timeout in nanoseconds // set timeout in nanoseconds
@@ -188,7 +188,7 @@ func (g *grpcClient) stream(ctx context.Context, addr string, req client.Request
var header map[string][]string var header map[string][]string
if md, ok := metadata.FromOutgoingContext(ctx); ok { if md, ok := metadata.FromOutgoingContext(ctx); ok {
header = metadata.Copy(md) header = metadata.Copy(md).AsHTTP2()
} else { } else {
header = make(map[string][]string) header = make(map[string][]string)
} }