grpc-go
grpc-go copied to clipboard
grpc
The Go language implementation of gRPC. HTTP/2 based RPC
Fixes: #8125 RELEASE NOTES: - xdsclient: fixed an edge case race causing "resource doesn not exist" when rapidly subscribing and unsubscribing the same resource.
Fixes: https://github.com/grpc/grpc-go/issues/8305 After https://github.com/grpc/grpc-go/pull/7977 the server's serving mode started being updated to NOT_SERVING every time a listener resource is NACKed. During the test, the xDS management server replies with the...
Proposal to make the [http2ErrConvTab](https://github.com/grpc/grpc-go/blob/master/internal/transport/http_util.go#L51) configurable to users of the grpc-go client. ### Use case(s) - what problem will this feature solve? Gives gRPC clients greater control over how gRPC...
``` --- FAIL: Test (11.13s) --- FAIL: Test/ServerFailureMetrics_AfterResponseRecv (0.06s) metrics_test.go:221: Created new snapshot cache... tlogger.go:116: INFO server.go:690 [core] [Server #491]Server created (t=+1.218943ms) metrics_test.go:221: Registered Aggregated Discovery Service (ADS)... metrics_test.go:221: xDS...
Fixes: https://github.com/grpc/grpc-go/issues/8351 This change updates the test to avoid restarting the listener and instead fails the ADS stream by returning an error the the client's ACK based on https://github.com/grpc/grpc-go/issues/8351#issuecomment-2940759650 Verified...
Fixes: https://github.com/grpc/grpc-go/issues/8185 The test stores listener names in a buffered channel with capacity 1. The test generates 3 listener request messages: 1. Subscribe to resource. 2. ACK initial update. 3....
This reverts commit d2e836604b36400a54fbf04af495d12b38fa1e3a and fix the content-type for generic grpc transport. RELEASE NOTES: None
Fixes #8362 Partially addresses: #7286 In non-client streaming RPCs, the client's SendMsg() method is designed to automatically close the send operation after its initial call. If someone attempts to call...
Almost all references of [`BalancerData.Data`](https://github.com/grpc/grpc-go/blob/4275c5bdd8e86c450d84f66c9445560fefadc4ec/internal/balancer/stub/stub.go#L47-L54) are storing child balancers in it. This field is of type `any`, so callers have to cast it to a `balancer.Balancer` before every access. Example:...
``` --- FAIL: Test (7.02s) --- FAIL: Test/Server_RedundantUpdateSuppression (0.10s) server_resource_ext_test.go:169: Created new snapshot cache... tlogger.go:116: INFO server.go:715 [core] [Server #1501]Server created (t=+415.818µs) server_resource_ext_test.go:169: Registered Aggregated Discovery Service (ADS)... server_resource_ext_test.go:169: xDS...