{
"pairs":[
{
"asset_a":{
"name":"A"
},
"asset_b":{
"name":"B"
},
"a2b_fee":"0.1"
},
{
"asset_a":{
"name":"A"
},
"asset_c":{
"name":"C"
},
"a2c_fee":"0.01"
}
]
}
Hello,
I read in a few places that its strongly recommended that we provide our own executor.
https://stackoverflow.com/questions/42408634/what-is-the-exact-use-of-the-executor-in-grpc-java-s-serverbuilder-does-it-just
https://www.quora.com/What-are-some-tips-tricks-and-gotchas-when-using-gRPC
Had a few questions around this:
Is it as simple as the following?
serverBuilder.executor(Executors.newFixedThreadPool(executorProperties.eventLoopPoolSize, DefaultThreadFactory("some-pool-name")))Do I need to handle any graceful shutdown for ^. And if so, where/how would I do that?
How would I go about determining the appropriate count of threads for the above?
4 replies
I am working with ActiveMQ. I want to put gRPC calls as a message on ActiveMQ. As soon as consumer picks a message the gRPC in the message should execute.
gRPC calls take parameters so I want to understand how to send these parameters in the message body along with the method name/identifier. Is there any another way of achieving this which is followed already?
Example:
someResponse response = someStub.rpcMethodName(parameter); // grpc call
What I need is to store this statement in some format on ActiveMQ without calling the gRPC now. Then in the future when the consumer of ActiveMQ picks up the message containing this statement it should execute this gRPC call. Either storing the actual stub in the message or just the information required to recreate the stub will work.
1 reply
( Trying to send messages with IP using port forwarding on my router.)
I am having a wierd issue where i am able to send a message from each client i am testing once, but the next message that i try to send never arrives. I am using the same port, same blockingStub (and have seen that it is not blocked) since the program just exits from not getting a response!
What can it be and has anyone experienced the same thing??
, firewall was turned off on linux and on the router. Testing the exactly same code and sending the message to myself on the same computer but with same IP and Port works.
Please if anyone has an idea let me know!
:)
3 replies
Hello everyone,
This May 25 at 2:30 PM PT we are hosting a new gRPC community meetup.
Please add this meeting https://bit.ly/grpcmeetings to your calendar and join us to hear working groups updates and ask any technical questions you may have.
We will also show and discuss a demo, Improving experiences in Flutter with gRPC led by Fré Dumazy, Senior App Developer at Duo nv in Bruges, Belgium.
Looking forward to seeing most of you Thursday May 25th at our community meetup!
Hi,
I am running a grpc synchronous server impemented in C++. I notice when I run that many threads named ‘default-executo’ are spawned. It seems that even when clients cease to make connections, these threads still persist. There are dozens of these threads, and I would like to know what they are doing and what their lifespan is. Thanks!
Jeff
My apologies, I do not have editing permissions and instead of the calendar link, I shared the meeting doc. Below is the edited message regarding the upcoming community meetup.
Hello everyone,
This May 25 at 2:30 PM PT we are hosting a new gRPC community meetup.
Please add this meeting http://goo.gle/gRPCMeetupMay21 to your calendar and join us to hear working groups updates and ask any technical questions you may have.
We will also show and discuss a demo, Improving experiences in Flutter with gRPC led by Fré Dumazy, Senior App Developer at Duo nv in Bruges, Belgium.
Looking forward to seeing most of you Tuesday May 25th at our community meetup!
sudo bazel build :all (the command I am trying to run. I added sudo so it is similar to cmake install)?
Hi all,
Our gRPC clients in production occassionally suffer the following UNAVAILABLE errors when sending requests (likely due to scaling, pod reshuffling, or max connection age being reached).
14 UNAVAILABLE: goaway sent
14 UNAVAILABLE: GOAWAY received
14 UNAVAILABLE: Last stream closed after sending GOAWAY
14 UNAVAILABLE: TCP Write failedIn this documentation the UNAVAILABLE status has the following description.
The service is currently unavailable. This is most likely a transient condition, which can be corrected by retrying with a backoff. Note that it is not always safe to retry non-idempotent operations.
https://grpc.github.io/grpc/core/md_doc_statuscodes.html
The part that I'm interested in is this note.
Note that it is not always safe to retry non-idempotent operations
I have a client interceptor that will retry the request up to 3 times if the response status is UNAVAILABLE and the details are GOAWAY received.
I have confirmed locally that in the case of this response from the server the request does not reach the server application logic.
Is it safe to assume any responses returned by the gRPC server itself with the UNAVAILABLE status, have not hit the server application logic and can be retried without issues (double writes etc.)
?
7 replies
5 replies
Is there a rule of thumb for how to make sure code generated from protobuf version X is compatible with version Y? We've been bitten a few times when an upgrade is looking for new fields to be present in the generated code. (Python)
7 replies
DynamicMessage that is actually a BoolValue and turn it into a real com.google.protobuf.BoolValue in code? can i do this with a marshaller somehow (i.e. so a known-BoolValue field always parses to a BoolValue instead of a DynamicMessage), or do i need to do something like BoolValue.parseFrom(myDynamicMessage.toByteArray()) every time?
7 replies
I'm stucked in a very weird issue as posted here - grpc/grpc-java#7691
Saidly, I have no clue on how to reproduce it. I just know it happend after a while and my system blocking indefinitely
And I found someone in the chatting history encountered it as well
@ejona86 I'm calling it using a blocking stub, and in java, so I don't have a context to cancel like in Go, as far as I know. The blocking stub seems to hang indefinitely immediately if it can't get a response from the server, regardless of withDeadlineAfter()
Anybody has any idea?
1 reply
Unhandled Exception: gRPC Error (code: 14, codeName: UNAVAILABLE, message: Error connecting: SocketException: OS Error: Connection timed out, errno = 110, address = *.com, port = 49619, details: null, rawResponse: null)
Hey guys I need to use gRPC using flutter but no matter what i try I keep getting this. Has anyone used gRPC with flutter before I really would like to learn how to use it with TLS. All the videos and sources are mostly using local databases and insecure credentials.
Tuesday, June 22 at 2:30 PM PT we are hosting a new gRPC community meetup. Add this meeting to your calendar!
There will be working group updates, a demo, discussion time, and questions from users.
Ctx is key!, led by Samuel Davidson, Software Engineer, @Google.
Looking forward to seeing most of you this Thursday!
.proto file. you could probably just concatenate them yourself (removing the extra package line), if you felt strongly enough about it
Hello everybody.
We need an Urgent Help.
(Btw, we're also may be hiring soon and if you'll be able to help - it will most likely lead to an offer. )
Here is the thing:
We have NestJS microservices talking trough gRPC. We deploy it to AWS ECS on Fargate.
In the current (working) configuration we're using one instance per service and a CloudMap for service discovery.
Now we want to have multiple instances for some services. We've tried to configure the ALB.
In the TargetGroup we see targets in "Healthy" state.
But when we try to call services through the Load Balancer we receive '14 UNAVAILABLE: Trying to connect an http1.x server'
Any ideas?
3 replies
https://blog.gendocu.com/posts/grpc-web-on-aws/
If you like the product, please vote on us on today's product hunt:
https://www.producthunt.com/posts/gendocu-beta
I recently added grpc to my app, but it occasionally reports errors, which cannot be reproduced stably.
Console output:
java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception
at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:566)
at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:547)
My client uses Java, the server uses Python, and the grpc version is 1.36.0
Do I need to provide more information?
2 replies
func file_foo_proto_init() function is for? anyone know?
Hey guys, I'm considering using https://github.com/grpc-ecosystem/grpc-gateway for generating a REST API for my gRPC server, and I was wondering whether it is possible to specify exceptions to how types are mapped?
For example, I see in the documentation https://github.com/googleapis/googleapis/blob/master/google/api/http.proto that we can specify body to map the request body to a field in the gRPC request parameters.
However, will this work properly if I have a string field in my HTTP request body that is defined as an int or some other type in the protobuf definition? I want to use string for all numbers in my REST API, in order to eliminate loss of precision or ambiguity. And if it will not work properly out of the box, is there a way for me to specify the conversion?
