services

Documentation

Index

• Constants
• Variables
• func CSIToYCName(volumeName string) string
• func CheckVolumeAccessType(volCap *csi.VolumeCapability) error
• func NodeStageRO(ctx map[string]string) bool
• func ROPublishContext(ro bool) map[string]string
• func VerifyVolumeCapabilities(volCaps []*csi.VolumeCapability, volumeCaps []*csi.VolumeCapability_AccessMode) error

Constants

const (
	VolumeTypeKey     = "type"
	DefaultVolumeType = "network-hdd"

	// MinDiskSizeBytes is a compute API limitation.
	MinDiskSizeBytes     = 4 * 1024 * 1024
	ZoneKey              = "failure-domain.beta.kubernetes.io/zone"
	DefaultDiskSizeBytes = 4 * 1024 * 1024 * 1024
	FsTypeExt4           = "ext4"
	FsTypeExt3           = "ext3"
	DefaultFsType        = FsTypeExt4

	DevicePathPrefix = "/dev/disk/by-id/virtio"
	DriverName       = "disk-csi-driver.mks.ycloud.io"

	DiskPlacementGroupIDKey        = "diskPlacementGroupId"
	DiskPlacementGroupPartitionKey = "diskPlacementGroupPartition"
)

const MultiNodeReaderOnlyPublishFlag = "MULTI_NODE_READER_ONLY"

const MultiNodeReaderOnlyPublishFlagValue = "true"

Variables

var (
	// VolumeCaps represents how the volume could be accessed.
	VolumeCaps = []*csi.VolumeCapability_AccessMode{
		{
			Mode: csi.VolumeCapability_AccessMode_SINGLE_NODE_WRITER,
		},
		{
			Mode: csi.VolumeCapability_AccessMode_MULTI_NODE_READER_ONLY,
		},
	}

	// ProductionCapsForPublicAPIController represents the capability of controller service over public api.
	ProductionCapsForPublicAPIController = []*csi.ControllerServiceCapability{
		{
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME,
				},
			},
		}, {
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_PUBLISH_UNPUBLISH_VOLUME,
				},
			},
		}, {
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_EXPAND_VOLUME,
				},
			},
		},
		{
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_PUBLISH_READONLY,
				},
			},
		},
	}

	ProductionNodeCaps = []*csi.NodeServiceCapability{
		{
			Type: &csi.NodeServiceCapability_Rpc{
				Rpc: &csi.NodeServiceCapability_RPC{
					Type: csi.NodeServiceCapability_RPC_STAGE_UNSTAGE_VOLUME,
				},
			},
		}, {
			Type: &csi.NodeServiceCapability_Rpc{
				Rpc: &csi.NodeServiceCapability_RPC{
					Type: csi.NodeServiceCapability_RPC_GET_VOLUME_STATS,
				},
			},
		}, {
			Type: &csi.NodeServiceCapability_Rpc{
				Rpc: &csi.NodeServiceCapability_RPC{
					Type: csi.NodeServiceCapability_RPC_EXPAND_VOLUME,
				},
			},
		},
	}

	SanityControllerCaps = []*csi.ControllerServiceCapability{
		{
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME,
				},
			},
		}, {
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_PUBLISH_UNPUBLISH_VOLUME,
				},
			},
		}, {
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_LIST_SNAPSHOTS,
				},
			},
		}, {
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_CREATE_DELETE_SNAPSHOT,
				},
			},
		},
		{
			Type: &csi.ControllerServiceCapability_Rpc{
				Rpc: &csi.ControllerServiceCapability_RPC{
					Type: csi.ControllerServiceCapability_RPC_PUBLISH_READONLY,
				},
			},
		},
	}

	SanityNodeCaps = []*csi.NodeServiceCapability{
		{
			Type: &csi.NodeServiceCapability_Rpc{
				Rpc: &csi.NodeServiceCapability_RPC{
					Type: csi.NodeServiceCapability_RPC_STAGE_UNSTAGE_VOLUME,
				},
			},
		},
	}

	ProductionPluginCapabilities = []*csi.PluginCapability{
		{
			Type: &csi.PluginCapability_Service_{
				Service: &csi.PluginCapability_Service{
					Type: csi.PluginCapability_Service_CONTROLLER_SERVICE,
				},
			},
		},
		{
			Type: &csi.PluginCapability_Service_{
				Service: &csi.PluginCapability_Service{
					Type: csi.PluginCapability_Service_VOLUME_ACCESSIBILITY_CONSTRAINTS,
				},
			},
		},
		{
			Type: &csi.PluginCapability_VolumeExpansion_{
				VolumeExpansion: &csi.PluginCapability_VolumeExpansion{
					Type: csi.PluginCapability_VolumeExpansion_OFFLINE,
				},
			},
		},
	}

	SanityPluginCapabilities = []*csi.PluginCapability{
		{
			Type: &csi.PluginCapability_Service_{
				Service: &csi.PluginCapability_Service{
					Type: csi.PluginCapability_Service_CONTROLLER_SERVICE,
				},
			},
		},
		{
			Type: &csi.PluginCapability_Service_{
				Service: &csi.PluginCapability_Service{
					Type: csi.PluginCapability_Service_VOLUME_ACCESSIBILITY_CONSTRAINTS,
				},
			},
		},
	}
)

Functions

func CSIToYCName

func CSIToYCName(volumeName string) string

func CheckVolumeAccessType

func CheckVolumeAccessType(volCap *csi.VolumeCapability) error

func NodeStageRO

func NodeStageRO(ctx map[string]string) bool

func ROPublishContext

func ROPublishContext(ro bool) map[string]string

func VerifyVolumeCapabilities

func VerifyVolumeCapabilities(volCaps []*csi.VolumeCapability, volumeCaps []*csi.VolumeCapability_AccessMode) error