utils

Nov 26, 2024

Changes in this version

+ const PodNameKey

+ const PodNamespaceKey

+ const ServiceTypeEnv

+ const WorkerRoleResource

+ func GetDiskFStypePTtype(disk string) (fstype string, pttype string, err error)

+ func GetPodFromContextOrK8s(ctx context.Context, client kubernetes.Interface, ...) (*v1.Pod, error)

+ func WithPodInfo(ctx context.Context, client kubernetes.Interface, ...) (context.Context, *v1.Pod)

type Config

+ func (c *Config) GetInt(configKey, env string, defaultValue int) int

type Mounter

+ func NewFakeMounter() Mounter

type ServiceType

+ const Controller

+ const Node

+ func GetServiceType(runAsController, runControllerService, runNodeService bool) ServiceType

Aug 16, 2024

Changes in this version

+ const CGROUPFS_MOUNT_PATH

+ const RundRunTimeTag

+ type PodCGroup struct

+ func NewPodCGroup() (*PodCGroup, error)

+ func (cg *PodCGroup) ApplyConfig(devicePath string, req *csi.NodePublishVolumeRequest) error

Apr 10, 2024

Changes in this version

+ const PodBlkIOCgroupPath

+ func GetCredentialV2() (crev2.Credential, error)

+ func NewStsClient(ac AccessControl) (stsClient *sts.Client)

+ func WriteSharedMetricsInfo(metricsPathPrefix string, req *csi.NodePublishVolumeRequest, clientName string, ...)

+ func WriteTrunc(dirFd int, filePath string, value string) error

type ManageTokens

+ ExpireAt time.Time

Dec 4, 2023

Changes in this version

+ const MetadataMaxRetryCount

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

+ func GetRegionID() (string, error)

+ type Config struct

+ ConfigMap map[string]string

+ func (c *Config) Get(configKey, env, defaultValue string) string

+ func (c *Config) GetBool(configKey, env string, defaultValue bool) bool

+ type VolumeLocks struct

+ func NewVolumeLocks() *VolumeLocks

+ func (lock *VolumeLocks) Release(volumeID string)

+ func (lock *VolumeLocks) TryAcquire(volumeID string) bool

Aug 8, 2023

Changes in this version

+ const GiB

+ var NsenterArgs = []string

+ func Bytes2GiB(volumeSizeBytes int64) int64

+ func BytesToGiB(volumeSizeBytes int64) int64

+ func CommandOnNode(args ...string) *exec.Cmd

+ func GetAccessModes(caps []*csi.VolumeCapability) *[]string

+ func RoundUpBytes(volumeSizeBytes int64) int64

+ func RoundUpGiB(volumeSizeBytes int64) int64

May 29, 2023

Changes in this version

+ func FormatNewDisk(readOnly bool, source, fstype, target string, ...) error

+ func GetDiskPtypePTtype(disk string) (fstype string, pttype string, err error)

+ func KBlock2Bytes(kblocks int64) int64

+ func ParseProviderID(providerID string) string

Mar 21, 2023

Changes in this version

+ const VolDataFileName

+ var NodeAddrMap = map[string]string

+ var NodeAddrMutex sync.RWMutex

+ func AppendJSONData(dataFilePath string, appData map[string]string) error

+ func CheckCmd(cmd string, name string) error

+ func CheckCmdArgs(cmd string, args ...string) error

+ func CheckRequest(m map[string]string, path string) (bool, error)

+ func CheckRequestArgs(m map[string]string) (bool, error)

+ func ConnectorRun(cmd string) (string, error)

+ func CreateDestInHost(dest string) error

+ func DoMountInHost(mntCmd string) error

+ func FormatAndMount(diskMounter *k8smount.SafeFormatAndMount, source string, target string, ...) error

+ func Gi2Bytes(gb int64) int64

+ func HasSpecificTagKey(tagKey string, disk *ecs.Disk) (bool, string)

+ func IsKataInstall() bool

+ func IsMountedInHost(mountPath string) bool

+ func IsPathAvailiable(path string) error

+ func IsPrivateCloud() bool

+ func LoadJSONData(dataFileName string) (map[string]string, error)

+ func MkdirAll(path string, mode fs.FileMode) error

+ func RemoveAll(deletePath string) error

+ func RunWithFilter(cmd string, filter ...string) ([]string, error)

+ func SetNodeAddrMap(key string, value string)

+ func SetVolumeIOLimit(devicePath string, req *csi.NodePublishVolumeRequest) error

+ func UmountInHost(mountPath string) error

+ func ValidatePath(path string) (bool, error)

+ func ValidateRequest(m map[string]string) (bool, error)

+ func ValidateRun(cmd string) (string, error)

+ func WriteMetricsInfo(metricsPathPrefix string, req *csi.NodePublishVolumeRequest, metricsTop string, ...)

type AccessControl

+ func GetEnvAK() AccessControl

type AccessControlMode

+ const OIDCToken

+ type MountPoint struct

+ Device string

+ Freq int

+ Opts []string

+ Pass int

+ Path string

+ Type string

+ func ListProcMounts() ([]MountPoint, error)

type Mounter

+ IsNotMountPoint func(file string) (bool, error)

Jan 21, 2022

Changes in this version

+ type AccessControl struct

+ AccessKeyID string

+ AccessKeySecret string

+ Config *sdk.Config

+ Credential auth.Credential

+ RoleArn string

+ StsToken string

+ UseMode AccessControlMode

+ func GetAccessControl() AccessControl

+ type AccessControlMode int

+ const AccessKey

+ const Credential

+ const EcsRAMRole

+ const ManagedToken

+ const RoleArnToken

Jan 11, 2022

Changes in this version

+ const InstallSnapshotCRD

+ const MetadataMaxRetrycount

+ const NsenterCmd

+ var KubeletRootDir = "/var/lib/kubelet"

+ var MountPathWithTLS = "/tls"

+ func CheckParameterValidate(inputs []string) bool

+ func CheckQuotaPathValidate(kubeClient *kubernetes.Clientset, path string) error

+ func CreateCertPEM(option CertOption, ca *KeyPairArtifacts, begin, end time.Time, isClient bool) ([]byte, []byte, error)

+ func Fsync(f *os.File) error

+ func GetDefaultRoleAK() (string, string, string)

+ func GetNodeAddr(client kubernetes.Interface, node string, port string) (string, error)

+ func GetNodeIP(client kubernetes.Interface, nodeID string) (net.IP, error)

+ func GetPvNameFormPodMnt(mntPath string) string

+ func IsDirTmpfs(path string) bool

+ func IsHostFileExist(path string) bool

+ func IsLikelyNotMountPoint(file string) (bool, error)

+ func NewClientTLSFromFile(serverName, caFile, certFile, keyFile string) (credentials.TransportCredentials, error)

+ func NewServerTLSFromFile(caFile, certFile, keyFile string) (credentials.TransportCredentials, error)

+ func RetryGetMetaData(resource string) string

+ func WriteAndSyncFile(filename string, data []byte, perm os.FileMode) error

type AKInfo

+ RoleAccessKeyID string

+ RoleAccessKeySecret string

+ RoleArn string

+ type CertOption struct

+ CAName string

+ CAOrganizations []string

+ CommonName string

+ DNSNames []string

+ type KeyPairArtifacts struct

+ Cert *x509.Certificate

+ CertPEM []byte

+ Key *rsa.PrivateKey

+ KeyPEM []byte

+ func CreateCACert(option CertOption, begin, end time.Time) (*KeyPairArtifacts, error)

+ type ManageTokens struct

+ AccessKeyID string

+ AccessKeySecret string

+ RoleAccessKeyID string

+ RoleAccessKeySecret string

+ RoleArn string

+ SecurityToken string

Sep 6, 2021

Changes in this version

+ func RunTimeout(cmd string, timeout int) error

Jan 13, 2021

Changes in this version

+ const PluginService

+ const ProvisionerService

+ const ServiceType

+ func CreateEvent(recorder record.EventRecorder, objectRef *v1.ObjectReference, eventType string, ...)

+ func Ping(ipAddress string) (*ping.Statistics, error)

+ type CommandRunFunc func(cmd string) (string, error)

Nov 2, 2020

Changes in this version

+ const DiskAttachDetach

+ const DiskDelete

+ const DiskMount

+ const DiskProvision

+ const NasFilesystemCreate

+ const NasFilesystemDelete

+ const NasMountTargetCreate

+ const NasMountTargetDelete

+ var DiskAttachDetachErrors = map[string]*errorInfo

+ var DiskDeleteErrors = map[string]*errorInfo

+ var DiskMountErrors = map[string]*errorInfo

+ var DiskProvisionErrors = map[string]*errorInfo

+ var NasFilesystemCreateErrors = map[string]*errorInfo

+ var NasFilesystemDeleteErrors = map[string]*errorInfo

+ var NasMountTargetCreateErrors = map[string]*errorInfo

+ var NasMountTargetDeleteErrors = map[string]*errorInfo

+ func FindSuggestionByErrorMessage(errMsg, errorType string) string

+ func NewEventRecorder() record.EventRecorder

Apr 14, 2020

Changes in this version

+ const ConfigPath

+ func Decrypt(s string, keyring []byte) ([]byte, error)

+ func GetManagedToken() (string, string, string)

+ func PKCS5UnPadding(origData []byte) []byte

+ type AKInfo struct

+ AccessKeyID string

+ AccessKeySecret string

+ Expiration string

+ Keyring string

+ SecurityToken string

Mar 5, 2020

Changes in this version

+ const CsiPluginRunTimeFlagFile

+ const RuncRunTimeTag

+ const RunvRunTimeTag

+ func GetFileContent(fileName string) string

+ func GetPodRunTime(req *csi.NodePublishVolumeRequest, clientSet *kubernetes.Clientset) string

+ func IsMountPointRunv(mountPoint string) bool

Feb 18, 2020

Changes in this version

+ func GetMetrics(path string) (*csi.NodeGetVolumeStatsResponse, error)

Dec 20, 2019

Changes in this version

+ func IsDir(path string) bool

Nov 15, 2019

Changes in this version

+ const DefaultRegion

+ const InstanceIDTag

+ const MetadataURL

+ const RegionIDTag

+ const UserAKID

+ const UserAKSecret

+ var KubernetesAlicloudIdentity = fmt.Sprintf("Kubernetes.Alicloud/CsiPlugin")

+ func GetRegionAndInstanceID() (string, string, error)

+ func GetRegionIDAndInstanceID(nodeName string) (string, string, error)

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

+ func NewEcsClient(accessKeyID, accessKeySecret, accessToken string) (ecsClient *ecs.Client)

+ func ReadJSONFile(file string) (map[string]string, error)

+ func WriteJSONFile(obj interface{}, file string) error

+ type Mounter interface

+ EnsureBlock func(target string) error

+ EnsureFolder func(target string) error

+ Format func(source, fsType string) error

+ HasMountRefs func(mountPath string, mountRefs []string) bool

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

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

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

+ MountBlock func(source, target string, options ...string) error

+ SafePathRemove func(target string) error

+ Unmount func(target string) error

+ func NewMounter() Mounter

+ type RoleAuth struct

+ AccessKeyID string

+ AccessKeySecret string

+ Code string

+ Expiration time.Time

+ LastUpdated time.Time

+ SecurityToken string

Sep 19, 2018

Changes in this version

+ const INSTANCEID_TAG

+ const METADATA_URL

+ const REGIONID_TAG

+ const USER_AKID

+ const USER_AKSECRET

+ func CreateDest(dest string) error

+ func Finish(result Result)

+ func FinishError(message string)

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

+ func GetLocalAK() (string, string)

+ func GetMetaData(resource string) (string, error)

+ func GetRegionAndInstanceId() (string, string, error)

+ func GetRegionIdAndInstanceId(nodeName string) (string, string, error)

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

+ func IsFileExisting(filename string) bool

+ func IsMounted(mountPath string) bool

+ func ReadJsonFile(file string) (map[string]string, error)

+ func Run(cmd string) (string, error)

+ func Umount(mountPath string) bool

+ func WriteJosnFile(obj interface{}, file string) error

+ type DefaultOptions struct

+ Global struct{ ... }

+ type Result struct

+ Device string

+ Message string

+ Status string

+ func Fail(a ...interface{}) Result

+ func NotSupport(a ...interface{}) Result

+ func Succeed(a ...interface{}) Result