controllers

Documentation

Index

• func ControllerRigist(resourceObj interface{}, deepCopyF func(interface{}) meta_v1.Object, ...)
• type ControllerInterface
  • func NewControllerFactory(resourceObj interface{}, shareInformerFactory interface{}, ...) (ControllerInterface, cache.Controller)
• type PodController
  • func (c *PodController) SyncLoop(key string) error
• type RayController
  • func (c *RayController) SyncLoop(key string) error

Functions

func ControllerRigist

func ControllerRigist(resourceObj interface{},
	deepCopyF func(interface{}) meta_v1.Object,
	f newController)

Types

type ControllerInterface

type ControllerInterface interface {
	SyncLoop(key string) error
}

func NewControllerFactory

func NewControllerFactory(
	resourceObj interface{},
	shareInformerFactory interface{},
	addFunc, delFunc func(i interface{}) func() error,
	updateFunc func(old, new interface{}) func() error,
	rayclient rayclientset.Interface,
	kubeClient clientset.Interface) (ControllerInterface, cache.Controller)

type PodController

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

func (*PodController) SyncLoop

func (c *PodController) SyncLoop(key string) error

type RayController

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

func (*RayController) SyncLoop

func (c *RayController) SyncLoop(key string) error