| LOW | server.go | 301 | // will be ignored. |
| LOW | server.go | 361 | // See also |
| LOW | server.go | 381 | // |
| LOW | server.go | 401 | // |
| LOW | server.go | 621 | return newFuncServerOption(func(o *serverOptions) { |
| LOW | server.go | 661 | return newFuncServerOption(func(o *serverOptions) { |
| LOW | server.go | 861 | } |
| LOW | server.go | 1101 | // practically this means that the Request must also have arrived |
| LOW | server.go | 1901 | // Notice: This API is EXPERIMENTAL and may be changed or removed in a |
| LOW | server.go | 1921 | SendHeader(md metadata.MD) error |
| LOW | server.go | 2081 | |
| LOW | server.go | 2141 | // |
| LOW | dialoptions.go | 181 | }) |
| LOW | dialoptions.go | 241 | o.copts.StaticWindowSize = true |
| LOW | dialoptions.go | 301 | // incoming message decompression. If incoming response messages are encoded |
| LOW | dialoptions.go | 361 | // WithBlock returns a DialOption which makes callers of Dial block until the |
| LOW | dialoptions.go | 381 | // Use of this feature is not recommended. For more information, please see: |
| LOW | dialoptions.go | 421 | // WithLocalDNSResolution forces local DNS name resolution even when a proxy is |
| LOW | dialoptions.go | 481 | // should try to reconnect to the network address. |
| LOW | dialoptions.go | 541 | } |
| LOW | dialoptions.go | 621 | } |
| LOW | dialoptions.go | 661 | // |
| LOW | dialoptions.go | 761 | // # Experimental |
| LOW | dialoptions.go | 781 | // # Experimental |
| LOW | backoff.go | 41 | type BackoffConfig struct { |
| LOW | stream.go | 81 | // Stream defines the common interface a client or server stream has to satisfy. |
| LOW | stream.go | 101 | // headers, and the status can be discovered by calling RecvMsg. |
| LOW | stream.go | 121 | // unconditionally. |
| LOW | stream.go | 141 | // done. It returns io.EOF when the stream completes successfully. On |
| LOW | stream.go | 521 | |
| LOW | stream.go | 601 | // |
| LOW | stream.go | 1581 | // Errors returned from ServerStream methods are compatible with the status |
| LOW | stream.go | 1601 | Context() context.Context |
| LOW | clientconn.go | 61 | const ( |
| LOW | clientconn.go | 81 | // service config. |
| LOW | clientconn.go | 161 | // connect. The Connect method may be called to manually create a connection, |
| LOW | clientconn.go | 261 | |
| LOW | clientconn.go | 461 | // Block until the name resolver and LB policy are closed. |
| LOW | clientconn.go | 641 | } |
| LOW | clientconn.go | 741 | // If the ClientConn was not in idle mode, we need to call ExitIdle on the |
| LOW | clientconn.go | 1161 | cc.mu.RUnlock() |
| LOW | clientconn.go | 1541 | // state. tearDown() would have set the state to `Shutdown`, but |
| LOW | clientconn.go | 1721 | channelz.RemoveEntry(ac.channelz.ID) |
| LOW | clientconn.go | 1941 | return string(t) |
| LOW | stream_interfaces.go | 21 | // ServerStreamingClient represents the client side of a server-streaming (one |
| LOW | stream_interfaces.go | 41 | // |
| LOW | stream_interfaces.go | 61 | type ClientStreamingClient[Req any, Res any] interface { |
| LOW | stream_interfaces.go | 81 | // ClientStreamingServer represents the server side of a client-streaming (many |
| LOW | stream_interfaces.go | 101 | // calling SendAndClose. |
| LOW | stream_interfaces.go | 121 | |
| LOW | stream_interfaces.go | 141 | // an error from the status package, or use nil to indicate an OK status code. |
| LOW | interceptor.go | 21 | import ( |
| LOW | interceptor.go | 41 | // |
| LOW | interceptor.go | 61 | // StreamClientInterceptor may return a custom ClientStream to intercept all I/O |
| LOW | interceptor.go | 101 | // streaming RPC on the server. |
| LOW | service_config.go | 41 | // |
| LOW | service_config.go | 61 | // exact match for a method (i.e. /service/method) in the map, use the |
| LOW | service_config.go | 101 | MaxBackoff internalserviceconfig.Duration |
| LOW | rpc_util.go | 361 | } |
| LOW | rpc_util.go | 501 | return nil |
| 545 more matches not shown… |