[grpc-io] What's the Threading Model behind Completion Queue?

2021-07-22 Thread Lixin Wei
I'm wondering what's the threading model behind the completion queue? Who produces items to the completion queue? What is between the completion queue and the network? -- You received this message because you are subscribed to the Google Groups "grpc.io" group. To unsubscribe from this group a

Re: [grpc-io] Go - Reconnection in bidi streaming RPC communication

2021-07-22 Thread Amit Saha
> On 23 Jul 2021, at 2:29 am, 'dfa...@google.com' via grpc.io > wrote: > > On Wednesday, July 14, 2021 at 3:53:40 PM UTC-7 amits...@gmail.com wrote: > Thanks, I am able to understand what you are proposing. With this > approach, when I try to Send() with the stream disconnected, then the > o

[grpc-io] Re: In python asyncio grpc server, handling a client-triggered cancellation of an RPC on the server-side

2021-07-22 Thread Brunston
...Turns out you *can* catch the asyncio.CancelledError raised by grpc core. That should work for my current usecase. Any other suggestions that can shed light on the shared context would still be helpful! Brunston On Thursday, July 22, 2021 at 2:51:03 PM UTC-7 Brunston wrote: > Hi all! I have

[grpc-io] In python asyncio grpc server, handling a client-triggered cancellation of an RPC on the server-side

2021-07-22 Thread Brunston
Hi all! I have a question about a Python asyncio gRPC server: How can I perform some server-side action (eg, cleanup) based on a cancellation of an RPC from the client? In my microservice, I have an asyncio gRPC server whose main RPCs are bidirectional streams. On the client side (which is als

Re: [grpc-io] Re: Go - Reconnection in bidi streaming RPC communication

2021-07-22 Thread 'dfa...@google.com' via grpc.io
On Wednesday, July 14, 2021 at 3:53:40 PM UTC-7 amits...@gmail.com wrote: > Thanks, I am able to understand what you are proposing. With this > approach, when I try to Send() with the stream disconnected, then the > operation will either exit - which is not what I want, or wait for the > recv()

[grpc-io] Re: 2 way communication over single tcp connection

2021-07-22 Thread Rajat Goyal
Hi Sergii, Please find my nginx conf: user nginx; worker_processes 1; error_log /var/log/nginx/error.log notice; pid /var/run/nginx.pid; events { worker_connections 1024; } http { map $upstream_trailer_grpc_status $grpc_status { default $upstream_trailer_grpc_status; # We normall

[grpc-io] Re: gRPC Multiple service instances on same port

2021-07-22 Thread Cosmin
Thank you for the info. Does anybody know if something like this will be possible in the future on windows? On Wednesday, July 21, 2021 at 8:50:36 PM UTC+3 pixel...@gmail.com wrote: > Unfortunately, there's currently no support for this on Windows. There is > currently support for SO_REUSEPORT

[grpc-io] Please review my gRPC library which simplifies usage of the gRPC error model in Golang

2021-07-22 Thread Tobias Strandberg
Hi, I've written a library which I hope can be useful to the community. Please review it and leave comments. Thanks in advance, Tobias -- You received this message because you are subscribed to the Google Groups "grpc.io" group. To unsubscribe from this gro

[grpc-io] Go - TRANSIENT_FAILURE and FailOnNonTempDialError

2021-07-22 Thread Amit Saha
Hi all - is it correct to say that what's considered a transient failure (in the context of Wait For Ready semantics [1]) is also what's considered a temporary error when using the grpc.WithBlock() DialOption? Also, is there any documentation around what's considered a temporary failure and/or tra