reservation

Feb 17, 2025

Changes in this version

type Plugin

+ func (pl *Plugin) FilterNominateReservation(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ type PreemptionMgr struct

+ func (pm *PreemptionMgr) Name() string

+ func (pm *PreemptionMgr) PostFilter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (*framework.PostFilterResult, *framework.Status)

+ func (pm *PreemptionMgr) SelectVictimsOnNode(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) ([]*corev1.Pod, int, *framework.Status)

Jun 3, 2024

Changes in this version

type Plugin

+ func (pl *Plugin) AddNominatedReservePod(pod *corev1.Pod, nodeName string)

+ func (pl *Plugin) DeleteNominatedReservePod(pod *corev1.Pod)

Jan 9, 2024

Changes in this version

+ const ErrReasonNoReservationsMeetRequirements

type Plugin

+ func (pl *Plugin) AddNominatedReservation(pod *corev1.Pod, nodeName string, rInfo *frameworkext.ReservationInfo)

+ func (pl *Plugin) GetNominatedReservation(pod *corev1.Pod, nodeName string) *frameworkext.ReservationInfo

+ func (pl *Plugin) RemoveNominatedReservations(pod *corev1.Pod)

+ func (pl *Plugin) ReservationScoreExtensions() frameworkext.ReservationScoreExtensions

type ReservationCache

+ GetReservationInfoByPod func(pod *corev1.Pod, nodeName string) *frameworkext.ReservationInfo

Aug 14, 2023

Changes in this version

+ const ErrReasonPreemptionFailed

+ const ErrReasonReservationAffinity

+ const ErrReasonReservationAllocatePolicyConflict

+ const ErrReasonReservationInsufficientResources

+ func SetReservationCache(cache ReservationCache)

+ type NodeReservations struct

+ Items []ReservationItem

type Plugin

+ func (pl *Plugin) AddPod(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ func (pl *Plugin) EventsToRegister() []framework.ClusterEvent

+ func (pl *Plugin) RegisterEndpoints(group *gin.RouterGroup)

+ func (pl *Plugin) RemovePod(ctx context.Context, cycleState *framework.CycleState, ...) *framework.Status

+ type ReservationCache interface

+ DeleteReservation func(r *schedulingv1alpha1.Reservation) *frameworkext.ReservationInfo

+ func GetReservationCache() ReservationCache

+ type ReservationItem struct

+ Allocatable corev1.ResourceList

+ AllocatablePorts framework.HostPortInfo

+ AllocateOnce bool

+ AllocatePolicy schedulingv1alpha1.ReservationAllocatePolicy

+ Allocated corev1.ResourceList

+ AllocatedPorts framework.HostPortInfo

+ AssignedPods []*frameworkext.PodRequirement

+ Available bool

+ Kind string

+ Name string

+ Namespace string

+ Owners []schedulingv1alpha1.ReservationOwner

+ UID types.UID

Apr 7, 2023

Changes in this version

+ const ErrReasonOnlyOneSameReusableReservationOnSameNode

type Plugin

+ func (pl *Plugin) AfterPreFilter(_ frameworkext.ExtendedHandle, cycleState *framework.CycleState, ...) error

+ func (pl *Plugin) BeforeFilter(handle frameworkext.ExtendedHandle, cycleState *framework.CycleState, ...) (*corev1.Pod, *framework.NodeInfo, bool)

+ func (pl *Plugin) BeforePreFilter(_ frameworkext.ExtendedHandle, cycleState *framework.CycleState, ...) (*corev1.Pod, bool)

+ func (pl *Plugin) FilterReservation(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (pl *Plugin) NewControllers() ([]frameworkext.Controller, error)

+ func (pl *Plugin) NominateReservation(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (*schedulingv1alpha1.Reservation, *framework.Status)

+ func (pl *Plugin) ScoreReservation(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)

Sep 21, 2022

Changes in this version

+ const ErrReasonReservationInactive

+ const ErrReasonReservationNotMatchStale

type AvailableCache

+ func (a *AvailableCache) GetOwnedR(key string) *reservationInfo

type Plugin

+ func (p *Plugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (p *Plugin) PreScore(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

Aug 4, 2022

Changes in this version

+ const ErrReasonNodeNotMatchReservation

+ const ErrReasonReservationFailed

+ const ErrReasonReservationFailedToReserve

+ const ErrReasonReservationNotFound

+ const Name

+ const NodeNameIndex

+ const SkipReasonNotReservation

+ var AnnotationReservationName = apiext.SchedulingDomainPrefix + "/reservation-name"

+ var AnnotationReservationNode = apiext.SchedulingDomainPrefix + "/reservation-node"

+ var AnnotationReservePod = apiext.SchedulingDomainPrefix + "/reserve-pod"

+ func GetReservationKey(r *schedulingv1alpha1.Reservation) string

+ func GetReservationNameFromReservePod(pod *corev1.Pod) string

+ func GetReservationNodeName(r *schedulingv1alpha1.Reservation) string

+ func GetReservationSchedulerName(r *schedulingv1alpha1.Reservation) string

+ func GetReservePodKey(pod *corev1.Pod) string

+ func GetReservePodNodeName(pod *corev1.Pod) string

+ func IsReservationActive(r *schedulingv1alpha1.Reservation) bool

+ func IsReservationExpired(r *schedulingv1alpha1.Reservation) bool

+ func IsReservationFailed(r *schedulingv1alpha1.Reservation) bool

+ func IsReservationScheduled(r *schedulingv1alpha1.Reservation) bool

+ func IsReservePod(pod *corev1.Pod) bool

+ func New(args runtime.Object, handle framework.Handle) (framework.Plugin, error)

+ func NewReservePod(r *schedulingv1alpha1.Reservation) *corev1.Pod

+ func SetReservationNodeName(r *schedulingv1alpha1.Reservation, nodeName string)

+ func StatusNodeNameIndexFunc(obj interface{}) ([]string, error)

+ func ValidateReservation(r *schedulingv1alpha1.Reservation) error

+ type AvailableCache struct

+ func (a *AvailableCache) Add(r *schedulingv1alpha1.Reservation)

+ func (a *AvailableCache) Delete(r *schedulingv1alpha1.Reservation)

+ func (a *AvailableCache) Get(key string) *reservationInfo

+ func (a *AvailableCache) GetOnNode(nodeName string) []*reservationInfo

+ func (a *AvailableCache) Len() int

+ type Hook struct

+ func NewHook() *Hook

+ func (h *Hook) FilterHook(handle frameworkext.ExtendedHandle, cycleState *framework.CycleState, ...) (*corev1.Pod, *framework.NodeInfo, bool)

+ func (h *Hook) Name() string

+ func (h *Hook) PreFilterHook(handle frameworkext.ExtendedHandle, cycleState *framework.CycleState, ...) (*corev1.Pod, bool)

+ type Plugin struct

+ func (p *Plugin) Bind(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (p *Plugin) Filter(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (p *Plugin) Name() string

+ func (p *Plugin) PostFilter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (*framework.PostFilterResult, *framework.Status)

+ func (p *Plugin) PreBind(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (p *Plugin) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod) *framework.Status

+ func (p *Plugin) PreFilterExtensions() framework.PreFilterExtensions

+ func (p *Plugin) Reserve(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (p *Plugin) Score(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)

+ func (p *Plugin) ScoreExtensions() framework.ScoreExtensions

+ func (p *Plugin) Unreserve(ctx context.Context, cycleState *framework.CycleState, pod *corev1.Pod, ...)