github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 20:24:09 +00:00
Code Issues Projects Releases Wiki Activity

Provide whole delegate chain to kube aggregator

Browse Source
This commit is contained in:
mbohlool 2017-08-31 10:24:40 -07:00
parent 28857a2f02
commit 7cbdb90890
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
staging/src/k8s.io/apiserver/pkg/server/config.go
View File

@ -405,6 +405,7 @@ func (c completedConfig) New(name string, delegationTarget DelegationTarget) (*G
requestContextMapper: c.RequestContextMapper, requestContextMapper: c.RequestContextMapper,
Serializer: c.Serializer, Serializer: c.Serializer,
AuditBackend: c.AuditBackend, AuditBackend: c.AuditBackend,
delegationTarget: delegationTarget,
minRequestTimeout: time.Duration(c.MinRequestTimeout) * time.Second, minRequestTimeout: time.Duration(c.MinRequestTimeout) * time.Second,

13
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
View File

@ -145,6 +145,9 @@ type GenericAPIServer struct {
// enableAPIResponseCompression indicates whether API Responses should support compression // enableAPIResponseCompression indicates whether API Responses should support compression
// if the client requests it via Accept-Encoding // if the client requests it via Accept-Encoding
enableAPIResponseCompression bool enableAPIResponseCompression bool
// delegationTarget is the next delegate in the chain or nil
delegationTarget DelegationTarget
} }
// DelegationTarget is an interface which allows for composition of API servers with top level handling that works // DelegationTarget is an interface which allows for composition of API servers with top level handling that works
@ -165,6 +168,9 @@ type DelegationTarget interface {
// ListedPaths returns the paths for supporting an index // ListedPaths returns the paths for supporting an index
ListedPaths() []string ListedPaths() []string
// NextDelegate returns the next delegationTarget in the chain of delegations
NextDelegate() DelegationTarget
} }
func (s *GenericAPIServer) UnprotectedHandler() http.Handler { func (s *GenericAPIServer) UnprotectedHandler() http.Handler {
@ -181,6 +187,10 @@ func (s *GenericAPIServer) ListedPaths() []string {
return s.listedPathProvider.ListedPaths() return s.listedPathProvider.ListedPaths()
} }
func (s *GenericAPIServer) NextDelegate() DelegationTarget {
return s.delegationTarget
}
var EmptyDelegate = emptyDelegate{ var EmptyDelegate = emptyDelegate{
requestContextMapper: apirequest.NewRequestContextMapper(), requestContextMapper: apirequest.NewRequestContextMapper(),
} }
@ -204,6 +214,9 @@ func (s emptyDelegate) ListedPaths() []string {
func (s emptyDelegate) RequestContextMapper() apirequest.RequestContextMapper { func (s emptyDelegate) RequestContextMapper() apirequest.RequestContextMapper {
return s.requestContextMapper return s.requestContextMapper
} }
func (s emptyDelegate) NextDelegate() DelegationTarget {
return nil
}
// RequestContextMapper is exposed so that third party resource storage can be build in a different location. // RequestContextMapper is exposed so that third party resource storage can be build in a different location.
// TODO refactor third party resource storage // TODO refactor third party resource storage