internal

package

Go to main page

Versions in this module

v0

v0.3.4

Aug 20, 2020

v0.3.3

Jul 2, 2020

v0.3.2

Apr 7, 2020

v0.3.1

Mar 30, 2020

Changes in this version

+ type SchedulingPhase string

+ const FilteringPhase

+ const PreemptingPhase

v0.3.0

Mar 24, 2020

Changes in this version

+ func IsNodeHealthy(node *core.Node) bool

type InspectHandlers

+ GetAllAffinityGroupsHandler func() si.AffinityGroupList

+ GetAllVirtualClustersStatusHandler func() map[si.VirtualClusterName]si.VirtualClusterStatus

+ GetClusterStatusHandler func() si.ClusterStatus

+ GetPhysicalClusterStatusHandler func() si.PhysicalClusterStatus

+ GetVirtualClusterStatusHandler func(vcName si.VirtualClusterName) si.VirtualClusterStatus

type SchedulerAlgorithm

+ AddUnallocatedPod func(pod *core.Pod)

+ DeleteUnallocatedPod func(pod *core.Pod)

+ GetAllAffinityGroups func() si.AffinityGroupList

+ GetAllVirtualClustersStatus func() map[si.VirtualClusterName]si.VirtualClusterStatus

+ GetClusterStatus func() si.ClusterStatus

+ GetPhysicalClusterStatus func() si.PhysicalClusterStatus

+ GetVirtualClusterStatus func(si.VirtualClusterName) si.VirtualClusterStatus

v0.2.6

Feb 6, 2020

v0.2.5

Dec 9, 2019

v0.2.4

Dec 6, 2019

Changes in this version

+ type InspectHandlers struct

+ GetAffinityGroupHandler func(name string) si.AffinityGroup

+ GetAffinityGroupsHandler func() si.AffinityGroupList

type PodWaitInfo

+ Reason string

type SchedulerAlgorithm

+ GetAffinityGroup func(name string) si.AffinityGroup

+ GetAffinityGroups func() si.AffinityGroupList

v0.2.3

Nov 25, 2019

v0.2.2

Nov 18, 2019

v0.2.1

Nov 13, 2019

v0.2.0

Nov 4, 2019

v0.1.0

Aug 2, 2019

Changes in this version

+ func AsBadRequestPanic()

+ func BindPod(kClient kubeClient.Interface, bindingPod *core.Pod)

+ func CreateClient(kConfig *rest.Config) kubeClient.Interface

+ func ExtractPodBindAnnotations(allocatedPod *core.Pod) map[string]string

+ func ExtractPodBindInfo(allocatedPod *core.Pod) *si.PodBindInfo

+ func ExtractPodSchedulingSpec(pod *core.Pod) *si.PodSchedulingSpec

+ func GetKey(obj interface{}) (string, error)

+ func HandleInformerPanic(logPfx string, logOnSucceeded bool)

+ func HandleRoutinePanic(logPfx string)

+ func HandleWebServerPanic(handler func(*si.WebServerError))

+ func IsAllocated(state PodState) bool

+ func IsBound(pod *core.Pod) bool

+ func IsCompleted(pod *core.Pod) bool

+ func IsHivedEnabled(pod *core.Pod) bool

+ func IsInterested(pod *core.Pod) bool

+ func IsLive(pod *core.Pod) bool

+ func IsUnbound(pod *core.Pod) bool

+ func Key(p *core.Pod) string

+ func NewBadRequestError(message string) *si.WebServerError

+ func NewBindingPod(pod *core.Pod, podBindInfo *si.PodBindInfo) *core.Pod

+ func SplitKey(key string) (namespace, name string, err error)

+ func ToNode(obj interface{}) *core.Node

+ func ToPod(obj interface{}) *core.Pod

+ type ExtenderHandlers struct

+ BindHandler func(args ei.ExtenderBindingArgs) *ei.ExtenderBindingResult

+ FilterHandler func(args ei.ExtenderArgs) *ei.ExtenderFilterResult

+ PreemptHandler func(args ei.ExtenderPreemptionArgs) *ei.ExtenderPreemptionResult

+ type PodKey struct

+ Name string

+ Namespace string

+ UID types.UID

+ func NewPodKey(namespace string, name string, uid types.UID) *PodKey

+ func (pk *PodKey) String() string

+ type PodPreemptInfo struct

+ VictimPods []*core.Pod

+ type PodScheduleResult struct

+ PodBindInfo *si.PodBindInfo

+ PodPreemptInfo *PodPreemptInfo

+ PodWaitInfo *PodWaitInfo

+ type PodScheduleStatus struct

+ Pod *core.Pod

+ PodBindAttempts int32

+ PodScheduleResult *PodScheduleResult

+ PodState PodState

+ type PodScheduleStatuses map[types.UID]*PodScheduleStatus

+ type PodState string

+ const PodBinding

+ const PodBound

+ const PodPreempting

+ const PodUnknown

+ const PodWaiting

+ type PodWaitInfo struct

+ FailedNodeReasons map[string]string

+ type SchedulerAlgorithm interface

+ AddAllocatedPod func(pod *core.Pod)

+ AddNode func(node *core.Node)

+ DeleteAllocatedPod func(pod *core.Pod)

+ DeleteNode func(node *core.Node)

+ Schedule func(pod *core.Pod, suggestedNodes []string) PodScheduleResult

+ UpdateNode func(oldNode, newNode *core.Node)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL