type google.golang.org/grpc.Server
43 uses
google.golang.org/grpc (current package)
server.go#L73: internal.GetServerCredentials = func(srv *Server) credentials.TransportCredentials {
server.go#L76: internal.IsRegisteredMethod = func(srv *Server, method string) bool {
server.go#L89: internal.MetricsRecorderForServer = func(srv *Server) estats.MetricsRecorder {
server.go#L128: type Server struct {
server.go#L679: func (s *Server) serverWorker() {
server.go#L692: func (s *Server) initServerWorkers() {
server.go#L704: func NewServer(opt ...ServerOption) *Server {
server.go#L712: s := &Server{
server.go#L740: func (s *Server) printf(format string, a ...any) {
server.go#L748: func (s *Server) errorf(format string, a ...any) {
server.go#L770: func (s *Server) RegisterService(sd *ServiceDesc, ss any) {
server.go#L781: func (s *Server) register(sd *ServiceDesc, ss any) {
server.go#L827: func (s *Server) GetServiceInfo() map[string]ServiceInfo {
server.go#L888: func (s *Server) Serve(lis net.Listener) error {
server.go#L982: func (s *Server) handleRawConn(lisAddr string, rawConn net.Conn) {
server.go#L1013: func (s *Server) newHTTP2Transport(c net.Conn) transport.ServerTransport {
server.go#L1053: func (s *Server) serveStreams(ctx context.Context, st transport.ServerTransport, rawConn net.Conn) {
server.go#L1093: var _ http.Handler = (*Server)(nil)
server.go#L1123: func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
server.go#L1137: func (s *Server) addConn(addr string, st transport.ServerTransport) bool {
server.go#L1158: func (s *Server) removeConn(addr string, st transport.ServerTransport) {
server.go#L1175: func (s *Server) incrCallsStarted() {
server.go#L1180: func (s *Server) incrCallsSucceeded() {
server.go#L1184: func (s *Server) incrCallsFailed() {
server.go#L1188: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1225: func chainUnaryServerInterceptors(s *Server) {
server.go#L1260: func (s *Server) processUnaryRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1555: func chainStreamServerInterceptors(s *Server) {
server.go#L1590: func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1782: func (s *Server) handleMalformedMethodName(stream *transport.ServerStream, ti *traceInfo) {
server.go#L1800: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.ServerStream) {
server.go#L1943: func (s *Server) Stop() {
server.go#L1950: func (s *Server) GracefulStop() {
server.go#L1954: func (s *Server) stop(graceful bool) {
server.go#L1999: func (s *Server) closeServerTransportsLocked() {
server.go#L2008: func (s *Server) drainAllServerTransportsLocked() {
server.go#L2020: func (s *Server) closeListenersLocked() {
server.go#L2029: func (s *Server) getCodec(contentSubtype string) baseCodec {
server.go#L2047: func serverFromContext(ctx context.Context) *Server {
server.go#L2048: s, _ := ctx.Value(serverKey{}).(*Server)
server.go#L2053: func contextWithServer(ctx context.Context, server *Server) context.Context {
server.go#L2060: func (s *Server) isRegisteredMethod(serviceMethod string) bool {
go.pact.im/x/grpcprocess
grpcprocess.go#L15: func Server(srv *grpc.Server, lis net.Listener) process.Runner {