workernodeeviction

Documentation

Index

• Constants
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, carbonclientset clientset.Interface, ...) *Controller
  • func (c *Controller) DeleteSubObj(namespace, key string) error
  • func (c *Controller) GetObj(namespace, key string) (interface{}, error)
  • func (c *Controller) Sync(key string) error
  • func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool

Constants

const (

	// SuccessSynced is used as part of the Event 'reason' when a ControllersManager is synced
	SuccessSynced = "Synced"
)

Types

type Controller

type Controller struct {
	schema.GroupVersionKind
	controller.DefaultController
	// contains filtered or unexported fields
}

Controller is the controller implementation for ControllersManager resources

func NewController

func NewController(
	kubeclientset kubernetes.Interface,
	carbonclientset clientset.Interface,
	podInformer coreinformers.PodInformer,
	workerNodeInformer informers.WorkerNodeInformer,
	evictionInformer informers.WorkerNodeEvictionInformer,
) *Controller

NewController returns a new ControllersManager controller

func (*Controller) DeleteSubObj

func (c *Controller) DeleteSubObj(namespace, key string) error

DeleteSubObj DeleteSubObj

func (*Controller) GetObj

func (c *Controller) GetObj(namespace, key string) (interface{}, error)

GetObj GetObj

func (*Controller) Sync

func (c *Controller) Sync(key string) error

Sync sync

func (*Controller) WaitForCacheSync

func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool

WaitForCacheSync WaitForCacheSync