Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( Scheme = runtime.NewScheme() Codecs = serializer.NewCodecFactory(Scheme) )
Functions ¶
This section is empty.
Types ¶
type APIAggregator ¶
type APIAggregator struct { GenericAPIServer *genericapiserver.GenericAPIServer // provided for easier embedding APIRegistrationInformers informers.SharedInformerFactory // contains filtered or unexported fields }
APIAggregator contains state for a Kubernetes cluster master/api server.
func (*APIAggregator) AddAPIService ¶
func (s *APIAggregator) AddAPIService(apiService *apiregistration.APIService) error
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 (*APIAggregator) RemoveAPIService ¶
func (s *APIAggregator) RemoveAPIService(apiServiceName string)
RemoveAPIService removes the APIService from being handled. 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.
type APIHandlerManager ¶
type APIHandlerManager interface { AddAPIService(apiService *apiregistration.APIService) error RemoveAPIService(apiServiceName string) }
type APIServiceRegistrationController ¶
type APIServiceRegistrationController struct {
// contains filtered or unexported fields
}
func NewAPIServiceRegistrationController ¶
func NewAPIServiceRegistrationController(apiServiceInformer informers.APIServiceInformer, serviceInformer v1informers.ServiceInformer, apiHandlerManager APIHandlerManager) *APIServiceRegistrationController
func (*APIServiceRegistrationController) Run ¶
func (c *APIServiceRegistrationController) Run(stopCh <-chan struct{})
type CompletedConfig ¶ added in v1.8.0
type CompletedConfig struct {
// contains filtered or unexported fields
}
func (CompletedConfig) NewWithDelegate ¶ added in v1.8.0
func (c CompletedConfig) NewWithDelegate(delegationTarget genericapiserver.DelegationTarget) (*APIAggregator, error)
New returns a new instance of APIAggregator from the given config.
type Config ¶
type Config struct { GenericConfig *genericapiserver.RecommendedConfig ExtraConfig ExtraConfig }
func (*Config) Complete ¶
func (cfg *Config) Complete() CompletedConfig
Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.
type ExtraConfig ¶ added in v1.8.0
type ExtraConfig struct { // 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 // If present, the Dial method will be used for dialing out to delegate // apiservers. ProxyTransport *http.Transport // Mechanism by which the Aggregator will resolve services. Required. ServiceResolver ServiceResolver }
type ServiceResolver ¶ added in v1.7.0
A ServiceResolver knows how to get a URL given a service.
func NewClusterIPServiceResolver ¶ added in v1.7.0
func NewClusterIPServiceResolver(services listersv1.ServiceLister) ServiceResolver
NewEndpointServiceResolver returns a ServiceResolver that directly calls the service's cluster IP.
func NewEndpointServiceResolver ¶ added in v1.7.0
func NewEndpointServiceResolver(services listersv1.ServiceLister, endpoints listersv1.EndpointsLister) ServiceResolver
NewEndpointServiceResolver returns a ServiceResolver that chooses one of the service's endpoints.
func NewLoopbackServiceResolver ¶ added in v1.10.6
func NewLoopbackServiceResolver(delegate ServiceResolver, host *url.URL) ServiceResolver
NewLoopbackServiceResolver returns a ServiceResolver that routes the kubernetes/default service to loopback.