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{})

Package Files ¶

establishing_controller.go

type EstablishingController ¶ Uses

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

EstablishingController controls how and when CRD is established.

func NewEstablishingController ¶ Uses

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

NewEstablishingController creates new EstablishingController.

func (*EstablishingController) QueueCRD ¶ Uses

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

QueueCRD adds CRD into the establishing queue.

func (*EstablishingController) Run ¶ Uses

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

Run starts the EstablishingController.