driver

package

v0.9.4 Latest Latest Go to latest Published: Mar 6, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/moosefs/moosefs-csi

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CreateListener(csiEndpoint string) (net.Listener, error)
func CreategRPCServer() *grpc.Server
func Init(sanityTestRun bool, logLevel int, mfsLog bool) error
func NewMfsHandler(mfsmaster string, mfsmaster_port int, rootPath, pluginDataPath, name string, ...) *mfsHandler
func StartService(service *Service, mode, csiEndpoint string) error
type ControllerService
- func NewControllerService(mfsmaster string, mfsmaster_port int, rootPath, pluginDataPath string) (*ControllerService, error)
type IdentityService
type Mounter
type MounterInterface
type NodeService
- func NewNodeService(mfsmaster string, mfsmaster_port int, rootPath, pluginDataPath, nodeId string, ...) (*NodeService, error)
type Service

Constants ¶

This section is empty.

Variables ¶

View Source

var MfsLog bool

View Source

var SanityTestRun bool

Functions ¶

func CreateListener ¶

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

CreateListener create listener ready for communication over given csi endpoint

func CreategRPCServer ¶

func CreategRPCServer() *grpc.Server

func Init ¶

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

func NewMfsHandler ¶

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

func StartService ¶

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

Types ¶

type ControllerService ¶

type ControllerService struct {
	//	csi.UnimplementedControllerServer
	csi.ControllerServer
	Service
	// contains filtered or unexported fields
}

func NewControllerService ¶

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

func (*ControllerService) ControllerExpandVolume ¶

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

func (*ControllerService) ControllerGetCapabilities ¶

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

func (*ControllerService) ControllerPublishVolume ¶

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

func (*ControllerService) ControllerUnpublishVolume ¶

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

func (*ControllerService) CreateVolume ¶

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

CreateVolume creates a new volume from the given request. The function is idempotent.

func (*ControllerService) DeleteVolume ¶

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

func (*ControllerService) ValidateVolumeCapabilities ¶

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

type IdentityService ¶

type IdentityService struct {
	csi.UnimplementedIdentityServer
	Service
}

func (*IdentityService) GetPluginCapabilities ¶

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

func (*IdentityService) GetPluginInfo ¶

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

func (*IdentityService) Probe ¶

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

type Mounter ¶

type Mounter struct {
	MounterInterface
}

func (*Mounter) IsMounted ¶

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

func (*Mounter) Mount ¶

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

func (*Mounter) UMount ¶

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

type MounterInterface ¶

type MounterInterface interface {
	// Mount a volume
	Mount(sourcePath string, destPath, mountType string, opts ...string) error

	// Unmount a volume
	UMount(destPath string) error

	// Verify mount
	IsMounted(destPath string) (bool, error)
}

type NodeService ¶

type NodeService struct {
	csi.UnimplementedNodeServer
	Service
	// contains filtered or unexported fields
}

func NewNodeService ¶

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

func (*NodeService) NodeGetCapabilities ¶

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

func (*NodeService) NodeGetInfo ¶

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

func (*NodeService) NodePublishVolume ¶

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

func (*NodeService) NodeUnpublishVolume ¶

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

type Service ¶

type Service interface{}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL