type google.golang.org/grpc.Server
38 uses
google.golang.org/grpc (current package)
server.go#L70: internal.GetServerCredentials = func(srv *Server) credentials.TransportCredentials {
server.go#L73: internal.DrainServerTransports = func(srv *Server, addr string) {
server.go#L125: type Server struct {
server.go#L568: func (s *Server) serverWorker(ch chan *serverWorkerData) {
server.go#L585: func (s *Server) initServerWorkers() {
server.go#L593: func (s *Server) stopServerWorkers() {
server.go#L601: func NewServer(opt ...ServerOption) *Server {
server.go#L609: s := &Server{
server.go#L637: func (s *Server) printf(format string, a ...interface{}) {
server.go#L645: func (s *Server) errorf(format string, a ...interface{}) {
server.go#L667: func (s *Server) RegisterService(sd *ServiceDesc, ss interface{}) {
server.go#L678: func (s *Server) register(sd *ServiceDesc, ss interface{}) {
server.go#L724: func (s *Server) GetServiceInfo() map[string]ServiceInfo {
server.go#L780: func (s *Server) Serve(lis net.Listener) error {
server.go#L873: func (s *Server) handleRawConn(lisAddr string, rawConn net.Conn) {
server.go#L896: func (s *Server) drainServerTransports(addr string) {
server.go#L907: func (s *Server) newHTTP2Transport(c net.Conn) transport.ServerTransport {
server.go#L944: func (s *Server) serveStreams(st transport.ServerTransport) {
server.go#L978: var _ http.Handler = (*Server)(nil)
server.go#L1008: func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
server.go#L1024: func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceInfo) {
server.go#L1046: func (s *Server) addConn(addr string, st transport.ServerTransport) bool {
server.go#L1067: func (s *Server) removeConn(addr string, st transport.ServerTransport) {
server.go#L1084: func (s *Server) channelzMetric() *channelz.ServerInternalMetric {
server.go#L1093: func (s *Server) incrCallsStarted() {
server.go#L1098: func (s *Server) incrCallsSucceeded() {
server.go#L1102: func (s *Server) incrCallsFailed() {
server.go#L1106: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
server.go#L1132: func chainUnaryServerInterceptors(s *Server) {
server.go#L1167: func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1447: func chainStreamServerInterceptors(s *Server) {
server.go#L1482: func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1674: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceInfo) {
server.go#L1789: func (s *Server) Stop() {
server.go#L1831: func (s *Server) GracefulStop() {
server.go#L1874: func (s *Server) getCodec(contentSubtype string) baseCodec {
server.go#L1966: s *Server
go.pact.im/x/grpcprocess
grpcprocess.go#L14: func Server(srv *grpc.Server, lis net.Listener) process.Runnable {