driver

package
v0.9.2-dev Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 29, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Copyright 2019 Tuxera Oy. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.