apiserver

Documentation

Index

• Constants
• Variables
• type APIAggregator
  • func (s *APIAggregator) AddAPIService(apiService *apiregistration.APIService)
  • func (s *APIAggregator) RemoveAPIService(apiServiceName string)
• type APIHandlerManager
• type APIServiceRegistrationController
  • func NewAPIServiceRegistrationController(apiServiceInformer informers.APIServiceInformer, ...) *APIServiceRegistrationController
  • func (c *APIServiceRegistrationController) Run(stopCh <-chan struct{})
• type Config
  • func (c *Config) Complete() completedConfig
  • func (c *Config) SkipComplete() completedConfig
• type ServiceResolver

Constants

const (
	LOAD_OPENAPI_SPEC_MAX_RETRIES = 10
)

Variables

var (
	Scheme = runtime.NewScheme()
	Codecs = serializer.NewCodecFactory(Scheme)
)

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)

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)
	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 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
	ProxyTransport  *http.Transport

	// Indicates if the Aggregator should send to the cluster IP (false) or route to the endpoints IP (true)
	EnableAggregatorRouting bool
}

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.

type ServiceResolver

type ServiceResolver interface {
	ResolveEndpoint(namespace, name string) (*url.URL, error)
}