csi_util

Documentation

Index

• Constants
• Variables
• func ExtractBlockVolumePerformanceLevel(attribute string) (int64, error)
• func ExtractISCSIInformation(attributes map[string]string) (*disk.Disk, error)
• func ExtractISCSIInformationFromMountPath(logger *zap.SugaredLogger, diskPath []string) (*disk.Disk, error)
• func ExtractStorage(capRange *csi.CapacityRange) (int64, error)
• func FormatBytes(inputBytes int64) string
• func GetDevicePath(sd *disk.Disk) string
• func GetKubeClient(logger *zap.SugaredLogger, master, kubeconfig string) *kubernetes.Clientset
• func MaxOfInt(a, b int64) int64
• func RoundUpMinSize() int64
• func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64
• func ValidateFsType(logger *zap.SugaredLogger, fsType string) string
• type Util
  • func (u *Util) GetAvailableDomainInNodeLabel(fullAD string) string
  • func (u *Util) LookupNodeAvailableDomain(k kubernetes.Interface, nodeID string) (string, error)
  • func (u *Util) LookupNodeID(k kubernetes.Interface, nodeName string) (string, error)
  • func (u *Util) WaitForPathToExist(path string, maxRetries int) bool
• type VolumeLocks
  • func NewVolumeLocks() *VolumeLocks
  • func (vl *VolumeLocks) Release(volumeID string)
  • func (vl *VolumeLocks) TryAcquire(volumeID string) bool

Constants

const (
	// minimumVolumeSizeInBytes is used to validate that the user is not trying
	// to create a volume that is smaller than what we support
	MinimumVolumeSizeInBytes int64 = 50 * client.GiB

	// maximumVolumeSizeInBytes is used to validate that the user is not trying
	// to create a volume that is larger than what we support
	MaximumVolumeSizeInBytes int64 = 32 * client.TiB

	// Block Volume Performance Units
	VpusPerGB                 = "vpusPerGB"
	LowCostPerformanceOption  = 0
	BalancedPerformanceOption = 10
	HigherPerformanceOption   = 20
)

Variables

var (
	DiskByPathPatternPV    = `/dev/disk/by-path/pci-\d+:\d+:\d+\.\d+-scsi-\d+:\d+:\d+:\d+$`
	DiskByPathPatternISCSI = `/dev/disk/by-path/ip-[\w\.]+:\d+-iscsi-[\w\.\-:]+-lun-1$`
)

Functions

func ExtractBlockVolumePerformanceLevel

func ExtractBlockVolumePerformanceLevel(attribute string) (int64, error)

Extracts the vpusPerGB as int64 from given string input

func ExtractISCSIInformation

func ExtractISCSIInformation(attributes map[string]string) (*disk.Disk, error)

func ExtractISCSIInformationFromMountPath

func ExtractISCSIInformationFromMountPath(logger *zap.SugaredLogger, diskPath []string) (*disk.Disk, error)

func ExtractStorage

func ExtractStorage(capRange *csi.CapacityRange) (int64, error)

extractStorage extracts the storage size in bytes from the given capacity range. If the capacity range is not satisfied it returns the default volume size. If the capacity range is below or above supported sizes, it returns an error.

func FormatBytes

func FormatBytes(inputBytes int64) string

func GetDevicePath

func GetDevicePath(sd *disk.Disk) string

func GetKubeClient

func GetKubeClient(logger *zap.SugaredLogger, master, kubeconfig string) *kubernetes.Clientset

func MaxOfInt

func MaxOfInt(a, b int64) int64

func RoundUpMinSize

func RoundUpMinSize() int64

func RoundUpSize

func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64

func ValidateFsType

func ValidateFsType(logger *zap.SugaredLogger, fsType string) string

Types

type Util

type Util struct {
	Logger *zap.SugaredLogger
}

Util interface

func (*Util) GetAvailableDomainInNodeLabel

func (u *Util) GetAvailableDomainInNodeLabel(fullAD string) string

convert "zkJl:US-ASHBURN-AD-1" to "US-ASHBURN-AD-1"

func (*Util) LookupNodeAvailableDomain

func (u *Util) LookupNodeAvailableDomain(k kubernetes.Interface, nodeID string) (string, error)

func (*Util) LookupNodeID

func (u *Util) LookupNodeID(k kubernetes.Interface, nodeName string) (string, error)

func (*Util) WaitForPathToExist

func (u *Util) WaitForPathToExist(path string, maxRetries int) bool

waitForPathToExist waits for for a given filesystem path to exist.

type VolumeLocks

type VolumeLocks struct {
	// contains filtered or unexported fields
}

func NewVolumeLocks

func NewVolumeLocks() *VolumeLocks

func (*VolumeLocks) Release

func (vl *VolumeLocks) Release(volumeID string)

func (*VolumeLocks) TryAcquire

func (vl *VolumeLocks) TryAcquire(volumeID string) bool