google.golang.org/grpc.Server.opts (field)
60 uses
google.golang.org/grpc (current package)
server.go#L101: opts serverOptions
server.go#L480: s.serverWorkerChannels = make([]chan *serverWorkerData, s.opts.numServerWorkers)
server.go#L481: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L488: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L502: opts: opts,
server.go#L517: if s.opts.numServerWorkers > 0 {
server.go#L648: if s.opts.creds == nil {
server.go#L651: return s.opts.creds.ServerHandshake(rawConn)
server.go#L775: rawConn.SetDeadline(time.Now().Add(s.opts.connectionTimeout))
server.go#L811: MaxStreams: s.opts.maxConcurrentStreams,
server.go#L813: InTapHandle: s.opts.inTapHandle,
server.go#L814: StatsHandler: s.opts.statsHandler,
server.go#L815: KeepaliveParams: s.opts.keepaliveParams,
server.go#L816: KeepalivePolicy: s.opts.keepalivePolicy,
server.go#L817: InitialWindowSize: s.opts.initialWindowSize,
server.go#L818: InitialConnWindowSize: s.opts.initialConnWindowSize,
server.go#L819: WriteBufferSize: s.opts.writeBufferSize,
server.go#L820: ReadBufferSize: s.opts.readBufferSize,
server.go#L822: MaxHeaderListSize: s.opts.maxHeaderListSize,
server.go#L823: HeaderTableSize: s.opts.headerTableSize,
server.go#L845: if s.opts.numServerWorkers > 0 {
server.go#L848: case s.serverWorkerChannels[atomic.AddUint32(&roundRobinCounter, 1)%s.opts.numServerWorkers] <- data:
server.go#L899: st, err := transport.NewServerHandlerTransport(w, r, s.opts.statsHandler)
server.go#L995: if len(payload) > s.opts.maxSendMessageSize {
server.go#L996: return status.Errorf(codes.ResourceExhausted, "grpc: trying to send message larger than max (%d vs. %d)", len(payload), s.opts.maxSendMessageSize)
server.go#L999: if err == nil && s.opts.statsHandler != nil {
server.go#L1000: s.opts.statsHandler.HandleRPC(stream.Context(), outPayload(false, msg, data, payload, time.Now()))
server.go#L1009: interceptors := s.opts.chainUnaryInts
server.go#L1010: if s.opts.unaryInt != nil {
server.go#L1011: interceptors = append([]UnaryServerInterceptor{s.opts.unaryInt}, s.opts.chainUnaryInts...)
server.go#L1025: s.opts.unaryInt = chainedInt
server.go#L1040: sh := s.opts.statsHandler
server.go#L1130: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1131: dc = s.opts.dc
server.go#L1145: if s.opts.cp != nil {
server.go#L1146: cp = s.opts.cp
server.go#L1160: d, err := recvAndDecompress(&parser{r: stream}, stream, dc, s.opts.maxReceiveMessageSize, payInfo, decomp)
server.go#L1194: reply, appErr := md.Handler(info.serviceImpl, ctx, df, s.opts.unaryInt)
server.go#L1290: interceptors := s.opts.chainStreamInts
server.go#L1291: if s.opts.streamInt != nil {
server.go#L1292: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1306: s.opts.streamInt = chainedInt
server.go#L1324: sh := s.opts.statsHandler
server.go#L1340: maxReceiveMessageSize: s.opts.maxReceiveMessageSize,
server.go#L1341: maxSendMessageSize: s.opts.maxSendMessageSize,
server.go#L1406: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1407: ss.dc = s.opts.dc
server.go#L1421: if s.opts.cp != nil {
server.go#L1422: ss.cp = s.opts.cp
server.go#L1423: stream.SetSendCompress(s.opts.cp.Type())
server.go#L1440: if s.opts.streamInt == nil {
server.go#L1448: appErr = s.opts.streamInt(server, ss, info, sd.Handler)
server.go#L1526: if unknownDesc := s.opts.unknownStreamDesc; unknownDesc != nil {
server.go#L1622: if s.opts.numServerWorkers > 0 {
server.go#L1683: if s.opts.codec != nil {
server.go#L1684: return s.opts.codec
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |