package establish

import "k8s.io/apiextensions-apiserver/pkg/controller/establish"

Index ¶

• type EstablishingController
• func NewEstablishingController(crdInformer informers.CustomResourceDefinitionInformer, crdClient client.CustomResourceDefinitionsGetter) *EstablishingController
• func (ec *EstablishingController) QueueCRD(key string, timeout time.Duration)
• func (ec *EstablishingController) Run(stopCh <-chan struct{})

Types ¶

type EstablishingController ¶

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

EstablishingController controls how and when CRD is established.

func NewEstablishingController ¶

func NewEstablishingController(crdInformer informers.CustomResourceDefinitionInformer,
	crdClient client.CustomResourceDefinitionsGetter) *EstablishingController

NewEstablishingController creates new EstablishingController.

func (*EstablishingController) QueueCRD ¶

func (ec *EstablishingController) QueueCRD(key string, timeout time.Duration)

QueueCRD adds CRD into the establishing queue.

func (*EstablishingController) Run ¶

func (ec *EstablishingController) Run(stopCh <-chan struct{})

Run starts the EstablishingController.

Source Files ¶

establishing_controller.go