const DefaultHostAcceptRE … const DefaultPathAcceptRE … const DefaultPathRejectRE … const DefaultMethodRejectRE … type FilterServer … // MakeRegexpArray splits a comma separated list of regexps into an array of Regexp objects. func MakeRegexpArray(str string) ([]*regexp.Regexp, error) { … } // MakeRegexpArrayOrDie creates an array of regular expression objects from a string or exits. func MakeRegexpArrayOrDie(str string) []*regexp.Regexp { … } func matchesRegexp(str string, regexps []*regexp.Regexp) bool { … } func (f *FilterServer) accept(method, path, host string) bool { … } // HandlerFor makes a shallow copy of f which passes its requests along to the // new delegate. func (f *FilterServer) HandlerFor(delegate http.Handler) *FilterServer { … } // Get host from a host header value like "localhost" or "localhost:8080" func extractHost(header string) (host string) { … } func (f *FilterServer) ServeHTTP(rw http.ResponseWriter, req *http.Request) { … } type Server … type responder … func (r *responder) Error(w http.ResponseWriter, req *http.Request, err error) { … } // makeUpgradeTransport creates a transport that explicitly bypasses HTTP2 support // for proxy connections that must upgrade. func makeUpgradeTransport(config *rest.Config, keepalive time.Duration) (proxy.UpgradeRequestRoundTripper, error) { … } // NewServer creates and installs a new Server. // 'filter', if non-nil, protects requests to the api only. func NewServer(filebase string, apiProxyPrefix string, staticPrefix string, filter *FilterServer, cfg *rest.Config, keepalive time.Duration, appendLocationPath bool) (*Server, error) { … } // NewProxyHandler creates an api proxy handler for the cluster func NewProxyHandler(apiProxyPrefix string, filter *FilterServer, cfg *rest.Config, keepalive time.Duration, appendLocationPath bool) (http.Handler, error) { … } // Listen is a simple wrapper around net.Listen. func (s *Server) Listen(address string, port int) (net.Listener, error) { … } // ListenUnix does net.Listen for a unix socket func (s *Server) ListenUnix(path string) (net.Listener, error) { … } // ServeOnListener starts the server using given listener, loops forever. func (s *Server) ServeOnListener(l net.Listener) error { … } func newFileHandler(prefix, base string) http.Handler { … } // like http.StripPrefix, but always leaves an initial slash. (so that our // regexps will work.) func stripLeaveSlash(prefix string, h http.Handler) http.Handler { … }
Codebase Browser
kubernetes