47deg/mu

http://higherkindness.io/mu-scala/

Mauro González

@maurogonzalez

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.

Sander Dijkhuis

@sander

@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

Mauro González

@maurogonzalez

Thanks @sander , I'll give it a try.

Mauro González

@maurogonzalez

I just tried using srcGen and still throwing the same error with numeric types like float. Any idea?

Fede Fernández

@fedefernandez

@maurogonzalez not from top of my head sorry. could you please raise an issue? thanks

Mauro González

@maurogonzalez

Sure @fedefernandez

Mauro González

@maurogonzalez

higherkindness/mu#606

Fede Fernández

@fedefernandez

thanks

Sander Dijkhuis

@sander

Raised a best-practices question in higherkindness/mu#608 - curious about your experiences

Juan Pedro Moreno

@juanpedromoreno

Hi @maurogonzalez , I replied in the issue but I’m afraid that I cannot reproduce the problem :/

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 :)

Mauro González

@maurogonzalez

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.

Mauro González

@maurogonzalez

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 value

while mu client returns other value of the enum type different from the one defined in the handler.

Mauro González

@maurogonzalez

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)

Juan Pedro Moreno

@juanpedromoreno

@maurogonzalez , would you mind to submit an issue? We’ll take a look at it asap. Thanks!

Mauro González

@maurogonzalez

Sure @juanpedromoreno higherkindness/mu#611 Also I'll take a look if it's related with Scala's Object and Java's dependencies.

Juan Pedro Moreno

@juanpedromoreno

Thanks Mauro!

Adrian Ramirez Fornell

@AdrianRaFo

@maurogonzalez One question, Do you have the enum elements declared on the same order for both the idl and the scala enum?

Mauro González

@maurogonzalez

@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).

Maureen Elsberry

@MaureenElsberry

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/

Javier de Silóniz Sandino

@jdesiloniz

Please feel free to let us know your comments or questions about the article :)

Lukasz Trojanowski

@lstrojanowski_twitter

Does anyone work on the kotlin version of mu, or is this currently on hold?

Raúl Raja Martínez

@raulraja

@lstrojanowski_twitter we are getting started but prioritising work on Arrow Fx since streams is needed for Mu

We will focus on Mu for Kotlin once Arrow 0.10 releases in a couple of weeks

Ghost

@ghost~576313fbc2f0db084a1e4ad4

hi, i was looking at mu. it looks really interesting. i had a question, is it a bad idea to have a grpc client and server on the same JVM instance ?

call graph server A <--> server B server A <--> server C and server B <--> server C

its bi directional

Juan Manuel Méndez Rey

@vejeta

@virdis For starters, Imagine that one of the processes make the JVM crash, for example, the client, that would destroy both client and server, separating them would prevent such problems.
I don't understand the second question.

sandeep virdi

@_svirdi_twitter

@vejeta thanks for the reply, apologies for not being very clear.
I want server to server communication, and these servers form a "ring". From all that I have seen, it seems adding a client to the same JVM process is the way to go.

Juan Manuel Méndez Rey

@vejeta

ah, ok, that makes more sense

sbrignone

@sbrignone

Is there an example that shows how to use okhttp?

Vadim Agishev

@Chicker

@juanpedromoreno Hi! Could you look at my PR? higherkindness/mu#683

We heavy use your library and this feature is really needed for us.

Daniel Ochoa Rodríguez

@tzimisce012

:+1:

Vadim Agishev

@Chicker

@fedefernandez @juanpedromoreno Thanks a lot for your quick response to my PR!
Is there any chance to make a release that will include that PR?

Rik

@rikvdkleij-cleverbase

Hi, When an exception is thrown in a grpc mu handler, the exception is swallowed

Any idea how to solve it properly in a generic way?

So for example a NPE in pure and/or impure code

Adrian Ramirez Fornell

@AdrianRaFo

Any grpc endpoint or call using Mu should return an F of whatever, that F, if you have an implicit of MonadError or any of its inheritors, should let you use attempt, handleError or the handling method that fits better your logic to manage those errors. See https://typelevel.org/cats-effect/ for more info

Rik

@rikvdkleij-cleverbase

@AdrianRaFo Thanks for your reply

There is always the possibility that an exception is thrown in pure code

For example a NPE

Rik

@rikvdkleij-cleverbase

So you have to handle the errors your self? If not handled by yourself by using handleError then they are swallowed?

Vadim Agishev

@Chicker

@fedefernandez @juanpedromoreno Hi, there!
Is there any chance to make a release in the near future that will include this PR: higherkindness/mu#683 This functionality is really needed for us. Thanks for your response.

Juan Pedro Moreno

@juanpedromoreno

@Chicker Sure, will do a release early this week with your changes. Thanks

Odomontois

@Odomontois

Is there some effort to cross compile to 2.13?

Juan Manuel Méndez Rey

@vejeta

that is the intention @Odomontois , apropos: higherkindness/mu#642
not sure if there is anyone working actively on it right now.

Anti-pin

@Anti-pin

Hello. A suggestion - separate examples from your main git project, ideally each example should have its own set of dependencies.

As it is, "seed" is not really a seed as I can't simply copy it over and start my own project using mu as an external dependency

Where communities thrive

People

Repo info

Activity