type google.golang.org/grpc.Server
42 uses
google.golang.org/grpc (current package)
server.go#L71: internal.GetServerCredentials = func(srv *Server) credentials.TransportCredentials {
server.go#L74: internal.IsRegisteredMethod = func(srv *Server, method string) bool {
server.go#L87: internal.MetricsRecorderForServer = func(srv *Server) estats.MetricsRecorder {
server.go#L126: type Server struct {
server.go#L661: func (s *Server) serverWorker() {
server.go#L674: func (s *Server) initServerWorkers() {
server.go#L686: func NewServer(opt ...ServerOption) *Server {
server.go#L694: s := &Server{
server.go#L721: func (s *Server) printf(format string, a ...any) {
server.go#L729: func (s *Server) errorf(format string, a ...any) {
server.go#L751: func (s *Server) RegisterService(sd *ServiceDesc, ss any) {
server.go#L762: func (s *Server) register(sd *ServiceDesc, ss any) {
server.go#L808: func (s *Server) GetServiceInfo() map[string]ServiceInfo {
server.go#L869: func (s *Server) Serve(lis net.Listener) error {
server.go#L965: func (s *Server) handleRawConn(lisAddr string, rawConn net.Conn) {
server.go#L996: func (s *Server) newHTTP2Transport(c net.Conn) transport.ServerTransport {
server.go#L1036: func (s *Server) serveStreams(ctx context.Context, st transport.ServerTransport, rawConn net.Conn) {
server.go#L1076: var _ http.Handler = (*Server)(nil)
server.go#L1106: func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
server.go#L1120: func (s *Server) addConn(addr string, st transport.ServerTransport) bool {
server.go#L1141: func (s *Server) removeConn(addr string, st transport.ServerTransport) {
server.go#L1158: func (s *Server) incrCallsStarted() {
server.go#L1163: func (s *Server) incrCallsSucceeded() {
server.go#L1167: func (s *Server) incrCallsFailed() {
server.go#L1171: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1212: func chainUnaryServerInterceptors(s *Server) {
server.go#L1247: func (s *Server) processUnaryRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1543: func chainStreamServerInterceptors(s *Server) {
server.go#L1578: func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1775: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.ServerStream) {
server.go#L1927: func (s *Server) Stop() {
server.go#L1934: func (s *Server) GracefulStop() {
server.go#L1938: func (s *Server) stop(graceful bool) {
server.go#L1983: func (s *Server) closeServerTransportsLocked() {
server.go#L1992: func (s *Server) drainAllServerTransportsLocked() {
server.go#L2004: func (s *Server) closeListenersLocked() {
server.go#L2013: func (s *Server) getCodec(contentSubtype string) baseCodec {
server.go#L2031: func serverFromContext(ctx context.Context) *Server {
server.go#L2032: s, _ := ctx.Value(serverKey{}).(*Server)
server.go#L2037: func contextWithServer(ctx context.Context, server *Server) context.Context {
server.go#L2044: 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 {