controller

Documentation

Index

• type HorizontalPodAutoscalerControllerConfig
  • func (c *HorizontalPodAutoscalerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type KubeControllerConfig
  • func BuildKubeControllerConfig(options configapi.MasterConfig) (*KubeControllerConfig, error)
  • func (c KubeControllerConfig) GetControllerInitializers() (map[string]kubecontroller.InitFunc, error)
• type SchedulerControllerConfig
  • func (c *SchedulerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)

Types

type HorizontalPodAutoscalerControllerConfig

type HorizontalPodAutoscalerControllerConfig struct {
	HeapsterNamespace string
}

func (*HorizontalPodAutoscalerControllerConfig) RunController

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

type KubeControllerConfig

type KubeControllerConfig struct {
	HorizontalPodAutoscalerControllerConfig HorizontalPodAutoscalerControllerConfig

	// TODO the scheduler should move out into its own logical component
	SchedulerControllerConfig SchedulerControllerConfig
}

KubeControllerConfig is the runtime (non-serializable) config object used to launch the set of kube (not openshift) controllers.

func BuildKubeControllerConfig

func BuildKubeControllerConfig(options configapi.MasterConfig) (*KubeControllerConfig, error)

BuildKubeControllerConfig builds the struct to create the controller initializers. Eventually we want this to be fully stock kube with no modification.

func (KubeControllerConfig) GetControllerInitializers

func (c KubeControllerConfig) GetControllerInitializers() (map[string]kubecontroller.InitFunc, error)

GetControllerInitializers return the controller initializer functions for kube controllers TODO in 3.7, CloudProvider is on the context

type SchedulerControllerConfig

type SchedulerControllerConfig struct {
	// TODO: Move this closer to upstream, we want unprivileged client here.
	PrivilegedClient kclientset.Interface
	SchedulerServer  *scheduleroptions.SchedulerServer
}

func (*SchedulerControllerConfig) RunController

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