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 ¶
View Source
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
View Source
const ( VolumeSnapshotNamespaceKey = "csi.storage.k8s.io/volumesnapshot/namespace" VolumeSnapshotNameKey = "csi.storage.k8s.io/volumesnapshot/name" )
constants of keys in volume snapshot parameters
View Source
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" )
View Source
const ( VolumeSnapshotNameTag = "csi.alibabacloud.com/snapshot/name" VolumeSnapshotNamespaceTag = "csi.alibabacloud.com/snapshot/namespace" )
Tags that will be added to ECS snapshots
Variables ¶
This section is empty.
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)
Click to show internal directories.
Click to hide internal directories.