type ConflictReason … type ConflictReasons … func (reasons ConflictReasons) Len() int { … } func (reasons ConflictReasons) Less(i, j int) bool { … } func (reasons ConflictReasons) Swap(i, j int) { … } const ErrReasonBindConflict … const ErrReasonNodeConflict … const ErrReasonNotEnoughSpace … const ErrReasonPVNotExist … type BindingInfo … // StorageClassName returns the name of the storage class. func (b *BindingInfo) StorageClassName() string { … } type StorageResource … // StorageResource returns storage resource. func (b *BindingInfo) StorageResource() *StorageResource { … } type PodVolumes … type InTreeToCSITranslator … type SchedulerVolumeBinder … type PodVolumeClaims … type volumeBinder … var _ … type CapacityCheck … // NewVolumeBinder sets up all the caches needed for the scheduler to make volume binding decisions. // // capacityCheck determines how storage capacity is checked (CSIStorageCapacity feature). func NewVolumeBinder( logger klog.Logger, kubeClient clientset.Interface, podInformer coreinformers.PodInformer, nodeInformer coreinformers.NodeInformer, csiNodeInformer storageinformers.CSINodeInformer, pvcInformer coreinformers.PersistentVolumeClaimInformer, pvInformer coreinformers.PersistentVolumeInformer, storageClassInformer storageinformers.StorageClassInformer, capacityCheck CapacityCheck, bindTimeout time.Duration) SchedulerVolumeBinder { … } // FindPodVolumes finds the matching PVs for PVCs and nodes to provision PVs // for the given pod and node. If the node does not fit, conflict reasons are // returned. func (b *volumeBinder) FindPodVolumes(logger klog.Logger, pod *v1.Pod, podVolumeClaims *PodVolumeClaims, node *v1.Node) (podVolumes *PodVolumes, reasons ConflictReasons, err error) { … } // AssumePodVolumes will take the matching PVs and PVCs to provision in pod's // volume information for the chosen node, and: // 1. Update the pvCache with the new prebound PV. // 2. Update the pvcCache with the new PVCs with annotations set // 3. Update PodVolumes again with cached API updates for PVs and PVCs. func (b *volumeBinder) AssumePodVolumes(logger klog.Logger, assumedPod *v1.Pod, nodeName string, podVolumes *PodVolumes) (allFullyBound bool, err error) { … } // RevertAssumedPodVolumes will revert assumed PV and PVC cache. func (b *volumeBinder) RevertAssumedPodVolumes(podVolumes *PodVolumes) { … } // BindPodVolumes gets the cached bindings and PVCs to provision in pod's volumes information, // makes the API update for those PVs/PVCs, and waits for the PVCs to be completely bound // by the PV controller. func (b *volumeBinder) BindPodVolumes(ctx context.Context, assumedPod *v1.Pod, podVolumes *PodVolumes) (err error) { … } func getPodName(pod *v1.Pod) string { … } func getPVCName(pvc *v1.PersistentVolumeClaim) string { … } // bindAPIUpdate makes the API update for those PVs/PVCs. func (b *volumeBinder) bindAPIUpdate(ctx context.Context, pod *v1.Pod, bindings []*BindingInfo, claimsToProvision []*v1.PersistentVolumeClaim) error { … } var versioner … // checkBindings runs through all the PVCs in the Pod and checks: // * if the PVC is fully bound // * if there are any conditions that require binding to fail and be retried // // It returns true when all of the Pod's PVCs are fully bound, and error if // binding (and scheduling) needs to be retried // Note that it checks on API objects not PV/PVC cache, this is because // PV/PVC cache can be assumed again in main scheduler loop, we must check // latest state in API server which are shared with PV controller and // provisioners func (b *volumeBinder) checkBindings(logger klog.Logger, pod *v1.Pod, bindings []*BindingInfo, claimsToProvision []*v1.PersistentVolumeClaim) (bool, error) { … } func (b *volumeBinder) isVolumeBound(logger klog.Logger, pod *v1.Pod, vol *v1.Volume) (bound bool, pvc *v1.PersistentVolumeClaim, err error) { … } func (b *volumeBinder) isPVCBound(logger klog.Logger, namespace, pvcName string) (bool, *v1.PersistentVolumeClaim, error) { … } func (b *volumeBinder) isPVCFullyBound(pvc *v1.PersistentVolumeClaim) bool { … } // arePodVolumesBound returns true if all volumes are fully bound func (b *volumeBinder) arePodVolumesBound(logger klog.Logger, pod *v1.Pod) bool { … } // GetPodVolumeClaims returns a pod's PVCs separated into bound, unbound with delayed binding (including provisioning), // unbound with immediate binding (including prebound) and PVs that belong to storage classes of unbound PVCs with delayed binding. func (b *volumeBinder) GetPodVolumeClaims(logger klog.Logger, pod *v1.Pod) (podVolumeClaims *PodVolumeClaims, err error) { … } func (b *volumeBinder) checkBoundClaims(logger klog.Logger, claims []*v1.PersistentVolumeClaim, node *v1.Node, pod *v1.Pod) (bool, bool, error) { … } // findMatchingVolumes tries to find matching volumes for given claims, // and return unbound claims for further provision. func (b *volumeBinder) findMatchingVolumes(logger klog.Logger, pod *v1.Pod, claimsToBind []*v1.PersistentVolumeClaim, unboundVolumesDelayBinding map[string][]*v1.PersistentVolume, node *v1.Node) (foundMatches bool, bindings []*BindingInfo, unboundClaims []*v1.PersistentVolumeClaim, err error) { … } // checkVolumeProvisions checks given unbound claims (the claims have gone through func // findMatchingVolumes, and do not have matching volumes for binding), and return true // if all of the claims are eligible for dynamic provision. func (b *volumeBinder) checkVolumeProvisions(logger klog.Logger, pod *v1.Pod, claimsToProvision []*v1.PersistentVolumeClaim, node *v1.Node) (provisionSatisfied, sufficientStorage bool, dynamicProvisions []*v1.PersistentVolumeClaim, err error) { … } func (b *volumeBinder) revertAssumedPVs(bindings []*BindingInfo) { … } func (b *volumeBinder) revertAssumedPVCs(claims []*v1.PersistentVolumeClaim) { … } // hasEnoughCapacity checks whether the provisioner has enough capacity left for a new volume of the given size // that is available from the node. func (b *volumeBinder) hasEnoughCapacity(logger klog.Logger, provisioner string, claim *v1.PersistentVolumeClaim, storageClass *storagev1.StorageClass, node *v1.Node) (bool, error) { … } func capacitySufficient(capacity *storagev1.CSIStorageCapacity, sizeInBytes int64) bool { … } func volumeLimit(capacity *storagev1.CSIStorageCapacity) *resource.Quantity { … } func (b *volumeBinder) nodeHasAccess(logger klog.Logger, node *v1.Node, capacity *storagev1.CSIStorageCapacity) bool { … } type byPVCSize … func (a byPVCSize) Len() int { … } func (a byPVCSize) Swap(i, j int) { … } func (a byPVCSize) Less(i, j int) bool { … } // isCSIMigrationOnForPlugin checks if CSI migration is enabled for a given plugin. func isCSIMigrationOnForPlugin(pluginName string) bool { … } // isPluginMigratedToCSIOnNode checks if an in-tree plugin has been migrated to a CSI driver on the node. func isPluginMigratedToCSIOnNode(pluginName string, csiNode *storagev1.CSINode) bool { … } // tryTranslatePVToCSI will translate the in-tree PV to CSI if it meets the criteria. If not, it returns the unmodified in-tree PV. func (b *volumeBinder) tryTranslatePVToCSI(logger klog.Logger, pv *v1.PersistentVolume, csiNode *storagev1.CSINode) (*v1.PersistentVolume, error) { … }
Codebase Browser
kubernetes