Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const VolumeSchedulerSubsystem + var VolumeBindingRequestSchedulerBinderCache = metrics.NewCounterVec(&metrics.CounterOpts{ ... }, []string{ ... }) + var VolumeSchedulingStageFailed = metrics.NewCounterVec(&metrics.CounterOpts{ ... }, []string{ ... }) + var VolumeSchedulingStageLatency = metrics.NewHistogramVec(&metrics.HistogramOpts{ ... }, []string{ ... }) + func RegisterVolumeSchedulingMetrics() + type AssumeCache interface + Assume func(obj interface{}) error + Get func(objName string) (interface{}, error) + GetAPIObj func(objName string) (interface{}, error) + List func(indexObj interface{}) []interface{} + Restore func(objName string) + func NewAssumeCache(informer cache.SharedIndexInformer, description, indexName string, ...) AssumeCache + type FakeVolumeBinder struct + AssumeCalled bool + BindCalled bool + func NewFakeVolumeBinder(config *FakeVolumeBinderConfig) *FakeVolumeBinder + func (b *FakeVolumeBinder) AssumePodVolumes(assumedPod *v1.Pod, nodeName string) (bool, error) + func (b *FakeVolumeBinder) BindPodVolumes(assumedPod *v1.Pod) error + func (b *FakeVolumeBinder) FindPodVolumes(pod *v1.Pod, node *v1.Node) (unboundVolumesSatisfied, boundVolumesSatsified bool, err error) + func (b *FakeVolumeBinder) GetBindingsCache() PodBindingCache + type FakeVolumeBinderConfig struct + AllBound bool + AssumeErr error + BindErr error + FindBoundSatsified bool + FindErr error + FindUnboundSatsified bool + type PVAssumeCache interface + GetAPIPV func(pvName string) (*v1.PersistentVolume, error) + GetPV func(pvName string) (*v1.PersistentVolume, error) + ListPVs func(storageClassName string) []*v1.PersistentVolume + func NewPVAssumeCache(informer cache.SharedIndexInformer) PVAssumeCache + type PVCAssumeCache interface + GetAPIPVC func(pvcKey string) (*v1.PersistentVolumeClaim, error) + GetPVC func(pvcKey string) (*v1.PersistentVolumeClaim, error) + func NewPVCAssumeCache(informer cache.SharedIndexInformer) PVCAssumeCache + type PodBindingCache interface + ClearBindings func(pod *v1.Pod, node string) + DeleteBindings func(pod *v1.Pod) + GetBindings func(pod *v1.Pod, node string) []*bindingInfo + GetDecisions func(pod *v1.Pod) nodeDecisions + GetProvisionedPVCs func(pod *v1.Pod, node string) []*v1.PersistentVolumeClaim + UpdateBindings func(pod *v1.Pod, node string, bindings []*bindingInfo, ...) + func NewPodBindingCache() PodBindingCache + type SchedulerVolumeBinder interface + AssumePodVolumes func(assumedPod *v1.Pod, nodeName string) (allFullyBound bool, err error) + BindPodVolumes func(assumedPod *v1.Pod) error + FindPodVolumes func(pod *v1.Pod, node *v1.Node) (unboundVolumesSatisified, boundVolumesSatisfied bool, err error) + GetBindingsCache func() PodBindingCache + func NewVolumeBinder(kubeClient clientset.Interface, nodeInformer coreinformers.NodeInformer, ...) SchedulerVolumeBinder
Go to main page