grpclib
grpclib copied to clipboard
vmagamedov
Pure-Python gRPC implementation for asyncio
`graceful_exit` ultimate calls `server.close()` which is defined as: ``` def close(self) -> None: """Stops accepting new connections, cancels all currently running requests. Request handlers are able to handle `CancelledError` and...
The docs as per https://grpclib.readthedocs.io/en/latest/errors.html#server-side state: The docs state: 1. Task running SayHello coroutine gets cancelled and CancelledError is raised inside it 2. When SayHello coroutine finishes, grpclib server internally...
It would be great to be able to trace our gRPC servers and clients using opentelemetry. How would I tie it into this library? I would like to have each...
First of all, this package is amazing! I'm trying to write middleware that catches an RPC error and examines it before re-raising to the caller. I have defined a number...
The official grpc client supports [grpc service config](https://fuchsia.googlesource.com/third_party/grpc/+/HEAD/doc/service_config.md) and allows for client side retry ([example](https://stackoverflow.com/questions/64227270/use-retrypolicy-with-python-grpc-client). Is this something that could be done with an event? Or would retry have to...
For example, adjusting max streams does not seem to be possible.
In the example provided in the docs using the `open()` method on a stream creates a context manager that can be used to send and receive messages. One of the...
I'd like to see this and might have the time to work on it. Right now, asyncio seems to be hardcoded into the interface. Are there any plans for how...
just like `conn = Channel(cache_address, options=[('grpc.max_message_length', 1024 * 1024 * 1024), ('grpc.max_send_message_length', 1024 * 1024 * 1024), ('grpc.max_receive_message_length', 1024 * 1024 * 1024)])`
