package apiserver

import "k8s.io/kubernetes/cmd/kube-aggregator/pkg/apiserver"

Index ¶

• func WithAPIs(handler http.Handler, informer informers.APIServiceInformer, serviceLister v1listers.ServiceLister, endpointsLister v1listers.EndpointsLister) http.Handler
• func WithProxyMux(handler http.Handler, mux *http.ServeMux) http.Handler
• type APIDiscoveryServer
• func (s *APIDiscoveryServer) AddAPIService(apiService *apiregistration.APIService)
• func (s *APIDiscoveryServer) RemoveAPIService(apiServiceName string)
• type APIHandlerManager
• type APIServiceRegistrationController
• func NewAPIServiceRegistrationController(apiServerInformer informers.APIServiceInformer, apiHandlerManager APIHandlerManager) *APIServiceRegistrationController
• func (c *APIServiceRegistrationController) Run(stopCh <-chan struct{})
• type Config
• func (c *Config) Complete() completedConfig
• func (c *Config) SkipComplete() completedConfig

Functions ¶

func WithAPIs ¶

func WithAPIs(handler http.Handler, informer informers.APIServiceInformer, serviceLister v1listers.ServiceLister, endpointsLister v1listers.EndpointsLister) http.Handler

WithAPIs adds the handling for /apis and /apis/<group: -apiregistration.k8s.io>.

func WithProxyMux ¶

func WithProxyMux(handler http.Handler, mux *http.ServeMux) http.Handler

Types ¶

type APIDiscoveryServer ¶

type APIDiscoveryServer struct {
	GenericAPIServer *genericapiserver.GenericAPIServer
	// contains filtered or unexported fields
}

APIDiscoveryServer contains state for a Kubernetes cluster master/api server.

func (*APIDiscoveryServer) AddAPIService ¶

func (s *APIDiscoveryServer) AddAPIService(apiService *apiregistration.APIService)

AddAPIService adds an API service. It is not thread-safe, so only call it on one thread at a time please. It's a slow moving API, so its ok to run the controller on a single thread

func (*APIDiscoveryServer) RemoveAPIService ¶

func (s *APIDiscoveryServer) RemoveAPIService(apiServiceName string)

RemoveAPIService removes the APIService from being handled. Later on it will disable the proxy endpoint. Right now it does nothing because our handler has to properly 404 itself since muxes don't unregister

type APIHandlerManager ¶

type APIHandlerManager interface {
	AddAPIService(apiServer *apiregistration.APIService)
	RemoveAPIService(apiServerName string)
}

type APIServiceRegistrationController ¶

type APIServiceRegistrationController struct {
	// contains filtered or unexported fields
}

func NewAPIServiceRegistrationController ¶

func NewAPIServiceRegistrationController(apiServerInformer informers.APIServiceInformer, apiHandlerManager APIHandlerManager) *APIServiceRegistrationController

func (*APIServiceRegistrationController) Run ¶

func (c *APIServiceRegistrationController) Run(stopCh <-chan struct{})

type Config ¶

type Config struct {
	GenericConfig       *genericapiserver.Config
	CoreAPIServerClient kubeclientset.Interface

	// ProxyClientCert/Key are the client cert used to identify this proxy. Backing APIServices use
	// this to confirm the proxy's identity
	ProxyClientCert []byte
	ProxyClientKey  []byte

	// RESTOptionsGetter is used to construct storage for a particular resource
	RESTOptionsGetter generic.RESTOptionsGetter
}

func (*Config) Complete ¶

func (c *Config) Complete() completedConfig

Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.

func (*Config) SkipComplete ¶

func (c *Config) SkipComplete() completedConfig

SkipComplete provides a way to construct a server instance without config completion.

Source Files ¶

apiserver.go apiservice_controller.go handler_apis.go handler_proxy.go