nas

Documentation

Index

• Constants
• func DetermineClientTypeAndMountProtocol(cnfs *v1beta1.ContainerNetworkFileSystem, opt *Options) error
• func GetFsIDByCpfsServer(server string) string
• func GetFsIDByNasServer(server string) string
• func NewNasMounter() mountutils.Interface
• func ParseMountFlags(mntOptions []string) (string, string)
• type NAS
  • func NewDriver(meta *metadata.Metadata, endpoint, serviceType string) *NAS
  • func (d *NAS) Run()
• type NasMounter
  • func (m *NasMounter) Mount(source string, target string, fstype string, options []string) (err error)
• type Options
• type RoleAuth
• type RunvNasOptions

Constants

const (
	ProtocolType    = "protocolType"
	FileSystemType  = "fileSystemType"
	EncryptType     = "encryptType"
	SnapshotID      = "snapshotID"
	StorageType     = "storageType"
	ZoneID          = "zoneId"
	DESCRIPTION     = "description"
	ZoneIDTag       = "zone-id"
	NetworkType     = "networkType"
	VpcID           = "vpcId"
	VSwitchID       = "vSwitchId"
	AccessGroupName = "accessGroupName"
	RegionID        = "regionId"
	CnHangzhouFin   = "cn-hangzhou-finance"
	DeleteVolume    = "deleteVolume"
	// NASTAGKEY1 tag
	NASTAGKEY1 = "k8s.aliyun.com"
	// NASTAGVALUE1 value
	NASTAGVALUE1 = "true"
	// NASTAGKEY2 key
	NASTAGKEY2 = "createdby"
	// NASTAGVALUE2 value
	NASTAGVALUE2 = "alibabacloud-csi-plugin"
	// NASTAGKEY3 key
	NASTAGKEY3 = "ack.aliyun.com"
	// AddDefaultTagsError means that the add nas default tags error
	AddDefaultTagsError string = "AddDefaultTagsError"
	// LosetupType tag
	LosetupType = "losetup"
	// SkipMountType tag
	SkipMountType = "skipmount"
)

const (
	// NasTempMntPath used for create sub directory
	NasTempMntPath = "/mnt/acs_mnt/k8s_nas/temp"
	// NasPortnum is nas port
	NasPortnum = "2049"
	// NasMntPoint tag
	NasMntPoint = "/mnt/nasplugin.alibabacloud.com"
	// MountProtocolNFS common nfs protocol
	MountProtocolNFS = "nfs"
	// MountProtocolEFC common efc protocol
	MountProtocolEFC = "efc"
	// MountProtocolCPFS common cpfs protocol
	MountProtocolCPFS = "cpfs"
	// MountProtocolCPFSNFS cpfs-nfs protocol
	MountProtocolCPFSNFS = "cpfs-nfs"
	// MountProtocolCPFSNative cpfs-native protocol
	MountProtocolCPFSNative = "cpfs-native"
	// MountProtocolAliNas alinas protocol
	MountProtocolAliNas = "alinas"
	// MountProtocolTag tag
	MountProtocolTag = "mountProtocol"

	//EFCClient
	EFCClient = "efcclient"
	//NFSClient
	NFSClient = "nfsclient"
	//NativeClient
	NativeClient = "nativeclient"
)

const (
	// RegionTag is region id
	RegionTag = "region-id"
	// LoopLockFile lock file for nas loopsetup
	LoopLockFile = "loopsetup.nas.csi.alibabacloud.com.lck"
	// LoopImgFile image file for nas loopsetup
	LoopImgFile = "loopsetup.nas.csi.alibabacloud.com.img"
	// Resize2fsFailedFilename ...
	Resize2fsFailedFilename = "resize2fs_failed.txt"
	// Resize2fsFailedFixCmd ...
	Resize2fsFailedFixCmd = "%s fsck -a %s"
	// GiB bytes
	GiB = 1 << 30
	// see https://help.aliyun.com/zh/nas/modify-the-maximum-number-of-concurrent-nfs-requests
	TcpSlotTableEntries      = "/proc/sys/sunrpc/tcp_slot_table_entries"
	TcpSlotTableEntriesValue = "128\n"
)

Functions

func DetermineClientTypeAndMountProtocol

func DetermineClientTypeAndMountProtocol(cnfs *v1beta1.ContainerNetworkFileSystem, opt *Options) error

func GetFsIDByCpfsServer

func GetFsIDByCpfsServer(server string) string

GetFsIDByCpfsServer func is get fsID from serverName

func GetFsIDByNasServer

func GetFsIDByNasServer(server string) string

GetFsIDByNasServer func is get fsID from serverName

func NewNasMounter

func NewNasMounter() mountutils.Interface

func ParseMountFlags

func ParseMountFlags(mntOptions []string) (string, string)

ParseMountFlags parse mountOptions

Types

type NAS

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

NAS the NAS object

func NewDriver

func NewDriver(meta *metadata.Metadata, endpoint, serviceType string) *NAS

func (*NAS) Run

func (d *NAS) Run()

type NasMounter

type NasMounter struct {
	mountutils.Interface
	// contains filtered or unexported fields
}

func (*NasMounter) Mount

func (m *NasMounter) Mount(source string, target string, fstype string, options []string) (err error)

type Options

type Options struct {
	Server        string `json:"server"`
	Accesspoint   string `json:"accesspoint"`
	Path          string `json:"path"`
	Vers          string `json:"vers"`
	Mode          string `json:"mode"`
	ModeType      string `json:"modeType"`
	Options       string `json:"options"`
	MountType     string `json:"mountType"`
	LoopImageSize int    `json:"loopImageSize"`
	LoopLock      string `json:"loopLock"`
	MountProtocol string `json:"mountProtocol"`
	ClientType    string `json:"clientType"`
	FSType        string `json:"fsType"`
}

Options struct definition

type RoleAuth

type RoleAuth struct {
	AccessKeyID     string
	AccessKeySecret string
	Expiration      time.Time
	SecurityToken   string
	LastUpdated     time.Time
	Code            string
}

RoleAuth define STS Token Response

type RunvNasOptions

type RunvNasOptions struct {
	Server     string `json:"server"`
	Path       string `json:"path"`
	Vers       string `json:"vers"`
	Mode       string `json:"mode"`
	ModeType   string `json:"modeType"`
	Options    string `json:"options"`
	RunTime    string `json:"runtime"`
	MountFile  string `json:"mountfile"`
	VolumeType string `json:"volumeType"`
}

RunvNasOptions struct definition