core

Documentation

Index

• func CheckClusterResource(nodeList []*framework.NodeInfo, resourceRequest corev1.ResourceList, ...) error
• func GetNamespacedName(obj metav1.Object) string
• type Manager
• type PodGroupManager
  • func NewPodGroupManager(pgClient pgclientset.Interface, snapshotSharedLister framework.SharedLister, ...) *PodGroupManager
  • func (pgMgr *PodGroupManager) AddDeniedPodGroup(pgFullName string)
  • func (pgMgr *PodGroupManager) CalculateAssignedPods(podGroupName, namespace string) int
  • func (pgMgr *PodGroupManager) DeletePermittedPodGroup(pgFullName string)
  • func (pgMgr *PodGroupManager) GetCreationTimestamp(pod *corev1.Pod, ts time.Time) time.Time
  • func (pgMgr *PodGroupManager) GetPodGroup(pod *corev1.Pod) (string, *v1alpha1.PodGroup)
  • func (pgMgr *PodGroupManager) PatchPodGroup(pgName string, namespace string, patch []byte) error
  • func (pgMgr *PodGroupManager) Permit(ctx context.Context, pod *corev1.Pod, nodeName string) (bool, error)
  • func (pgMgr *PodGroupManager) PostBind(ctx context.Context, pod *corev1.Pod, nodeName string)
  • func (pgMgr *PodGroupManager) PreFilter(ctx context.Context, pod *corev1.Pod) error

Functions

func CheckClusterResource

func CheckClusterResource(nodeList []*framework.NodeInfo, resourceRequest corev1.ResourceList, desiredPodGroupName string) error

CheckClusterResource checks if resource capacity of the cluster can satisfy <resourceRequest>. It returns an error detailing the resource gap if not satisfied; otherwise returns nil.

func GetNamespacedName

func GetNamespacedName(obj metav1.Object) string

GetNamespacedName returns the namespaced name

Types

type Manager

type Manager interface {
	PreFilter(context.Context, *corev1.Pod) error
	Permit(context.Context, *corev1.Pod, string) (bool, error)
	PostBind(context.Context, *corev1.Pod, string)
	GetPodGroup(*corev1.Pod) (string, *v1alpha1.PodGroup)
	GetCreationTimestamp(*corev1.Pod, time.Time) time.Time
	AddDeniedPodGroup(string)
	DeletePermittedPodGroup(string)
	CalculateAssignedPods(string, string) int
}

Manager defines the interfaces for PodGroup management.

type PodGroupManager

type PodGroupManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

PodGroupManager defines the scheduling operation called

func NewPodGroupManager

func NewPodGroupManager(pgClient pgclientset.Interface, snapshotSharedLister framework.SharedLister, scheduleTimeout, deniedPGExpirationTime *time.Duration,
	pgInformer pginformer.PodGroupInformer, podInformer informerv1.PodInformer) *PodGroupManager

NewPodGroupManager create a new operation object

func (*PodGroupManager) AddDeniedPodGroup

func (pgMgr *PodGroupManager) AddDeniedPodGroup(pgFullName string)

AddDeniedPodGroup adds a podGroup that fails to be scheduled to a PodGroup cache with expriration.

func (*PodGroupManager) CalculateAssignedPods

func (pgMgr *PodGroupManager) CalculateAssignedPods(podGroupName, namespace string) int

CalculateAssignedPods returns the number of pods that has been assigned a node: assumed or bound.

func (*PodGroupManager) DeletePermittedPodGroup

func (pgMgr *PodGroupManager) DeletePermittedPodGroup(pgFullName string)

DeletePodGroup delete a podGroup that pass Pre-Filter but reach PostFilter.

func (*PodGroupManager) GetCreationTimestamp

func (pgMgr *PodGroupManager) GetCreationTimestamp(pod *corev1.Pod, ts time.Time) time.Time

GetCreationTimestamp returns the creation time of a podGroup or a pod.

func (*PodGroupManager) GetPodGroup

func (pgMgr *PodGroupManager) GetPodGroup(pod *corev1.Pod) (string, *v1alpha1.PodGroup)

GetPodGroup returns the PodGroup that a Pod belongs to from cache.

func (*PodGroupManager) PatchPodGroup

func (pgMgr *PodGroupManager) PatchPodGroup(pgName string, namespace string, patch []byte) error

PatchPodGroup patches a podGroup.

func (*PodGroupManager) Permit

func (pgMgr *PodGroupManager) Permit(ctx context.Context, pod *corev1.Pod, nodeName string) (bool, error)

Permit permits a pod to run, if the minMember match, it would send a signal to chan.

func (*PodGroupManager) PostBind

func (pgMgr *PodGroupManager) PostBind(ctx context.Context, pod *corev1.Pod, nodeName string)

PostBind updates a PodGroup's status.

func (*PodGroupManager) PreFilter

func (pgMgr *PodGroupManager) PreFilter(ctx context.Context, pod *corev1.Pod) error

PreFilter filters out a pod if it 1. belongs to a podgroup that was recently denied or 2. the total number of pods in the podgroup is less than the minimum number of pods that is required to be scheduled.