master

Documentation

Index

• Constants
• 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)
• type NodeControllerConfig
  • func (c *NodeControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type PersistentVolumeAttachDetachControllerConfig
  • func (c *PersistentVolumeAttachDetachControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type PersistentVolumeControllerConfig
  • func (c *PersistentVolumeControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type SchedulerControllerConfig
  • func (c *SchedulerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type ServiceLoadBalancerControllerConfig
  • func (c *ServiceLoadBalancerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

Constants

const DefaultWatchCacheSize = 1000

Variables

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

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 map[schema.GroupResource]schema.GroupVersion) (*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

	ExternalInformers kexternalinformers.SharedInformerFactory
}

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,
	externalKubeInformers kexternalinformers.SharedInformerFactory,
	admissionControl admission.Interface,
	originAuthenticator authenticator.Request,
	kubeAuthorizer authorizer.Authorizer,
) (*MasterConfig, error)

TODO this function's parameters need to be refactored

type NodeControllerConfig

type NodeControllerConfig struct {
	CloudProvider cloudprovider.Interface
}

func (*NodeControllerConfig) RunController

func (c *NodeControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

type PersistentVolumeAttachDetachControllerConfig

type PersistentVolumeAttachDetachControllerConfig struct {
	CloudProvider cloudprovider.Interface
}

func (*PersistentVolumeAttachDetachControllerConfig) RunController

func (c *PersistentVolumeAttachDetachControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

type PersistentVolumeControllerConfig

type PersistentVolumeControllerConfig struct {
	RecyclerImage string
	CloudProvider cloudprovider.Interface
}

func (*PersistentVolumeControllerConfig) RunController

func (c *PersistentVolumeControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

type SchedulerControllerConfig

type SchedulerControllerConfig struct {
	// TODO: Move this closer to upstream, we want unprivileged client here.
	PrivilegedClient               kclientset.Interface
	SchedulerName                  string
	HardPodAffinitySymmetricWeight int
	SchedulerPolicy                *schedulerapi.Policy
}

func (*SchedulerControllerConfig) RunController

func (c *SchedulerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

type ServiceLoadBalancerControllerConfig

type ServiceLoadBalancerControllerConfig struct {
	CloudProvider cloudprovider.Interface
}

func (*ServiceLoadBalancerControllerConfig) RunController

func (c *ServiceLoadBalancerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)