osutils

Mar 17, 2023

Changes in this version

+ const UUIDPrefix — darwin/amd64, linux/amd64, windows/amd64

+ func GetMounter(ctx context.Context, osUtils *OsUtils) (mounter.CSIProxyMounter, error) — windows/amd64

+ type Device struct

+ FullPath string

+ Name string

+ RealDev string

+ type NodePublishParams struct

+ Device string

+ DiskID string

+ Ro bool

+ StagingTarget string

+ Target string

+ VolID string

+ VolumePath string

+ type NodeStageParams struct

+ FsType string

+ MntFlags []string

+ Ro bool

+ StagingTarget string

+ VolID string

+ type OsUtils struct

+ Mounter *mount.SafeFormatAndMount

+ func NewOsUtils(ctx context.Context) (*OsUtils, error)

+ func (osUtils *OsUtils) CleanupPublishPath(ctx context.Context, target string, volID string) error

+ func (osUtils *OsUtils) CleanupStagePath(ctx context.Context, stagingTarget string, volID string) error

+ func (osUtils *OsUtils) ConvertUUID(uuid string) (string, error)

+ func (osUtils *OsUtils) EnsureMountVol(ctx context.Context, volCap *csi.VolumeCapability) (string, []string, error)

+ func (osUtils *OsUtils) GetBlockSizeBytes(ctx context.Context, devicePath string) (int64, error)

+ func (osUtils *OsUtils) GetDevFromMount(ctx context.Context, target string) (*Device, error)

+ func (osUtils *OsUtils) GetDevMounts(ctx context.Context, sysDevice *Device) ([]gofsutil.Info, error)

+ func (osUtils *OsUtils) GetDevice(ctx context.Context, path string) (*Device, error)

+ func (osUtils *OsUtils) GetDeviceRescanPath(dev *Device) (string, error)

+ func (osUtils *OsUtils) GetDiskID(pubCtx map[string]string, log *zap.SugaredLogger) (string, error)

+ func (osUtils *OsUtils) GetDiskPath(id string) (string, error)

+ func (osUtils *OsUtils) GetMetrics(ctx context.Context, path string) (*k8svol.Metrics, error)

+ func (osUtils *OsUtils) GetSystemUUID(ctx context.Context) (string, error)

+ func (osUtils *OsUtils) GetVolumeCapabilityFsType(ctx context.Context, capability *csi.VolumeCapability) (string, error)

+ func (osUtils *OsUtils) IsBlockDevice(ctx context.Context, volumePath string) (bool, error)

+ func (osUtils *OsUtils) IsBlockVolumeMounted(ctx context.Context, volID string, stagingTargetPath string) (bool, error)

+ func (osUtils *OsUtils) IsBlockVolumePublished(ctx context.Context, volID string, target string) (bool, error)

+ func (osUtils *OsUtils) IsTargetInMounts(ctx context.Context, path string) (bool, error)

+ func (osUtils *OsUtils) Mkdir(ctx context.Context, path string) (bool, error)

+ func (osUtils *OsUtils) Mkfile(ctx context.Context, path string) (bool, error)

+ func (osUtils *OsUtils) NodeStageBlockVolume(ctx context.Context, req *csi.NodeStageVolumeRequest, params NodeStageParams) (*csi.NodeStageVolumeResponse, error)

+ func (osUtils *OsUtils) PreparePublishPath(ctx context.Context, path string) error

+ func (osUtils *OsUtils) PublishBlockVol(ctx context.Context, req *csi.NodePublishVolumeRequest, dev *Device, ...) (*csi.NodePublishVolumeResponse, error)

+ func (osUtils *OsUtils) PublishFileVol(ctx context.Context, req *csi.NodePublishVolumeRequest, ...) (*csi.NodePublishVolumeResponse, error)

+ func (osUtils *OsUtils) PublishMountVol(ctx context.Context, req *csi.NodePublishVolumeRequest, dev *Device, ...) (*csi.NodePublishVolumeResponse, error)

+ func (osUtils *OsUtils) RescanDevice(ctx context.Context, dev *Device) error

+ func (osUtils *OsUtils) ResizeVolume(ctx context.Context, devicePath, volumePath string, reqVolSizeBytes int64) error

+ func (osUtils *OsUtils) Rmpath(ctx context.Context, target string) error

+ func (osUtils *OsUtils) ShouldContinue(ctx context.Context)

+ func (osUtils *OsUtils) VerifyTargetDir(ctx context.Context, target string, targetShouldExist bool) (bool, error)

+ func (osUtils *OsUtils) VerifyVolumeAttached(ctx context.Context, diskID string) (string, error)

+ func (osUtils *OsUtils) VerifyVolumeAttachedAndFillParams(ctx context.Context, pubCtx map[string]string, params *NodePublishParams, ...) error