operator

Documentation

Index

• func RunOperator(clientConfig *rest.Config, stopCh <-chan struct{}) error
• type KubeSchedulerOperator
  • func NewKubeSchedulerOperator(...) *KubeSchedulerOperator
  • func (c *KubeSchedulerOperator) Run(workers int, stopCh <-chan struct{})

Functions

func RunOperator

func RunOperator(clientConfig *rest.Config, stopCh <-chan struct{}) error

Types

type KubeSchedulerOperator

type KubeSchedulerOperator struct {
	// contains filtered or unexported fields
}

func NewKubeSchedulerOperator

func NewKubeSchedulerOperator(
	operatorConfigInformer operatorconfiginformerv1alpha1.KubeSchedulerOperatorConfigInformer,
	namespacedKubeInformers informers.SharedInformerFactory,
	operatorConfigClient operatorconfigclientv1alpha1.KubeschedulerV1alpha1Interface,
	appsv1Client appsclientv1.AppsV1Interface,
	corev1Client coreclientv1.CoreV1Interface,
	rbacv1Client rbacclientv1.RbacV1Interface,
) *KubeSchedulerOperator

func (*KubeSchedulerOperator) Run

func (c *KubeSchedulerOperator) Run(workers int, stopCh <-chan struct{})

Run starts the kube-scheduler and blocks until stopCh is closed.