podassignment

Documentation

Index

• Constants
• type Controller
  • func NewController(podIndex cache.Indexer, cparIndex cache.Indexer, parIndex cache.Indexer, ...) *Controller
  • func (c *Controller) OnAddPod(pod *corev1.Pod)
  • func (c *Controller) OnDeletePod(pod *corev1.Pod)
  • func (c *Controller) OnUpdatePod(oldPod *corev1.Pod, newPod *corev1.Pod)
  • func (c *Controller) PodManager() *Manager
• type Manager
  • func NewManager(podIndex cache.Indexer, cparIndex cache.Indexer, parIndex cache.Indexer, ...) *Manager
  • func (m *Manager) GetPodAssignmentsScheduling(pod *corev1.Pod) []*assignmentsv1alpha1.PodAssignmentRuleScheduling
  • func (m *Manager) GetPodSchedulingPatches(pod *corev1.Pod) []utils.JsonPatchOperation
  • func (m *Manager) PodIsProtected(pod *corev1.Pod) bool

Constants

const (
	// ProtectedLabelKey the protected label key
	ProtectedLabelKey = "pod.initializer.kube-valet.io/protected"
	// ProtectedLabelValue true
	ProtectedLabelValue = "true"
)

Types

type Controller

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

Controller processes pod events and assigns based on pars and cpars

func NewController

func NewController(podIndex cache.Indexer, cparIndex cache.Indexer, parIndex cache.Indexer, kubeClient kubernetes.Interface, valetClient valet.Interface, threadiness int, stopChannel chan struct{}) *Controller

NewController creates a new Controller

func (*Controller) OnAddPod

func (c *Controller) OnAddPod(pod *corev1.Pod)

OnAddPod processes the pod

func (*Controller) OnDeletePod

func (c *Controller) OnDeletePod(pod *corev1.Pod)

OnDeletePod if the pod was deleted

func (*Controller) OnUpdatePod

func (c *Controller) OnUpdatePod(oldPod *corev1.Pod, newPod *corev1.Pod)

OnUpdatePod if the pod has been updated

func (*Controller) PodManager

func (c *Controller) PodManager() *Manager

type Manager

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

func NewManager

func NewManager(podIndex cache.Indexer, cparIndex cache.Indexer, parIndex cache.Indexer, kubeClient kubernetes.Interface) *Manager

func (*Manager) GetPodAssignmentsScheduling

func (m *Manager) GetPodAssignmentsScheduling(pod *corev1.Pod) []*assignmentsv1alpha1.PodAssignmentRuleScheduling

TODO make this ordered!

func (*Manager) GetPodSchedulingPatches

func (m *Manager) GetPodSchedulingPatches(pod *corev1.Pod) []utils.JsonPatchOperation

func (*Manager) PodIsProtected

func (m *Manager) PodIsProtected(pod *corev1.Pod) bool