go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-12-24 10:07:04 +02:00
Code Issues Releases Activity

Don't set stream unless its true

Browse Source
This commit is contained in:
Asim Aslam 2019-11-09 10:32:52 +00:00
parent 0b1e6d7eaf
commit a9e8fc6039
2 changed files with 19 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/extractor.go
View File

@ -95,14 +95,20 @@ func extractEndpoint(method reflect.Method) *registry.Endpoint {
request := extractValue(reqType, 0)
response := extractValue(rspType, 0)
return &registry.Endpoint{
ep := &registry.Endpoint{
Name: method.Name,
Request: request,
Response: response,
Metadata: map[string]string{
"stream": fmt.Sprintf("%v", stream),
},
}
// set endpoint metadata for stream
if stream {
ep.Metadata = map[string]string{
"stream": fmt.Sprintf("%v", stream),
}
}
return ep
}
func extractSubValue(typ reflect.Type) *registry.Value {

13
server/grpc/extractor.go
View File

@ -90,14 +90,19 @@ func extractEndpoint(method reflect.Method) *registry.Endpoint {
request := extractValue(reqType, 0)
response := extractValue(rspType, 0)
return &registry.Endpoint{
ep := &registry.Endpoint{
Name: method.Name,
Request: request,
Response: response,
Metadata: map[string]string{
"stream": fmt.Sprintf("%v", stream),
},
}
if stream {
ep.Metadata = map[string]string{
"stream": fmt.Sprintf("%v", stream),
}
}
return ep
}
func extractSubValue(typ reflect.Type) *registry.Value {