driver

Mar 20, 2021

Changes in this version

+ var MfsLog bool

+ var SanityTestRun bool

+ func CreateListener(csiEndpoint string) (net.Listener, error)

+ func CreategRPCServer() *grpc.Server

+ func Init(sanityTestRun bool, logLevel int, mfsLog bool) error

+ func NewMfsHandler(mfsmaster, rootPath, pluginDataPath, name string, num ...int) *mfsHandler

+ func StartService(service *Service, mode, csiEndpoint string) error

+ type ControllerService struct

+ func NewControllerService(mfsmaster, rootPath, pluginDataPath string) (*ControllerService, error)

+ func (cs *ControllerService) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (cs *ControllerService) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (cs *ControllerService) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (cs *ControllerService) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (cs *ControllerService) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (cs *ControllerService) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (cs *ControllerService) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type IdentityService struct

+ func (is *IdentityService) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

+ func (is *IdentityService) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

+ func (is *IdentityService) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

+ type Mounter struct

+ func (m *Mounter) IsMounted(destPath string) (bool, error)

+ func (m *Mounter) Mount(sourcePath, destPath, mountType string, opts ...string) error

+ func (m *Mounter) UMount(destPath string) error

+ type MounterInterface interface

+ IsMounted func(destPath string) (bool, error)

+ Mount func(sourcePath string, destPath, mountType string, opts ...string) error

+ UMount func(destPath string) error

+ type NodeService struct

+ func NewNodeService(mfsmaster, rootPath, pluginDataPath, nodeId string, mountPointsCount int) (*NodeService, error)

+ func (ns *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (ns *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (ns *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (ns *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ type Service interface