state

Nov 4, 2024

Changes in this version

+ func ToJSONable(ps map[types.NamespacedName]map[string]int32) map[string]map[string]int32

Sep 1, 2023

Changes in this version

type State

+ ExpectedVReplicaByVPod map[types.NamespacedName]int32

+ Pending map[types.NamespacedName]int32

+ func (s *State) TotalExpectedVReplicas() int32

+ func (s *State) TotalPending() int32

Feb 9, 2023

Changes in this version

type State

+ func (s *State) IsSchedulablePod(ordinal int32) bool

+ func (s *State) MarshalJSON() ([]byte, error)

Nov 1, 2021

Changes in this version

+ const AvailabilityNodePriority

+ const AvailabilityZonePriority

+ const EvenPodSpread

+ const LowestOrdinalPriority

+ const NoMaxResourceCount

+ const PodFitsResources

+ const RemoveWithAvailabilityNodePriority

+ const RemoveWithAvailabilityZonePriority

+ const RemoveWithEvenPodSpreadPriority

+ const RemoveWithHighestOrdinalPriority

+ func GetVPod(key types.NamespacedName, vpods []scheduler.VPod) scheduler.VPod

+ func OrdinalFromPodName(podName string) int32

+ func PodNameFromOrdinal(name string, ordinal int32) string

+ func SatisfyNodeAvailability(feasiblePods []int32, states *State) bool

+ func SatisfyZoneAvailability(feasiblePods []int32, states *State) bool

+ type AvailabilityNodePriorityArgs struct

+ MaxSkew int32

+ type AvailabilityZonePriorityArgs struct

+ MaxSkew int32

+ type Code int

+ const Error

+ const Success

+ const Unschedulable

+ type EvenPodSpreadArgs struct

+ MaxSkew int32

+ type FilterPlugin interface

+ Filter func(ctx context.Context, args interface{}, state *State, key types.NamespacedName, ...) *Status

+ type NoMaxResourceCountArgs struct

+ NumPartitions int

+ type Plugin interface

+ Name func() string

+ type PluginToPodScores map[string]PodScoreList

+ type PluginToStatus map[string]*Status

+ func (p PluginToStatus) Merge() *Status

+ type PodScore struct

+ ID int32

+ Score uint64

+ type PodScoreList []PodScore

+ type ScoreExtensions interface

+ NormalizeScore func(ctx context.Context, state *State, scores PodScoreList) *Status

+ type ScorePlugin interface

+ Score func(ctx context.Context, args interface{}, state *State, feasiblePods []int32, ...) (uint64, *Status)

+ ScoreExtensions func() ScoreExtensions

+ type State struct

+ Capacity int32

+ DeschedPolicy *scheduler.SchedulerPolicy

+ FreeCap []int32

+ LastOrdinal int32

+ NodeSpread map[types.NamespacedName]map[string]int32

+ NodeToZoneMap map[string]string

+ NumNodes int32

+ NumZones int32

+ PodLister corev1.PodNamespaceLister

+ PodSpread map[types.NamespacedName]map[string]int32

+ Replicas int32

+ SchedPolicy *scheduler.SchedulerPolicy

+ SchedulablePods []int32

+ SchedulerPolicy scheduler.SchedulerPolicyType

+ StatefulSetName string

+ ZoneSpread map[types.NamespacedName]map[string]int32

+ func (s *State) Free(ordinal int32) int32

+ func (s *State) FreeCapacity() int32

+ func (s *State) GetPodInfo(podName string) (zoneName string, nodeName string, err error)

+ func (s *State) SetFree(ordinal int32, value int32)

+ type StateAccessor interface

+ State func(reserved map[types.NamespacedName]map[string]int32) (*State, error)

+ func NewStateBuilder(ctx context.Context, namespace, sfsname string, lister scheduler.VPodLister, ...) StateAccessor

+ type Status struct

+ func AsStatus(err error) *Status

+ func NewStatus(code Code, reasons ...string) *Status

+ func (s *Status) AsError() error

+ func (s *Status) Code() Code

+ func (s *Status) IsError() bool

+ func (s *Status) IsSuccess() bool

+ func (s *Status) IsUnschedulable() bool

+ func (s *Status) Message() string