nas

Documentation

Index

• Constants
• Variables
• func CheckNfsPathMounted(mountpoint, server, path string) bool
• func CreateDest(dest string) error
• func DoNfsMount(nfsServer, nfsPath, nfsVers, mountOptions, mountPoint, volumeID string) error
• func GetDefaultAK() (string, string, string)
• func GetLocalAK() (string, string)
• func GetMetaData(resource string) string
• func GetNfsDetails(nfsServersString string) (string, string)
• func GetSTSAK() (string, string, string)
• func GlobalConfigSet()
• func NewControllerServer(d *csicommon.CSIDriver, client *aliNas.Client, region string) csi.ControllerServer
• func ParseMountFlags(mntOptions []string) (string, string)
• func SetNasEndPoint(regionID string)
• type GlobalConfig
• type NAS
  • func NewDriver(nodeID, endpoint string) *NAS
  • func (d *NAS) Run()
• type Options
• type RoleAuth

Constants

const (
	MNTROOTPATH     = "/csi-persistentvolumes"
	MBSize          = 1024 * 1024
	DRIVER          = "driver"
	SERVER          = "server"
	MODE            = "mode"
	ModeType        = "modeType"
	VolumeAs        = "volumeAs"
	PATH            = "path"
	ProtocolType    = "protocolType"
	StorageType     = "storageType"
	ZoneID          = "zoneId"
	DESCRIPTION     = "description"
	ZoneIDTag       = "zone-id"
	NetworkType     = "networkType"
	VpcID           = "vpcId"
	VSwitchID       = "vSwitchId"
	AccessGroupName = "accessGroupName"
	DeleteVolume    = "deleteVolume"
)

resourcemode is selected by: subpath/filesystem

const (
	// NasTempMntPath used for create sub directory
	NasTempMntPath = "/mnt/acs_mnt/k8s_nas/temp"
	// NasPortnum is nas port
	NasPortnum = "2049"
	// NasMetricByPlugin tag
	NasMetricByPlugin = "NAS_METRIC_BY_PLUGIN"
)

const (
	// MetadataURL is metadata url
	MetadataURL = "http://100.100.100.200/latest/meta-data/"
	// RegionTag is region id
	RegionTag = "region-id"
)

const (

	// InstanceID is instance id
	InstanceID = "instance-id"
)

Variables

var (
	// VERSION should be updated by hand at each release
	VERSION = "v1.14.8"
	// GITCOMMIT will be overwritten automatically by the build system
	GITCOMMIT = "HEAD"
	// KubernetesAlicloudIdentity is the system identity for ecs client request
	KubernetesAlicloudIdentity = fmt.Sprintf("Kubernetes.Alicloud/CsiProvision.Nas-%s", VERSION)
)

Functions

func CheckNfsPathMounted

func CheckNfsPathMounted(mountpoint, server, path string) bool

CheckNfsPathMounted check whether the given nfs path was mounted

func CreateDest

func CreateDest(dest string) error

CreateDest create the target

func DoNfsMount

func DoNfsMount(nfsServer, nfsPath, nfsVers, mountOptions, mountPoint, volumeID string) error

DoNfsMount execute the mount command for nas dir

func GetDefaultAK

func GetDefaultAK() (string, string, string)

GetDefaultAK read default ak from local file or from STS

func GetLocalAK

func GetLocalAK() (string, string)

GetLocalAK return if ak meta defined in env

func GetMetaData

func GetMetaData(resource string) string

GetMetaData get host regionid, zoneid

func GetNfsDetails

func GetNfsDetails(nfsServersString string) (string, string)

GetNfsDetails get nfs server's details

func GetSTSAK

func GetSTSAK() (string, string, string)

GetSTSAK get STS AK and token from ecs meta server

func GlobalConfigSet

func GlobalConfigSet()

GlobalConfigSet set global config

func NewControllerServer

func NewControllerServer(d *csicommon.CSIDriver, client *aliNas.Client, region string) csi.ControllerServer

NewControllerServer is to create controller server

func ParseMountFlags

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

ParseMountFlags parse mountOptions

func SetNasEndPoint

func SetNasEndPoint(regionID string)

SetNasEndPoint Set Endpoint for Nas

Types

type GlobalConfig

type GlobalConfig struct {
	Region             string
	NasTagEnable       bool
	ADControllerEnable bool
	MetricEnable       bool
}

GlobalConfig save global values for plugin

var (

	// GlobalConfigVar Global Config
	GlobalConfigVar GlobalConfig
)

type NAS

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

NAS the NAS object

func NewDriver

func NewDriver(nodeID, endpoint string) *NAS

NewDriver create the identity/node/controller server and disk driver

func (*NAS) Run

func (d *NAS) Run()

Run start a new NodeServer

type Options

type Options 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"`
}

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