const VSphereDriverName … const VSphereInTreePluginName … const vSphereCSITopologyZoneKey … const vSphereCSITopologyRegionKey … const paramStoragePolicyName … const paramcsiMigration … const paramDatastore … const paramDiskFormat … const paramHostFailuresToTolerate … const paramForceProvisioning … const paramCacheReservation … const paramDiskstripes … const paramObjectspacereservation … const paramIopslimit … const AttributeInitialVolumeFilepath … var _ … type vSphereCSITranslator … // NewvSphereCSITranslator returns a new instance of vSphereCSITranslator func NewvSphereCSITranslator() InTreePlugin { … } // TranslateInTreeStorageClassToCSI translates InTree vSphere storage class parameters to CSI storage class func (t *vSphereCSITranslator) TranslateInTreeStorageClassToCSI(logger klog.Logger, sc *storage.StorageClass) (*storage.StorageClass, error) { … } // TranslateInTreeInlineVolumeToCSI takes a Volume with VsphereVolume set from in-tree // and converts the VsphereVolume source to a CSIPersistentVolumeSource func (t *vSphereCSITranslator) TranslateInTreeInlineVolumeToCSI(logger klog.Logger, volume *v1.Volume, podNamespace string) (*v1.PersistentVolume, error) { … } // TranslateInTreePVToCSI takes a PV with VsphereVolume set from in-tree // and converts the VsphereVolume source to a CSIPersistentVolumeSource func (t *vSphereCSITranslator) TranslateInTreePVToCSI(logger klog.Logger, pv *v1.PersistentVolume) (*v1.PersistentVolume, error) { … } // TranslateCSIPVToInTree takes a PV with CSIPersistentVolumeSource set and // translates the vSphere CSI source to a vSphereVolume source. func (t *vSphereCSITranslator) TranslateCSIPVToInTree(pv *v1.PersistentVolume) (*v1.PersistentVolume, error) { … } // CanSupport tests whether the plugin supports a given persistent volume // specification from the API. func (t *vSphereCSITranslator) CanSupport(pv *v1.PersistentVolume) bool { … } // CanSupportInline tests whether the plugin supports a given inline volume // specification from the API. func (t *vSphereCSITranslator) CanSupportInline(volume *v1.Volume) bool { … } // GetInTreePluginName returns the name of the in-tree plugin driver func (t *vSphereCSITranslator) GetInTreePluginName() string { … } // GetCSIPluginName returns the name of the CSI plugin func (t *vSphereCSITranslator) GetCSIPluginName() string { … } // RepairVolumeHandle is needed in VerifyVolumesAttached on the external attacher when we need to do strict volume // handle matching to check VolumeAttachment attached status. // vSphere volume does not need patch to help verify whether that volume is attached. func (t *vSphereCSITranslator) RepairVolumeHandle(volumeHandle, nodeID string) (string, error) { … } // translateTopologyFromInTreevSphereToCSI converts existing zone labels or in-tree vsphere topology to // vSphere CSI topology. func translateTopologyFromInTreevSphereToCSI(pv *v1.PersistentVolume, csiTopologyKeyZone string, csiTopologyKeyRegion string) error { … } // translateTopologyFromCSIToInTreevSphere converts CSI zone/region affinity rules to in-tree vSphere zone/region labels func translateTopologyFromCSIToInTreevSphere(pv *v1.PersistentVolume, csiTopologyKeyZone string, csiTopologyKeyRegion string) error { … }
Codebase Browser
kubernetes