Hi! I’m trying to create a gRPC service using mu that can be consumed from a golang client. However, I’m getting
Method not found errors. Code and description are in: https://github.com/sander/rpctest Any ideas what’s going on?
Found it, using Wireshark. Fix is in https://github.com/sander/rpctest/tree/fix . Turns out that even though
idlGen emitted a call to /rpctest.pkg.Greeter/SayHello, the server only accepts a call to /Greeter/sayHello. This is also what a mu client would send apparently. The former format appears more idiomatic gRPC. Do you intend to support this?
You could create a server interceptor
https://github.com/grpc/grpc-java/blob/master/examples/src/main/java/io/grpc/examples/header/HeaderServerInterceptor.java
And then pass it to the service with
https://github.com/higherkindness/mu/blob/ddda6faaae7ea3a7bb90794c652fe8812b40b78c/docs/src/main/tut/metrics-reporting.md#L81
https://github.com/grpc/grpc-java/blob/master/examples/src/main/java/io/grpc/examples/header/HeaderServerInterceptor.java
And then pass it to the service with
interceptWith. We do that for the metrics:https://github.com/higherkindness/mu/blob/ddda6faaae7ea3a7bb90794c652fe8812b40b78c/docs/src/main/tut/metrics-reporting.md#L81
Thanks, will try to prioritize in the backlog
Apr 24, 2019 5:08:00 PM io.grpc.internal.SerializingExecutor run
SEVERE: Exception while executing runnable io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable@7ae1abfe
java.util.NoSuchElementException: head of empty list
at scala.collection.immutable.Nil$.head(List.scala:426)
at scala.collection.immutable.Nil$.head(List.scala:423)
at pbdirect.PBParserImplicits.$anonfun$requiredParser$1(PBReader.scala:173)
at pbdirect.PBParserImplicits.$anonfun$requiredParser$1$adapted(PBReader.scala:162)
at pbdirect.LowPriorityPBParserImplicits$$anon$2.parse(PBReader.scala:119)
at pbdirect.LowPriorityPBParserImplicits.$anonfun$consParser$1(PBReader.scala:128)
at pbdirect.LowPriorityPBParserImplicits.$anonfun$consParser$1$adapted(PBReader.scala:127)
at pbdirect.LowPriorityPBParserImplicits$$anon$2.parse(PBReader.scala:119)
at pbdirect.PBReaderImplicits.$anonfun$prodReader$1(PBReader.scala:62)
at pbdirect.LowerPriorityPBReaderImplicits$$anon$1.read(PBReader.scala:38)
at pbdirect.PBParserImplicits.$anonfun$requiredParser$1(PBReader.scala:169)
at pbdirect.PBParserImplicits.$anonfun$requiredParser$1$adapted(PBReader.scala:162)
at pbdirect.LowPriorityPBParserImplicits$$anon$2.parse(PBReader.scala:119)
at pbdirect.package$PBParserOps$.pbTo$extension(package.scala:47)
at higherkindness.mu.rpc.internal.encoders.pbd$$anon$1.parse(pbd.scala:40)
at io.grpc.MethodDescriptor.parseRequest(MethodDescriptor.java:289)
at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:263)
at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:687)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) It seems to be a parser error but couldn't find the reason.
@maurogonzalez from https://github.com/higherkindness/mu/issues/604#issuecomment-486384131 I understand that
idlGen will be deprecated so rpctest should not be the best starting point. Better to create a valid .proto file first and then use srcGen
I’ve collected some pieces of code that I used in this gist: https://gist.github.com/juanpedromoreno/350b4051823cfaee6dcb455657534133
Thanks for higherkindness/mu#608 @sander , I’ll try to write up something, later today or tomorrow :)
Hi @juanpedromoreno thanks for the reply, with mu client I didn't have any issue, works fine. But using grpcurl (https://github.com/fullstorydev/grpcurl) and the given *.proto file it failed. I answered in the issue with the exact command. I'm trying to test interop.
Hey there, I found another issue related to enums in the response message:
grpcurl throws
ERROR:
Code: Internal
Message: grpc: failed to unmarshal the received message type_enum field HelloResponse.message is not compatible with nil valuewhile mu client returns other value of the enum type different from the one defined in the handler.
Hi @juanpedromoreno , hope things are going well. I also found that is failing in the request message (only testing mu's server/client). I forked and example to add client app and using
srcGen in compilation: https://github.com/maurogonzalez/rpctest/tree/enums
// ClientApp
... client.sayHello(Test.HELLO)
// Server Log: INFO GreeterServiceHandler - Request: HelloRequest(GOODBYE)
// Client Log: INFO GreeterServiceClient - Request: HELLO - Result: HelloResponse(GOODBYE)
Sure @juanpedromoreno higherkindness/mu#611 Also I'll take a look if it's related with Scala's Object and Java's dependencies.
@AdrianRaFo Scala's are generated by
srcGen and yes, they are in the same order. There are some issues with Scala object and java code because they are not really singletons from the java's perspective. An example: https://blog.softwaremill.com/is-your-scala-object-always-a-singleton-cb3fd24a2fd9 not sure if this is related with these "enums" and io.grpc (java).
Javi has a new article on extracting metrics from mu-rpc microservices using Prometheus and DropWizard here: https://www.47deg.com/blog/metrics-integration-with-mu/
We will focus on Mu for Kotlin once Arrow 0.10 releases in a couple of weeks
call graph server A <--> server B server A <--> server C and server B <--> server C
its bi directional
