csi

Documentation

Index

• Constants
• func GetNodeIP(client kubernetes.Interface, nodeID string) (net.IP, error)
• func IsBlockDevice(fullPath string) (bool, error)
• type CSIPlugin
  • func NewDriver(driverName, nodeID, endpoint string, grpcConnectionTimeout int) *CSIPlugin
  • func (plugin *CSIPlugin) Run()

Constants

const (
	// VolumeTypeKey volume type key words
	VolumeTypeKey = "volumeType"
	// LvmVolumeType lvm volume type
	LvmVolumeType = "LVM"
	// MountPointType type
	MountPointType = "MountPoint"
	// DeviceVolumeType type
	DeviceVolumeType = "Device"
	// PvcNameTag in annotations
	PvcNameTag = "csi.storage.k8s.io/pvc/name"
	// PvcNsTag in annotations
	PvcNsTag = "csi.storage.k8s.io/pvc/namespace"
	// NodeSchedueTag in annotations
	NodeSchedueTag = "volume.kubernetes.io/selected-node"
	// StorageSchedueTag in annotations
	StorageSchedueTag = "volume.kubernetes.io/selected-storage"
	// LastAppliyAnnotationTag tag
	LastAppliyAnnotationTag = "kubectl.kubernetes.io/last-applied-configuration"
	// CsiProvisionerIdentity tag
	CsiProvisionerIdentity = "storage.kubernetes.io/csiProvisionerIdentity"
	// CsiProvisionerTag tag
	CsiProvisionerTag = "volume.beta.kubernetes.io/storage-provisioner"
	// StripingType striping type
	StripingType = "striping"
	// connection timeout
	DefaultConnectTimeout = 3

	// TopologyNodeKey define host name of node
	TopologyNodeKey = "kubernetes.io/hostname"
	// TopologyYodaNodeKey define host name of node
	TopologyYodaNodeKey = "topology.yodaplugin.csi.alibabacloud.com/hostname"
)

const (
	// VgNameTag is the vg name tag
	VgNameTag = "vgName"
	// VolumeTypeTag is the pv type tag
	VolumeTypeTag = "volumeType"
	// PvTypeTag is the pv type tag
	PvTypeTag = "pvType"
	// FsTypeTag is the fs type tag
	FsTypeTag = "fsType"
	// LvmTypeTag is the lvm type tag
	LvmTypeTag = "lvmType"
	// NodeAffinity is the pv node schedule tag
	NodeAffinity = "nodeAffinity"
	// DefaultFs default fs
	DefaultFs = "ext4"
	// DefaultNodeAffinity default NodeAffinity
	DefaultNodeAffinity = "true"
	// LinearType linear type
	LinearType = "linear"
)

const (
	DefaultEndpoint   string = "unix://tmp/csi.sock"
	DefaultDriverName string = "local.csi.aliyun.com"
)

Functions

func GetNodeIP

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

GetNodeIP get node address

func IsBlockDevice

func IsBlockDevice(fullPath string) (bool, error)

IsBlockDevice checks if the given path is a block device

Types

type CSIPlugin

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

func NewDriver

func NewDriver(driverName, nodeID, endpoint string, grpcConnectionTimeout int) *CSIPlugin

func (*CSIPlugin) Run

func (plugin *CSIPlugin) Run()