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