driver

Apr 9, 2021

Changes in this version

+ const CapacityWeighted

+ const GB

+ const Gi

+ const MB

+ const Mi

+ const VolumeWeighted

+ var SupportedVolumeCapabilityAccessModes = []*csi.VolumeCapability_AccessMode

+ func CreateDeviceVolume(ctx context.Context, req *csi.CreateVolumeRequest, params *VolumeParams) (*apis.DeviceVolume, error)

+ func GetVolAndMountInfo(req *csi.NodePublishVolumeRequest) (*apis.DeviceVolume, *device.MountInfo, error)

+ func GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode

+ func IsSupportedVolumeCapabilityAccessMode(accessMode csi.VolumeCapability_AccessMode_Mode) bool

+ func LabelIndexFunc(label string) cache.IndexFunc

+ func LabelIndexName(label string) string

+ func NewController(d *CSIDriver) csi.ControllerServer

+ func NewIdentity(d *CSIDriver) csi.IdentityServer

+ func NewNode(d *CSIDriver) csi.NodeServer

+ type CSIDriver struct

+ func New(config *config.Config) *CSIDriver

+ func (d *CSIDriver) Run() error

+ type NonBlockingGRPCServer interface

+ ForceStop func()

+ Start func()

+ Stop func()

+ Wait func()

+ func NewNonBlockingGRPCServer(ep string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer) NonBlockingGRPCServer

+ type VolumeParams struct

+ DeviceName string

+ PVCName string

+ PVCNamespace string

+ PVName string

+ Scheduler string

+ Shared string

+ func NewVolumeParams(m map[string]string) (*VolumeParams, error)