controller

Documentation

Index

• type NagController
• type NodeController
• type PodController
• type ResourceWatcher
  • func NewResourceWatcher(kubeClientet kubernetes.Interface, valetClient valet.Interface, ...) *ResourceWatcher
  • func (rw *ResourceWatcher) ParController() *podassignment.Controller
  • func (rw *ResourceWatcher) Run(stopChan chan struct{})
  • func (rw *ResourceWatcher) StartElectedComponents(ctx context.Context)
  • func (rw *ResourceWatcher) StopElectedComponents()

Types

type NagController

type NagController interface {
	OnAddNag(nag *assignmentsv1alpha1.NodeAssignmentGroup)
	OnUpdateNag(oldNag *assignmentsv1alpha1.NodeAssignmentGroup, newNag *assignmentsv1alpha1.NodeAssignmentGroup)
	OnDeleteNag(nag *assignmentsv1alpha1.NodeAssignmentGroup)
}

NagController a controller that processes nag events

type NodeController

type NodeController interface {
	OnAddNode(node *corev1.Node)
	OnUpdateNode(oldNode *corev1.Node, newNode *corev1.Node)
	OnDeleteNode(node *corev1.Node)
}

NodeController a controller that processes node events

type PodController

type PodController interface {
	OnAddPod(pod *corev1.Pod)
	OnUpdatePod(oldPod *corev1.Pod, newPod *corev1.Pod)
	OnDeletePod(pod *corev1.Pod)
}

PodController a controller that processes pod events

type ResourceWatcher

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

ResourceWatcher abstracts and shares indexers and informers. Passes events onto the controllers that handle the business logic for each event.

func NewResourceWatcher

func NewResourceWatcher(kubeClientet kubernetes.Interface, valetClient valet.Interface, config *config.ValetConfig) *ResourceWatcher

NewResourceWatcher creates a new ResourceWatcher

func (*ResourceWatcher) ParController

func (rw *ResourceWatcher) ParController() *podassignment.Controller

func (*ResourceWatcher) Run

func (rw *ResourceWatcher) Run(stopChan chan struct{})

Run starts the indexers, informers, and controllers.

func (*ResourceWatcher) StartElectedComponents

func (rw *ResourceWatcher) StartElectedComponents(ctx context.Context)

func (*ResourceWatcher) StopElectedComponents

func (rw *ResourceWatcher) StopElectedComponents()