const ErrReasonMaxVolumeCountExceeded … type InTreeToCSITranslator … type CSILimits … var _ … var _ … var _ … const CSIName … // Name returns name of the plugin. It is used in logs, etc. func (pl *CSILimits) Name() string { … } // EventsToRegister returns the possible events that may make a Pod. // failed by this plugin schedulable. func (pl *CSILimits) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … } func (pl *CSILimits) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } func (pl *CSILimits) isSchedulableAfterPVCAdded(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } // PreFilter invoked at the prefilter extension point // // If the pod haven't those types of volumes, we'll skip the Filter phase func (pl *CSILimits) PreFilter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … } // PreFilterExtensions returns prefilter extensions, pod add and remove. func (pl *CSILimits) PreFilterExtensions() framework.PreFilterExtensions { … } // Filter invoked at the filter extension point. func (pl *CSILimits) Filter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { … } // filterAttachableVolumes filters the attachable volumes from the pod and adds them to the result map. // The result map is a map of volumeUniqueName to driver name. The volumeUniqueName is a unique name for // the volume in the format of "driverName/volumeHandle". And driver name is the CSI driver name. func (pl *CSILimits) filterAttachableVolumes( logger klog.Logger, pod *v1.Pod, csiNode *storagev1.CSINode, newPod bool, result map[string]string) error { … } // checkAttachableInlineVolume takes an inline volume and add to the result map if the // volume is migratable and CSI migration for this plugin has been enabled. func (pl *CSILimits) checkAttachableInlineVolume(logger klog.Logger, vol *v1.Volume, csiNode *storagev1.CSINode, pod *v1.Pod, result map[string]string) error { … } // getCSIDriverInfo returns the CSI driver name and volume ID of a given PVC. // If the PVC is from a migrated in-tree plugin, this function will return // the information of the CSI driver that the plugin has been migrated to. func (pl *CSILimits) getCSIDriverInfo(logger klog.Logger, csiNode *storagev1.CSINode, pvc *v1.PersistentVolumeClaim) (string, string) { … } // getCSIDriverInfoFromSC returns the CSI driver name and a random volume ID of a given PVC's StorageClass. func (pl *CSILimits) getCSIDriverInfoFromSC(logger klog.Logger, csiNode *storagev1.CSINode, pvc *v1.PersistentVolumeClaim) (string, string) { … } // NewCSI initializes a new plugin and returns it. func NewCSI(_ context.Context, _ runtime.Object, handle framework.Handle, fts feature.Features) (framework.Plugin, error) { … } // getVolumeLimits reads the volume limits from CSINode object and returns a map of volume limits. // The key is the driver name and the value is the maximum number of volumes that can be attached to the node. // If a key is not found in the map, it means there is no limit for the driver on the node. func getVolumeLimits(csiNode *storagev1.CSINode) map[string]int64 { … } // getNodeVolumeAttachmentInfo returns a map of volumeID to driver name for the given node. func (pl *CSILimits) getNodeVolumeAttachmentInfo(logger klog.Logger, nodeName string) (map[string]string, error) { … } func getVolumeUniqueName(driverName, volumeHandle string) string { … }
Codebase Browser
kubernetes