disk

package

Go to main page

Versions in this module

v1

v1.4.0

Apr 10, 2024

Changes in this version

+ const DefaultMaxVolumesPerNode

+ const DiskInvalidPL

+ const DiskSizeNotAvailable1

+ const DiskSizeNotAvailable2

+ const InstanceNotFound

+ const KMSKeyID

+ const MaxVolumesPerNodeLimit

+ const SNAPSHOT_TAG_PREFIX

+ func CheckDeviceAvailable(devicePath, volumeID, targetPath string) error

+ type AttachDetachSlots interface

+ GetSlotFor func(node string) slot

+ func NewParallelAttachDetachSlots() AttachDetachSlots

+ func NewSerialAttachDetachSlots() AttachDetachSlots

+ type DiskSize struct

+ Bytes int64

+ func (d DiskSize) String() string

type GlobalConfig

+ AttachDetachSlots AttachDetachSlots

+ DiskAllowAllType bool

+ type ParallelAttachDetachSlots struct

+ func (ParallelAttachDetachSlots) GetSlotFor(node string) slot

+ type SerialAttachDetachSlots struct

+ func (a *SerialAttachDetachSlots) GetSlotFor(node string) slot

v1.3.0

Dec 4, 2023

Changes in this version

+ const DISK_DELETE_MAX_RETRY

+ const DiskESSDEntry

+ const GetDiskTypeTimeout

+ const IdempotentParameterMismatch

+ const SnapshotNotFound

+ const UpdateNodeTimeout

+ func GetAvailableDiskTypes(ctx context.Context, c cloud.ECSInterface, instanceType, zoneID string) (types []string, err error)

+ func IsDiskCreatedByCsi(disk ecs.Disk) bool

v1.2.1

Aug 8, 2023

v1.2.0

May 29, 2023

Changes in this version

+ const BURSTING_ENABLED_KEY

+ const DiskIopsLimitExceeded

+ const OmitFilesystemCheck

+ const PROVISIONED_IOPS_KEY

+ const VfhpReconcilePeriod

+ func IsVFInstance() bool

type GlobalConfig

+ CheckBDFHotPlugin bool

+ OmitFilesystemCheck bool

v1.1.7

Mar 21, 2023

Changes in this version

+ const CSI_DEFAULT_FS_TYPE

+ const DISK_CLOUD_EFFICIENT_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_AUTO_PL_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_PL0_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_PL1_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_PL2_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_PL3_MIN_CAPACITY

+ const DISK_CLOUD_ESSD_PLX_MIN_CAPACITY

+ const DISK_CLOUD_SSD_MIN_CAPACITY

+ const DISK_PERFORMANCE_LEVEL0

+ const DISK_PERFORMANCE_LEVEL1

+ const DISK_PERFORMANCE_LEVEL2

+ const DISK_PERFORMANCE_LEVEL3

+ const DiskESSDAuto

+ const DiskPPerf

+ const DiskPerformanceLevelNotMatch

+ const DiskSPerf

+ const ESSD_PERFORMANCE_LEVEL

+ const EXT3_FSTYPE

+ const EXT4_FSTYPE

+ const FS_TYPE

+ const MinimumDiskSizeInBytes

+ const MinimumDiskSizeInGB

+ const MultiAttach

+ const NeverAttached

+ const NodeMultiZoneEnable

+ const SNAPSHOTRESOURCEGROUPID

+ const SNAPSHOT_MAX_RETENTION_DAYS

+ const SNAPSHOT_MIN_RETENTION_DAYS

+ const TopologyMultiZonePrefix

+ const VOLUME_DELETE_AUTO_SNAPSHOT_OP_RETENT_DAYS_KEY

+ const VOLUME_EXPAND_AUTO_SNAPSHOT_OP_KEY

+ const VolumeDeleteAutoSnapshotKey

+ const XFS_FSTYPE

+ var AvailableDiskTypes = []string

+ var CustomDiskPerfermance = map[string]string

+ var DEFAULT_VMFATAL_EVENTS = []string

+ var DiskCapacityMapping = map[string]int

+ func ChooseDevice(rootDevice, subDevice string) string

+ func DescribeDiskInstanceEvents(instanceId string, ecsClient *ecs.Client) (eventMaps map[string]string, err error)

+ func GetRootSubDevicePath(deviceList []string) (rootDevicePath, subDevicePath string, err error)

+ func IsDeviceNvme(deviceName string) bool

+ func StopDiskOperationRetry(instanceId string, ecsClient *ecs.Client) bool

type GlobalConfig

+ AddonVMFatalEvents []string

+ NodeMultiZoneEnable bool

+ RequestBaseInfo map[string]string

+ SnapshotBeforeDelete bool

+ WaitBeforeAttach bool

+ ZoneID string

v1.1.6

Jan 21, 2022

v1.1.5

Jan 11, 2022

Changes in this version

+ const CreateDiskARN

+ const DefaultVolumeSnapshotClass

+ const DiskMultiTenantEnable

+ const DiskSnapshotID

+ const IAVolumeSnapshotKey

+ const LastApplyKey

+ const MaxVolumesPerNode

+ const NOUUID

+ const PvNameKey

+ const PvcNameKey

+ const PvcNamespaceKey

+ const RemoteSnapshotLabelKey

+ const RetryMaxTimes

+ const RundSocketDir

+ const SnapshotRequestTag

+ const SnapshotVolumeKey

+ const SocketPath

+ const StorageProvisionerKey

+ const TenantUserUID

+ const VolumeSnapshotContentName

+ const VolumeSnapshotName

+ const VolumeSnapshotNamespace

+ var SnapshotRequestInterval = int64(10)

+ var SnapshotRequestMap = map[string]int64

type GlobalConfig

+ DiskMultiTenantEnable bool

+ SnapClient *snapClientset.Clientset

v1.1.4

Sep 6, 2021

Changes in this version

+ const BdfVolumeHang

+ const BdfVolumeUnUsed

+ const DiskBdfCheckTagKey

+ const DiskForceDetached

+ const DiskNotAvailableVer2

+ var DingURL = os.Getenv("Ding_URL")

+ var ObjReference = &v1.ObjectReference

+ func BdfHealthCheck()

+ func DingTalk(msg string)

+ type DingMsg struct

+ Mstype string

+ Text DingText

+ type DingText struct

+ Content string

type GlobalConfig

+ BdfHealthCheck bool

+ ControllerService bool

+ DetachBeforeAttach bool

v1.1.3

May 13, 2021

Changes in this version

+ const NotSupportDiskCategory

+ const NsenterCmd

+ func GetDiskFormat(disk string) (string, string, error)

type GlobalConfig

+ DiskPartitionEnable bool

v1.1.3-dev

Jun 17, 2021

v1.1.2

Mar 30, 2021

Changes in this version

+ const DISKTAGKEY3

+ const FileSystemLoseCapacityPercent

+ const INSTANTACCESSRETENTIONDAYS

+ const NodeSchedueTag

+ func UpdateNode(nodeID string, client *kubernetes.Clientset, c *ecs.Client)

type GlobalConfig

+ ClusterID string

+ FilesystemLosePercent float64

v1.1.1

Jan 13, 2021

Changes in this version

+ const FileSystemLose

+ const GBSIZE

+ const INSTANTACCESS

+ const RETENTIONDAYS

+ const SNAPSHOTTYPE

+ const ZoneID

+ var AvaliableDiskTypes = []string

+ var CustomDiskTypes = map[string]int

v1.1.0

Nov 2, 2020

Changes in this version

+ const CreateSnapshotError

+ const CreatedSnapshotSuccessfully

+ const DeleteSnapshotError

+ const DeletedSnapshotSuccessfully

+ const SnapshotAlreadyExist

+ const SnapshotTooMany

+ func GetRegionID() string

+ func GetVolumeIDByDevice(device string) (volumeID string, err error)

v1.0.7

Aug 5, 2020

v1.0.7-paas

Feb 25, 2021

v1.0.6

Jul 13, 2020

Changes in this version

+ const BLOCKVOLUMEPREFIX

+ const DiskDetachBeforeDelete

+ const InputOutputErr

+ const SNAPSHOTFORCETAG

+ const SNAPSHOTTAGKEY1

+ const SysConfigTag

+ func IsVFNode() bool

v1.0.5

Apr 14, 2020

Changes in this version

+ const BlkIDSz

+ const DevIDOffsetInBar0

+ const DiskBdfEnable

+ const DiskBdfTagKey

+ const DiskDetachDisable

+ const DiskUUIDPath

+ const InstanceStatusStopped

+ const MaxVfNum

+ const VfBar0Sz

+ func ExecCheckOutput(cmd string, args ...string) (io.Reader, error)

+ func FindLines(reader io.Reader, keyword string) []string

+ func GetDeviceByBdf(bdf string) (device string, err error)

+ func GetDeviceByUUID(diskID string) string

+ func IohubSriovBind(bdf string) error

+ func IohubSriovUnbind(bdf string) error

+ func IsNoSuchDeviceErr(err error) bool

+ func SaveUUID(diskID, deviceName string) error

+ func VirtioPciBind(bdf string) error

+ func VirtioPciUnbind(bdf string) error

+ type BdfAttachInfo struct

+ Depend bool

+ LastAttachedNodeID string

type GlobalConfig

+ ClientSet *kubernetes.Clientset

+ DetachBeforeDelete bool

+ DetachDisabled bool

+ DiskBdfEnable bool

+ NodeID string

+ type PatchStringValue struct

+ Op string

+ Path string

+ Value interface{}

v1.0.4

Mar 5, 2020

Changes in this version

+ const MixRunTimeMode

+ const RunvRunTimeMode

type GlobalConfig

+ RunTimeClass string

+ type QueryResponse struct

v1.0.3

Feb 18, 2020

Changes in this version

+ const DiskAttachByController

+ const DiskMetricByPlugin

+ func GetDeviceByVolumeID(volumeID string) (device string, err error)

+ func GetVolumeDeviceName(volumeID string) string

+ func GlobalConfigSet(client *ecs.Client, region string)

+ func IsDeviceMappedDiskIDEnabled() bool

+ type GlobalConfig struct

+ ADControllerEnable bool

+ AttachMutex sync.RWMutex

+ CanAttach bool

+ DiskTagEnable bool

+ EcsClient *ecs.Client

+ MetricEnable bool

+ Region string

+ var GlobalConfigVar GlobalConfig

v1.0.2

Dec 20, 2019

Changes in this version

+ const DISKTAGKEY1

+ const DISKTAGKEY2

+ const DISKTAGVALUE1

+ const DISKTAGVALUE2

+ const MkfsOptions

+ func SetEcsEndPoint(regionID string)

v1.0.1

Nov 15, 2019

Changes in this version

+ const DefaultRegion

+ const DiskAttachedKey

+ const DiskAttachedValue

+ const DiskCommon

+ const DiskConflict

+ const DiskCreatingSnapshot

+ const DiskESSD

+ const DiskEfficiency

+ const DiskHighAvail

+ const DiskLimitExceeded

+ const DiskNotAvailable

+ const DiskNotPortable

+ const DiskSSD

+ const DiskSharedEfficiency

+ const DiskSharedSSD

+ const DiskSizeNotAvailable

+ const DiskStatusAttached

+ const DiskStatusAttaching

+ const DiskStatusAvailable

+ const DiskStatusDetached

+ const DiskStatusInuse

+ const DiskTagedByPlugin

+ const DocumentURL

+ const IncorrectDiskStatus

+ const InstanceID

+ const KubernetesAlicloudDiskDriver

+ const LogfilePrefix

+ const MBSIZE

+ const MetadataURL

+ const PERFORMANCELEVELPL1

+ const PERFORMANCELEVELPL2

+ const PERFORMANCELEVELPL3

+ const RegionIDTag

+ const SharedEnable

+ const TagK8sPV

+ const TopologyZoneKey

+ const UserNotInTheWhiteList

+ const VolumeDir

+ const VolumeDirRemove

+ const ZoneIDTag

+ var KubernetesAlicloudIdentity = fmt.Sprintf("Kubernetes.Alicloud/CsiProvision.Disk-%s", VERSION)

+ func GetDeviceByMntPoint(targetPath string) string

+ func GetDevicePath(volumeID string) (path string)

+ func GetDevicePathByID(volumeID string) (path string)

+ func IsDeviceUsedOthers(deviceName, volumeID string) (bool, error)

+ func IsDirEmpty(name string) (bool, error)

+ type DISK struct

+ func (disk *DISK) Run()

+ type RoleAuth struct

+ AccessKeyID string

+ AccessKeySecret string

+ Code string

+ Expiration time.Time

+ LastUpdated time.Time

+ SecurityToken string

v0

v0.3.0

Feb 20, 2019

Changes in this version

+ const DISC_CREATING_SNAPSHOT

+ const DISC_INCORRECT_STATUS

+ const DISK_CONFILICT

+ const INSTANCE_ID

+ type Mounter interface

+ EnsureFolder func(target string) error

+ Format func(source, fsType string) error

+ IsFormatted func(source string) (bool, error)

+ IsMounted func(target string) (bool, error)

+ Mount func(source, target, fsType string, options ...string) error

+ Unmount func(target string) error

+ func NewMounter() Mounter

v0.2.0

Sep 19, 2018

Changes in this version

+ const DEFAULT_REGION

+ const DISK_COMMON

+ const DISK_EFFICIENCY

+ const DISK_HIGH_AVAIL

+ const DISK_NOTAVAILABLE

+ const DISK_SSD

+ const KUBERNETES_ALICLOUD_DISK_DRIVER

+ const LOGFILE_PREFIX

+ const MB_SIZE

+ const METADATA_URL

+ const PluginFolder

+ const REGIONID_TAG

+ const VOLUME_INUSE

+ const VOLUME_NONE

+ const VOLUME_STARTING

+ const VOLUMR_STOPPING

+ const ZONEID_TAG

+ var GITCOMMIT = "HEAD"

+ var KUBERNETES_ALICLOUD_IDENTITY = fmt.Sprintf("Kubernetes.Alicloud/CsiProvision.Disk-%s", ProvisionVersion())

+ var VERSION = "v1.10.4"

+ func GetDefaultAK() (string, string, string)

+ func GetDeviceMountNum(targetPath string) int

+ func GetLocalAK() (string, string)

+ func GetMetaData(resource string) string

+ func GetSTSAK() (string, string, string)

+ func IsFileExisting(filename string) bool

+ func NewControllerServer(d *csicommon.CSIDriver) *controllerServer

+ func NewDriver(nodeID, endpoint string) *disk

+ func NewIdentityServer(d *csicommon.CSIDriver) *identityServer

+ func NewNodeServer(d *csicommon.CSIDriver) *nodeServer

+ func ProvisionVersion() string

+ type DefaultOptions struct

+ Global struct{ ... }

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