reconciler

Documentation

Index

• type DispatchedPodsPopulator
  • func NewDispatchedPodsPopulator(schedulerName string, podLister v1.PodLister, queue workqueue.Interface, ...) *DispatchedPodsPopulator
  • func (dpp *DispatchedPodsPopulator) Run(stopCh <-chan struct{})
• type PodStateReconciler
  • func NewPodStateReconciler(client kubernetes.Interface, podLister listerv1.PodLister, ...) *PodStateReconciler
  • func (psr *PodStateReconciler) AbnormalPodsEnqueue(obj interface{})
  • func (psr *PodStateReconciler) AbnormalStatePodsSyncer()
  • func (psr *PodStateReconciler) DeleteScheduler(scheduler *schedulerapi.Scheduler)
  • func (psr *PodStateReconciler) Run(stop <-chan struct{})
  • func (psr *PodStateReconciler) StaleDispatchedPodsEnqueue(obj interface{})
  • func (psr *PodStateReconciler) StaleDispatchedPodsSyncer()

Types

type DispatchedPodsPopulator

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

DispatchedPodsPopulator is the populator struct for collecting dispatched pods who are in inactive schedulers

func NewDispatchedPodsPopulator

func NewDispatchedPodsPopulator(schedulerName string, podLister v1.PodLister, queue workqueue.Interface,
	maintainer *schemaintainer.SchedulerMaintainer,
) *DispatchedPodsPopulator

NewDispatchedPodsPopulator creates a new DispatchedPodsPopulator struct

func (*DispatchedPodsPopulator) Run

func (dpp *DispatchedPodsPopulator) Run(stopCh <-chan struct{})

Run starts the collection work

type PodStateReconciler

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

PodStateReconciler stores all abnormal state pods and try to reset pod state

func NewPodStateReconciler

func NewPodStateReconciler(client kubernetes.Interface,
	podLister listerv1.PodLister,
	nodeLister listerv1.NodeLister,
	schedulerLister schedulerv1alpha1.SchedulerLister,
	nmNodeLister nodelisterv1alpha1.NMNodeLister,
	schedulerName string,
	dispatchedPodsStore store.DispatchInfo,
	maintainer *schemaintainer.SchedulerMaintainer,
) *PodStateReconciler

NewPodStateReconciler creates a new PodStateReconciler struct

func (*PodStateReconciler) AbnormalPodsEnqueue

func (psr *PodStateReconciler) AbnormalPodsEnqueue(obj interface{})

AbnormalPodsEnqueue adds obj to abnormal queue

func (*PodStateReconciler) AbnormalStatePodsSyncer

func (psr *PodStateReconciler) AbnormalStatePodsSyncer()

AbnormalStatePodsSyncer tries reset abnormal state pods

func (*PodStateReconciler) DeleteScheduler

func (psr *PodStateReconciler) DeleteScheduler(scheduler *schedulerapi.Scheduler)

func (*PodStateReconciler) Run

func (psr *PodStateReconciler) Run(stop <-chan struct{})

Run runs pod state syncer worker

func (*PodStateReconciler) StaleDispatchedPodsEnqueue

func (psr *PodStateReconciler) StaleDispatchedPodsEnqueue(obj interface{})

StaleDispatchedPodsEnqueue adds obj to stale dispatched queue

func (*PodStateReconciler) StaleDispatchedPodsSyncer

func (psr *PodStateReconciler) StaleDispatchedPodsSyncer()