controller

Documentation

Index

• type HorizontalPodAutoscalerControllerConfig
  • func (c *HorizontalPodAutoscalerControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, error)
• type KubeControllerConfig
  • func (c KubeControllerConfig) GetControllerInitializers() (map[string]kubecontroller.InitFunc, error)
• type PersistentVolumeControllerConfig
  • func (c *PersistentVolumeControllerConfig) RunController(ctx kubecontroller.ControllerContext) (bool, 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 {
	RecyclerImage string

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

	HeapsterNamespace string
}

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

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 PersistentVolumeControllerConfig

type PersistentVolumeControllerConfig struct {
	RecyclerImage string
}

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
	SchedulerServer  *scheduleroptions.SchedulerServer
}

func (*SchedulerControllerConfig) RunController

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