volumebinding

package

Go to main page

Versions in this module

v1

v1.9.0-alpha.0

Feb 2, 2024

v1.8.2

Jan 9, 2024

v1.8.1

Sep 25, 2023

Changes in this version

type FakeVolumeBinder

+ func (b *FakeVolumeBinder) GetEligibleNodes(boundClaims []*v1.PersistentVolumeClaim) (eligibleNodes sets.String)

+ func (b *FakeVolumeBinder) GetPodVolumeClaims(pod *v1.Pod) (podVolumeClaims *PodVolumeClaims, err error)

+ type PodVolumeClaims struct

type SchedulerVolumeBinder

+ GetEligibleNodes func(boundClaims []*v1.PersistentVolumeClaim) (eligibleNodes sets.String)

+ GetPodVolumeClaims func(pod *v1.Pod) (podVolumeClaims *PodVolumeClaims, err error)

v1.8.0

Aug 8, 2023

v1.8.0-alpha.0

Jul 13, 2023

v1.7.0

Dec 30, 2022

Changes in this version

+ const DefaultBindTimeoutSeconds

+ const ErrReasonBindConflict

+ const ErrReasonNodeConflict

+ const ErrReasonNotEnoughSpace

+ const ErrReasonPVNotExist

+ const Name

+ func New(plArgs runtime.Object, fh framework.Handle, fts feature.Features) (framework.Plugin, error)

+ 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 BindingInfo struct

+ func (b *BindingInfo) StorageClassName() string

+ func (b *BindingInfo) StorageResource() *StorageResource

+ type CapacityCheck struct

+ CSIDriverInformer storageinformers.CSIDriverInformer

+ CSIStorageCapacityInformer storageinformersv1beta1.CSIStorageCapacityInformer

+ type ConflictReason string

+ type ConflictReasons []ConflictReason

+ func (reasons ConflictReasons) Len() int

+ func (reasons ConflictReasons) Less(i, j int) bool

+ func (reasons ConflictReasons) Swap(i, j int)

+ type FakeVolumeBinder struct

+ AssumeCalled bool

+ BindCalled bool

+ func NewFakeVolumeBinder(config *FakeVolumeBinderConfig) *FakeVolumeBinder

+ func (b *FakeVolumeBinder) AssumePodVolumes(assumedPod *v1.Pod, nodeName string, podVolumes *PodVolumes) (bool, error)

+ func (b *FakeVolumeBinder) BindPodVolumes(ctx context.Context, assumedPod *v1.Pod, podVolumes *PodVolumes) error

+ func (b *FakeVolumeBinder) FindPodVolumes(pod *v1.Pod, _, _ []*v1.PersistentVolumeClaim, node *v1.Node) (podVolumes *PodVolumes, reasons ConflictReasons, err error)

+ func (b *FakeVolumeBinder) GetPodVolumes(pod *v1.Pod) (...)

+ func (b *FakeVolumeBinder) RevertAssumedPodVolumes(_ *PodVolumes)

+ type FakeVolumeBinderConfig struct

+ AllBound bool

+ AssumeErr error

+ BindErr error

+ FindErr error

+ FindReasons ConflictReasons

+ type InTreeToCSITranslator interface

+ GetInTreePluginNameFromSpec func(pv *v1.PersistentVolume, vol *v1.Volume) (string, error)

+ IsPVMigratable func(pv *v1.PersistentVolume) bool

+ TranslateInTreePVToCSI func(pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ 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 PodVolumes struct

+ DynamicProvisions []*v1.PersistentVolumeClaim

+ StaticBindings []*BindingInfo

+ type SchedulerVolumeBinder interface

+ AssumePodVolumes func(assumedPod *v1.Pod, nodeName string, podVolumes *PodVolumes) (allFullyBound bool, err error)

+ BindPodVolumes func(ctx context.Context, assumedPod *v1.Pod, podVolumes *PodVolumes) error

+ FindPodVolumes func(pod *v1.Pod, boundClaims, claimsToBind []*v1.PersistentVolumeClaim, ...) (podVolumes *PodVolumes, reasons ConflictReasons, err error)

+ GetPodVolumes func(pod *v1.Pod) (...)

+ RevertAssumedPodVolumes func(podVolumes *PodVolumes)

+ func NewVolumeBinder(kubeClient clientset.Interface, podInformer coreinformers.PodInformer, ...) SchedulerVolumeBinder

+ type StorageResource struct

+ Capacity int64

+ Requested int64

+ type VolumeBinding struct

+ Binder SchedulerVolumeBinder

+ PVCLister corelisters.PersistentVolumeClaimLister

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

+ func (pl *VolumeBinding) Filter(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (pl *VolumeBinding) Name() string

+ func (pl *VolumeBinding) PreBind(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

+ func (pl *VolumeBinding) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)

+ func (pl *VolumeBinding) PreFilterExtensions() framework.PreFilterExtensions

+ func (pl *VolumeBinding) Reserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

+ func (pl *VolumeBinding) Score(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status)

+ func (pl *VolumeBinding) ScoreExtensions() framework.ScoreExtensions

+ func (pl *VolumeBinding) Unreserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string)

v1.7.0-beta.0

Dec 28, 2022

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