1234567891011121314151617181920212223242526272829303132333435363738394041 |
- /*
- Copyright 2016 The Kubernetes Authors.
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
- package server
- import (
- "net/http"
- genericapifilters "k8s.io/apiserver/pkg/endpoints/filters"
- "k8s.io/apiserver/pkg/server"
- genericfilters "k8s.io/apiserver/pkg/server/filters"
- )
- // BuildInsecureHandlerChain sets up the server to listen to http. Should be removed.
- func BuildInsecureHandlerChain(apiHandler http.Handler, c *server.Config) http.Handler {
- handler := apiHandler
- handler = genericapifilters.WithAudit(handler, c.AuditBackend, c.AuditPolicyChecker, c.LongRunningFunc)
- handler = genericapifilters.WithAuthentication(handler, server.InsecureSuperuser{}, nil, nil)
- handler = genericfilters.WithCORS(handler, c.CorsAllowedOriginList, nil, nil, nil, "true")
- handler = genericfilters.WithTimeoutForNonLongRunningRequests(handler, c.LongRunningFunc, c.RequestTimeout)
- handler = genericfilters.WithMaxInFlightLimit(handler, c.MaxRequestsInFlight, c.MaxMutatingRequestsInFlight, c.LongRunningFunc)
- handler = genericfilters.WithWaitGroup(handler, c.LongRunningFunc, c.HandlerChainWaitGroup)
- handler = genericapifilters.WithRequestInfo(handler, server.NewRequestInfoResolver(c))
- handler = genericfilters.WithPanicRecovery(handler)
- return handler
- }
|