| LOW | clientconn_provider.go | 21 | import ( | COMMENT |
| LOW | clientconn_provider.go | 61 | // A direct comparison of function values is not allowed in Go, so we use | COMMENT |
| LOW | server.go | 301 | // StaticStreamWindowSize returns a ServerOption to set the initial stream | COMMENT |
| LOW | server.go | 321 | // window size to the value provided and disables dynamic flow control. | COMMENT |
| LOW | server.go | 361 | // | COMMENT |
| LOW | server.go | 381 | // more details. Also see the documentation on RegisterCodec and | COMMENT |
| LOW | server.go | 401 | | COMMENT |
| LOW | server.go | 581 | } | COMMENT |
| LOW | server.go | 621 | // Notice: This API is EXPERIMENTAL and may be changed or removed in a | COMMENT |
| LOW | server.go | 641 | // a sane default. Preliminary experiments suggest that a value equal to the | COMMENT |
| LOW | server.go | 761 | s.events.Errorf(format, a...) | COMMENT |
| LOW | server.go | 1121 | // connection. When using the Go standard library's server, | COMMENT |
| LOW | server.go | 1641 | } | COMMENT |
| LOW | server.go | 1661 | // ServerTransportStreamFromContext returns the ServerTransportStream saved in | COMMENT |
| LOW | server.go | 1821 | // SetHeader sets the header metadata to be sent from the server to the client. | COMMENT |
| LOW | server.go | 1881 | // The context provided must be the context passed to the server's handler. | COMMENT |
| LOW | dialoptions.go | 221 | // and any value smaller than that will be ignored. | COMMENT |
| LOW | dialoptions.go | 241 | o.copts.InitialWindowSize = s | COMMENT |
| LOW | dialoptions.go | 301 | // WithDecompressor returns a DialOption which sets a Decompressor to use for | COMMENT |
| LOW | dialoptions.go | 361 | | COMMENT |
| LOW | dialoptions.go | 381 | // | COMMENT |
| LOW | dialoptions.go | 421 | | COMMENT |
| LOW | dialoptions.go | 481 | // returned by f, gRPC checks the error's Temporary() method to decide if it | COMMENT |
| LOW | dialoptions.go | 541 | }) | COMMENT |
| LOW | dialoptions.go | 621 | }) | COMMENT |
| LOW | dialoptions.go | 661 | // service config, which will be used in cases where: | COMMENT |
| LOW | dialoptions.go | 761 | // | COMMENT |
| LOW | dialoptions.go | 781 | // | COMMENT |
| LOW | backoff.go | 41 | type BackoffConfig struct { | COMMENT |
| LOW | stream.go | 61 | // status package, or be one of the context errors. Otherwise, gRPC will use | COMMENT |
| LOW | stream.go | 81 | | COMMENT |
| LOW | stream.go | 101 | // is nil and the error is also nil, then the stream was terminated without | COMMENT |
| LOW | stream.go | 121 | // RPCs (StreamDesc.ClientStreams is false), a nil error is returned | COMMENT |
| LOW | stream.go | 141 | // RecvMsg blocks until it receives a message into m or the stream is | COMMENT |
| LOW | stream.go | 221 | if err == nil { | COMMENT |
| LOW | stream.go | 641 | return status.Error(codes.Internal, err.Error()) | COMMENT |
| LOW | stream.go | 721 | | COMMENT |
| LOW | stream.go | 1401 | // | COMMENT |
| LOW | stream.go | 1721 | // this purpose. | COMMENT |
| LOW | stream.go | 1741 | // | COMMENT |
| LOW | clientconn.go | 61 | minConnectTimeout = 20 * time.Second | COMMENT |
| LOW | clientconn.go | 81 | // PickFirstBalancerName is the name of the pick_first balancer. | COMMENT |
| LOW | clientconn.go | 161 | // | COMMENT |
| LOW | clientconn.go | 261 | // | COMMENT |
| LOW | clientconn.go | 461 | <-bWrapper.serializer.Done() | COMMENT |
| LOW | clientconn.go | 641 | // ClientConnInterface defines the functions clients need to perform unary and | COMMENT |
| LOW | clientconn.go | 721 | } | COMMENT |
| LOW | clientconn.go | 741 | cc.mu.Lock() | COMMENT |
| LOW | clientconn.go | 1741 | // We have to release the lock before the call to GracefulClose/Close here | COMMENT |
| LOW | clientconn.go | 1961 | // Determine channel authority. The order of precedence is as follows: | COMMENT |
| LOW | stream_interfaces.go | 21 | // ServerStreamingClient represents the client side of a server-streaming (one | COMMENT |
| LOW | stream_interfaces.go | 41 | // | COMMENT |
| LOW | stream_interfaces.go | 61 | type ClientStreamingClient[Req any, Res any] interface { | COMMENT |
| LOW | stream_interfaces.go | 81 | // ClientStreamingServer represents the server side of a client-streaming (many | COMMENT |
| LOW | stream_interfaces.go | 101 | // calling SendAndClose. | COMMENT |
| LOW | stream_interfaces.go | 121 | | COMMENT |
| LOW | stream_interfaces.go | 141 | // an error from the status package, or use nil to indicate an OK status code. | COMMENT |
| LOW | interceptor.go | 21 | import ( | COMMENT |
| LOW | interceptor.go | 41 | // | COMMENT |
| LOW | interceptor.go | 61 | // StreamClientInterceptor may return a custom ClientStream to intercept all I/O | COMMENT |
| 593 more matches not shown… |
Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).