profiles

Documentation

Index

• type Controller
  • func NewController(profileInformer kubeflowv1informers.ProfileInformer, sync profileSyncCallback) *Controller
  • func (c *Controller) EnqueueProfile(obj interface{})
  • func (c *Controller) HandleObject(obj interface{})
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Types

type Controller

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

Controller for handling Kubeflow Profiles

func NewController

func NewController(
	profileInformer kubeflowv1informers.ProfileInformer,
	sync profileSyncCallback,
) *Controller

NewController for Profiles creation

func (*Controller) EnqueueProfile

func (c *Controller) EnqueueProfile(obj interface{})

EnqueueProfile takes a Profile resource and converts it into a namespace/name string which is then put onto the work queue. This method should *not* be passed resources of any type other than Profile.

func (*Controller) HandleObject

func (c *Controller) HandleObject(obj interface{})

HandleObject will take any resource implementing metav1.Object and attempt to find the Profile resource that 'owns' it. It does this by looking at the objects metadata.ownerReferences field for an appropriate OwnerReference. It then enqueues that Profile resource to be processed. If the object does not have an appropriate OwnerReference, it will simply be skipped.

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.