controller

Documentation

Index

• type APIServiceController
  • func NewAPIServiceController(cluster string, config *rest.Config, ...) (*APIServiceController, error)
  • func (c *APIServiceController) HasSynced() bool
  • func (c *APIServiceController) Start(stopCh <-chan struct{}) <-chan struct{}
• type CRDController
  • func NewCRDController(cluster string, config *rest.Config, version string, ...) (*CRDController, error)
  • func (c *CRDController) HasSynced() bool
  • func (c *CRDController) SetVersion(version string) error
  • func (c *CRDController) Start(stopCh <-chan struct{}) <-chan struct{}
• type CRDEventHandlerFuncs
  • func (handler CRDEventHandlerFuncs) OnAdd(obj interface{}, isInInitialList bool)
  • func (handler CRDEventHandlerFuncs) OnDelete(obj interface{})
  • func (handler CRDEventHandlerFuncs) OnUpdate(older, newer interface{})

Types

type APIServiceController

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

func NewAPIServiceController

func NewAPIServiceController(cluster string, config *rest.Config, reconciler func(apiservices []*v1.APIService)) (*APIServiceController, error)

func (*APIServiceController) HasSynced

func (c *APIServiceController) HasSynced() bool

func (*APIServiceController) Start

func (c *APIServiceController) Start(stopCh <-chan struct{}) <-chan struct{}

type CRDController

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

func NewCRDController

func NewCRDController(cluster string, config *rest.Config, version string, handler CRDEventHandlerFuncs) (*CRDController, error)

func (*CRDController) HasSynced

func (c *CRDController) HasSynced() bool

func (*CRDController) SetVersion

func (c *CRDController) SetVersion(version string) error

func (*CRDController) Start

func (c *CRDController) Start(stopCh <-chan struct{}) <-chan struct{}

type CRDEventHandlerFuncs

type CRDEventHandlerFuncs struct {
	Name string

	AddFunc func(obj *v1.CustomResourceDefinition)

	UpdateFunc          func(older *v1.CustomResourceDefinition, newer *v1.CustomResourceDefinition)
	UpdateFuncOnlyNewer func(newer *v1.CustomResourceDefinition)

	// cache.DeletedFinalStateUnknown will be ignored
	DeleteFunc func(obj *v1.CustomResourceDefinition)
}

func (CRDEventHandlerFuncs) OnAdd

func (handler CRDEventHandlerFuncs) OnAdd(obj interface{}, isInInitialList bool)

func (CRDEventHandlerFuncs) OnDelete

func (handler CRDEventHandlerFuncs) OnDelete(obj interface{})

func (CRDEventHandlerFuncs) OnUpdate

func (handler CRDEventHandlerFuncs) OnUpdate(older, newer interface{})