Method serve

pkg/controller/rtctrl/dispatcherv2.go:71–91

(address string, router *mux.Router)

}

func (s *DispatchServerV2) serve(address string, router *mux.Router) *http.Server {
	ln, err := ListenerFromAddress(address, os.ModePerm)
	if err != nil {
		logs.Fatalf("listen %s error: %s", address, err.Error())
		panic(err)
	}

	serverMux := http.NewServeMux()
	serverMux.Handle("/", router)
	server := &http.Server{
		Handler: serverMux,
	}

	go func() {
		err := server.Serve(ln)
		if err != nil {
			logs.Fatalf("serve %s error: %s", address, err.Error())
		}
	}()
	return server
}

func setupHijackConn(w http.ResponseWriter, r *http.Request) (net.Conn, *bufio.ReadWriter, bool) {
	runtimeid := r.Header.Get("x-cfc-runtimeid")