master

Documentation

Index

• Variables
• func BuildKubeAPIserverOptions(masterConfig configapi.MasterConfig) (*kapiserveroptions.ServerRunOptions, error)
• func BuildStorageFactory(masterConfig configapi.MasterConfig, ...) (*apiserverstorage.DefaultStorageFactory, error)
• func DefaultOpenAPIConfig() *openapicommon.Config
• type MasterConfig
  • func BuildKubernetesMasterConfig(masterConfig configapi.MasterConfig, ...) (*MasterConfig, error)
  • func (c *MasterConfig) RunCertificateSigningController(clientset kclientset.Interface)
  • func (c *MasterConfig) RunCronJobController(client kclientset.Interface)
  • func (c *MasterConfig) RunDaemonSetsController(client kclientset.Interface)
  • func (c *MasterConfig) RunDeploymentController(client kclientset.Interface)
  • func (c *MasterConfig) RunDisruptionBudgetController(client kclientset.Interface)
  • func (c *MasterConfig) RunEndpointController(client kclientset.Interface)
  • func (c *MasterConfig) RunGCController(client kclientset.Interface)
  • func (c *MasterConfig) RunGarbageCollectorController(client *osclient.Client, config *restclient.Config)
  • func (c *MasterConfig) RunHPAController(oc *osclient.Client, kc kclientset.Interface, heapsterNamespace string)
  • func (c *MasterConfig) RunJobController(client kclientset.Interface)
  • func (c *MasterConfig) RunNamespaceController(kubeClient kclientset.Interface, clientPool dynamic.ClientPool, ...)
  • func (c *MasterConfig) RunNodeController()
  • func (c *MasterConfig) RunPersistentVolumeAttachDetachController(client kclientset.Interface)
  • func (c *MasterConfig) RunPersistentVolumeController(client kclientset.Interface, ...)
  • func (c *MasterConfig) RunReplicaSetController(client kclientset.Interface)
  • func (c *MasterConfig) RunReplicationController(client kclientset.Interface)
  • func (c *MasterConfig) RunScheduler()
  • func (c *MasterConfig) RunServiceLoadBalancerController(client kclientset.Interface)
  • func (c *MasterConfig) RunStatefulSetController(client kclientset.Interface)

Variables

var LegacyAPIGroupPrefixes = sets.NewString(apiserver.DefaultLegacyAPIPrefix, api.Prefix, api.LegacyPrefix)

Functions

func BuildKubeAPIserverOptions

func BuildKubeAPIserverOptions(masterConfig configapi.MasterConfig) (*kapiserveroptions.ServerRunOptions, error)

BuildKubeAPIserverOptions constructs the appropriate kube-apiserver run options. It returns an error if no KubernetesMasterConfig was defined.

func BuildStorageFactory

func BuildStorageFactory(masterConfig configapi.MasterConfig, server *kapiserveroptions.ServerRunOptions, enforcedStorageVersions []schema.GroupVersionResource) (*apiserverstorage.DefaultStorageFactory, error)

BuildStorageFactory builds a storage factory based on server.Etcd.StorageConfig with overrides from masterConfig. This storage factory is used for kubernetes and origin registries. Compare pkg/util/restoptions/configgetter.go.

func DefaultOpenAPIConfig

func DefaultOpenAPIConfig() *openapicommon.Config

Types

type MasterConfig

type MasterConfig struct {
	Options            configapi.KubernetesMasterConfig
	InternalKubeClient kinternalclientset.Interface
	KubeClient         kclientset.Interface

	Master            *master.Config
	ControllerManager *cmapp.CMServer
	SchedulerServer   *scheduleroptions.SchedulerServer
	CloudProvider     cloudprovider.Interface

	Informers shared.InformerFactory
}

MasterConfig defines the required values to start a Kubernetes master

func BuildKubernetesMasterConfig

func BuildKubernetesMasterConfig(
	masterConfig configapi.MasterConfig,
	requestContextMapper apirequest.RequestContextMapper,
	kubeClient kclientset.Interface,
	internalKubeClient kinternalclientset.Interface,
	informers shared.InformerFactory,
	admissionControl admission.Interface,
	originAuthenticator authenticator.Request,
	kubeAuthorizer authorizer.Authorizer,
) (*MasterConfig, error)

TODO this function's parameters need to be refactored

func (*MasterConfig) RunCertificateSigningController

func (c *MasterConfig) RunCertificateSigningController(clientset kclientset.Interface)

func (*MasterConfig) RunCronJobController

func (c *MasterConfig) RunCronJobController(client kclientset.Interface)

RunCronJobController starts the Kubernetes scheduled job controller sync loop

func (*MasterConfig) RunDaemonSetsController

func (c *MasterConfig) RunDaemonSetsController(client kclientset.Interface)

func (*MasterConfig) RunDeploymentController

func (c *MasterConfig) RunDeploymentController(client kclientset.Interface)

func (*MasterConfig) RunDisruptionBudgetController

func (c *MasterConfig) RunDisruptionBudgetController(client kclientset.Interface)

RunDisruptionBudgetController starts the Kubernetes disruption budget controller

func (*MasterConfig) RunEndpointController

func (c *MasterConfig) RunEndpointController(client kclientset.Interface)

RunEndpointController starts the Kubernetes replication controller sync loop

func (*MasterConfig) RunGCController

func (c *MasterConfig) RunGCController(client kclientset.Interface)

RunGCController handles deletion of terminated pods.

func (*MasterConfig) RunGarbageCollectorController

func (c *MasterConfig) RunGarbageCollectorController(client *osclient.Client, config *restclient.Config)

RunGarbageCollectorController starts generic garbage collection for the cluster.

func (*MasterConfig) RunHPAController

func (c *MasterConfig) RunHPAController(oc *osclient.Client, kc kclientset.Interface, heapsterNamespace string)

RunHPAController starts the Kubernetes hpa controller sync loop

func (*MasterConfig) RunJobController

func (c *MasterConfig) RunJobController(client kclientset.Interface)

RunJobController starts the Kubernetes job controller sync loop

func (*MasterConfig) RunNamespaceController

func (c *MasterConfig) RunNamespaceController(kubeClient kclientset.Interface, clientPool dynamic.ClientPool, namespaceInformer coreinformers.NamespaceInformer)

RunNamespaceController starts the Kubernetes Namespace Manager

func (*MasterConfig) RunNodeController

func (c *MasterConfig) RunNodeController()

RunNodeController starts the node controller TODO: handle node CIDR and route allocation

func (*MasterConfig) RunPersistentVolumeAttachDetachController

func (c *MasterConfig) RunPersistentVolumeAttachDetachController(client kclientset.Interface)

func (*MasterConfig) RunPersistentVolumeController

func (c *MasterConfig) RunPersistentVolumeController(client kclientset.Interface, namespace, recyclerImageName, recyclerServiceAccountName string)

func (*MasterConfig) RunReplicaSetController

func (c *MasterConfig) RunReplicaSetController(client kclientset.Interface)

func (*MasterConfig) RunReplicationController

func (c *MasterConfig) RunReplicationController(client kclientset.Interface)

RunReplicationController starts the Kubernetes replication controller sync loop

func (*MasterConfig) RunScheduler

func (c *MasterConfig) RunScheduler()

RunScheduler starts the Kubernetes scheduler

func (*MasterConfig) RunServiceLoadBalancerController

func (c *MasterConfig) RunServiceLoadBalancerController(client kclientset.Interface)

RunServiceLoadBalancerController starts the service loadbalancer controller if the cloud provider is configured.

func (*MasterConfig) RunStatefulSetController

func (c *MasterConfig) RunStatefulSetController(client kclientset.Interface)

RunStatefulSetController starts the StatefulSet controller