common

Documentation

Index

• Constants
• func RunCSIServer(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)
• func WrapControllerServerWithValidator(server csi.ControllerServer) csi.ControllerServer
• func WrapNodeServerWithValidator(server csi.NodeServer) csi.NodeServer
• type ControllerServerWithValidator
  • func (cs *ControllerServerWithValidator) ControllerExpandVolume(context context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
  • func (cs *ControllerServerWithValidator) ControllerPublishVolume(context context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)
  • func (cs *ControllerServerWithValidator) ControllerUnpublishVolume(context context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)
  • func (cs *ControllerServerWithValidator) CreateSnapshot(context context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)
  • func (cs *ControllerServerWithValidator) CreateVolume(context context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
  • func (cs *ControllerServerWithValidator) DeleteSnapshot(context context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)
  • func (cs *ControllerServerWithValidator) DeleteVolume(context context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)
  • func (cs *ControllerServerWithValidator) ValidateVolumeCapabilities(context context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)
• type NodeServerWithValidator
  • func (s *NodeServerWithValidator) NodeExpandVolume(context context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (s *NodeServerWithValidator) NodeGetVolumeStats(context context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (s *NodeServerWithValidator) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (s *NodeServerWithValidator) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (s *NodeServerWithValidator) NodeUnpublishVolume(context context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (s *NodeServerWithValidator) NodeUnstageVolume(context context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

Constants

const (
	// PVCNameKey contains name of the PVC for which is a volume provisioned.
	PVCNameKey = "csi.storage.k8s.io/pvc/name"

	// PVCNamespaceKey contains namespace of the PVC for which is a volume provisioned.
	PVCNamespaceKey = "csi.storage.k8s.io/pvc/namespace"

	// PVNameKey contains name of the final PV that will be used for the dynamically
	// provisioned volume
	PVNameKey = "csi.storage.k8s.io/pv/name"
)

constants of keys in volume parameters

const (
	VolumeSnapshotNamespaceKey = "csi.storage.k8s.io/volumesnapshot/namespace"
	VolumeSnapshotNameKey      = "csi.storage.k8s.io/volumesnapshot/name"
)

constants of keys in volume snapshot parameters

const (
	// PVCNameTag is tag applied to provisioned alibaba cloud disk for compatibility
	// with in-tree volume plugin. Value of the tag is PVC name. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVCNameTag = "kubernetes.io/created-for/pvc/name"

	// PVCNamespaceTag is tag applied to provisioned alibaba cloud disk for compatibility
	// with in-tree volume plugin. Value of the tag is PVC namespace. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVCNamespaceTag = "kubernetes.io/created-for/pvc/namespace"

	// PVNameTag is tag applied to provisioned alibaba cloud disk for compatibility
	// with in-tree volume plugin. Value of the tag is PV name. It is applied only when
	// the external provisioner sidecar is started with --extra-create-metadata=true and
	// thus provides such metadata to the CSI driver.
	PVNameTag = "kubernetes.io/created-for/pv/name"

	// VolumeNameTag is tag applied to provisioned alibaba cloud disk
	// Disk name have many restrictions, so we use this tag to store the original name
	VolumeNameTag = "csi.alibabacloud.com/volume-name"
)

const (
	VolumeSnapshotNameTag      = "csi.alibabacloud.com/snapshot/name"
	VolumeSnapshotNamespaceTag = "csi.alibabacloud.com/snapshot/namespace"
)

Tags that will be added to ECS snapshots

Functions

func RunCSIServer

func RunCSIServer(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

func WrapControllerServerWithValidator

func WrapControllerServerWithValidator(server csi.ControllerServer) csi.ControllerServer

func WrapNodeServerWithValidator

func WrapNodeServerWithValidator(server csi.NodeServer) csi.NodeServer

Types

type ControllerServerWithValidator

type ControllerServerWithValidator struct {
	csi.ControllerServer
}

func (*ControllerServerWithValidator) ControllerExpandVolume

func (cs *ControllerServerWithValidator) ControllerExpandVolume(context context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*ControllerServerWithValidator) ControllerPublishVolume

func (cs *ControllerServerWithValidator) ControllerPublishVolume(context context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*ControllerServerWithValidator) ControllerUnpublishVolume

func (cs *ControllerServerWithValidator) ControllerUnpublishVolume(context context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*ControllerServerWithValidator) CreateSnapshot

func (cs *ControllerServerWithValidator) CreateSnapshot(context context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*ControllerServerWithValidator) CreateVolume

func (cs *ControllerServerWithValidator) CreateVolume(context context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*ControllerServerWithValidator) DeleteSnapshot

func (cs *ControllerServerWithValidator) DeleteSnapshot(context context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*ControllerServerWithValidator) DeleteVolume

func (cs *ControllerServerWithValidator) DeleteVolume(context context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*ControllerServerWithValidator) ValidateVolumeCapabilities

func (cs *ControllerServerWithValidator) ValidateVolumeCapabilities(context context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type NodeServerWithValidator

type NodeServerWithValidator struct {
	csi.NodeServer
}

func (*NodeServerWithValidator) NodeExpandVolume

func (s *NodeServerWithValidator) NodeExpandVolume(context context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*NodeServerWithValidator) NodeGetVolumeStats

func (s *NodeServerWithValidator) NodeGetVolumeStats(context context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*NodeServerWithValidator) NodePublishVolume

func (s *NodeServerWithValidator) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*NodeServerWithValidator) NodeStageVolume

func (s *NodeServerWithValidator) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*NodeServerWithValidator) NodeUnpublishVolume

func (s *NodeServerWithValidator) NodeUnpublishVolume(context context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*NodeServerWithValidator) NodeUnstageVolume

func (s *NodeServerWithValidator) NodeUnstageVolume(context context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)