scale

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2019 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PluginFolder = "/var/lib/kubelet/plugins/ibm-spectrum-scale-csi"
)

PluginFolder defines the location of scaleplugin

Variables

This section is empty.

Functions

func ConvertToBytes

func ConvertToBytes(inputStr string) (uint64, error)

Types

type NonBlockingGRPCServer

type NonBlockingGRPCServer interface {
	// Start services at the endpoint
	Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
	// Waits for the service to stop
	Wait()
	// Stops the service gracefully
	Stop()
	// Stops the service forcefully
	ForceStop()
}

Defines Non blocking GRPC server interfaces

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer

type ScaleControllerServer

type ScaleControllerServer struct {
	Driver *ScaleDriver
}

func (*ScaleControllerServer) Cleanup

func (cs *ScaleControllerServer) Cleanup(scVol *scaleVolume) error

func (*ScaleControllerServer) ControllerExpandVolume

func (*ScaleControllerServer) ControllerGetCapabilities

ControllerGetCapabilities implements the default GRPC callout.

func (*ScaleControllerServer) ControllerPublishVolume

func (*ScaleControllerServer) ControllerUnpublishVolume

func (*ScaleControllerServer) CreateFilesetBasedVol

func (cs *ScaleControllerServer) CreateFilesetBasedVol(scVol *scaleVolume) (string, error)

func (*ScaleControllerServer) CreateLWVol

func (cs *ScaleControllerServer) CreateLWVol(scVol *scaleVolume) error

func (*ScaleControllerServer) CreateSnapshot

func (*ScaleControllerServer) CreateVolume

func (*ScaleControllerServer) DeleteSnapshot

func (*ScaleControllerServer) DeleteVolume

func (*ScaleControllerServer) GenerateVolId

func (cs *ScaleControllerServer) GenerateVolId(scVol *scaleVolume) (string, error)

func (*ScaleControllerServer) GetCapacity

func (*ScaleControllerServer) GetConnFromClusterID

func (cs *ScaleControllerServer) GetConnFromClusterID(cid string) (connectors.SpectrumScaleConnector, error)

func (*ScaleControllerServer) GetFsMntPt added in v1.0.0

func (cs *ScaleControllerServer) GetFsMntPt(scVol *scaleVolume) (string, error)

func (*ScaleControllerServer) GetFsetLnkPath added in v1.0.0

func (cs *ScaleControllerServer) GetFsetLnkPath(scaleVol *scaleVolume) (string, error)

func (*ScaleControllerServer) GetPriConnAndSLnkPath

func (*ScaleControllerServer) GetTargetPathforFset added in v1.0.0

func (cs *ScaleControllerServer) GetTargetPathforFset(scVol *scaleVolume) (string, error)

func (*ScaleControllerServer) GetVolIdMembers

func (cs *ScaleControllerServer) GetVolIdMembers(vId string) (scaleVolId, error)

func (*ScaleControllerServer) GetVolumeSizeInBytes

func (cs *ScaleControllerServer) GetVolumeSizeInBytes(req *csi.CreateVolumeRequest) (int64, error)

func (*ScaleControllerServer) IfFileSetBasedVolExist

func (cs *ScaleControllerServer) IfFileSetBasedVolExist(scVol *scaleVolume) (bool, error)

func (*ScaleControllerServer) IfLwVolExist

func (cs *ScaleControllerServer) IfLwVolExist(scVol *scaleVolume) (bool, error)

func (*ScaleControllerServer) IfSameVolReqInProcess

func (cs *ScaleControllerServer) IfSameVolReqInProcess(scVol *scaleVolume) (bool, error)

func (*ScaleControllerServer) ListSnapshots

func (*ScaleControllerServer) ListVolumes

func (*ScaleControllerServer) ValidateVolumeCapabilities

type ScaleDriver

type ScaleDriver struct {
	// contains filtered or unexported fields
}

func GetScaleDriver

func GetScaleDriver() *ScaleDriver

func (*ScaleDriver) AddControllerServiceCapabilities

func (driver *ScaleDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type) error

func (*ScaleDriver) AddNodeServiceCapabilities

func (driver *ScaleDriver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type) error

func (*ScaleDriver) AddVolumeCapabilityAccessModes

func (driver *ScaleDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) error

func (*ScaleDriver) CreatePrimaryFileset

func (driver *ScaleDriver) CreatePrimaryFileset(sc connectors.SpectrumScaleConnector, primaryFS string, fsmount string, filesetName string, inodeLimit string) (string, error)

func (*ScaleDriver) CreateSymlinkPath

func (driver *ScaleDriver) CreateSymlinkPath(sc connectors.SpectrumScaleConnector, fs string, fsmount string, fsetlinkpath string) (string, string, error)

func (*ScaleDriver) Run

func (driver *ScaleDriver) Run(endpoint string)

func (*ScaleDriver) SetupScaleDriver

func (driver *ScaleDriver) SetupScaleDriver(name, vendorVersion, nodeID string, mounter *mount.SafeFormatAndMount) error

func (*ScaleDriver) ValidateControllerServiceRequest

func (driver *ScaleDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

func (*ScaleDriver) ValidateHostpath

func (driver *ScaleDriver) ValidateHostpath(mountpath string, linkpath string) error

func (*ScaleDriver) ValidateScaleConfigParameters

func (driver *ScaleDriver) ValidateScaleConfigParameters(scaleConfig settings.ScaleSettingsConfigMap) (bool, error)

type ScaleIdentityServer

type ScaleIdentityServer struct {
	Driver *ScaleDriver
}

func NewIdentityServer

func NewIdentityServer(d *ScaleDriver) *ScaleIdentityServer

func (*ScaleIdentityServer) GetPluginCapabilities

func (*ScaleIdentityServer) GetPluginInfo

func (*ScaleIdentityServer) Probe

type ScaleNodeServer

type ScaleNodeServer struct {
	Driver  *ScaleDriver
	Mounter *mount.SafeFormatAndMount
	// contains filtered or unexported fields
}

func NewNodeServer

func NewNodeServer(d *ScaleDriver, mounter *mount.SafeFormatAndMount) *ScaleNodeServer

func (*ScaleNodeServer) NodeExpandVolume

func (*ScaleNodeServer) NodeGetCapabilities

func (*ScaleNodeServer) NodeGetInfo

func (*ScaleNodeServer) NodeGetVolumeStats

func (*ScaleNodeServer) NodePublishVolume

func (*ScaleNodeServer) NodeStageVolume

func (*ScaleNodeServer) NodeUnpublishVolume

func (*ScaleNodeServer) NodeUnstageVolume

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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