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)

func NewControllerServiceCapability 

func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability

func NewNodeServiceCapability 

func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

func NewVolumeCapabilityAccessMode 

func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode

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 NewControllerServer 

func NewControllerServer(d *ScaleDriver, connMap map[string]connectors.SpectrumScaleConnector, cmap settings.ScaleSettingsConfigMap, primary settings.Primary) *ScaleControllerServer

func (*ScaleControllerServer) Cleanup 

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

func (*ScaleControllerServer) ControllerExpandVolume 

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

func (*ScaleControllerServer) ControllerGetCapabilities 

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

ControllerGetCapabilities implements the default GRPC callout.

func (*ScaleControllerServer) ControllerPublishVolume 

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

func (*ScaleControllerServer) ControllerUnpublishVolume 

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

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 (cs *ScaleControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*ScaleControllerServer) CreateVolume 

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

func (*ScaleControllerServer) DeleteSnapshot 

func (cs *ScaleControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*ScaleControllerServer) DeleteVolume 

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

func (*ScaleControllerServer) GenerateVolId 

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

func (*ScaleControllerServer) GetCapacity 

func (cs *ScaleControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

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 (cs *ScaleControllerServer) GetPriConnAndSLnkPath() (connectors.SpectrumScaleConnector, string, string, string, string, string, error)

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 (cs *ScaleControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*ScaleControllerServer) ListVolumes 

func (cs *ScaleControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*ScaleControllerServer) ValidateVolumeCapabilities 

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

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) PluginInitialize 

func (driver *ScaleDriver) PluginInitialize() (map[string]connectors.SpectrumScaleConnector, settings.ScaleSettingsConfigMap, settings.Primary, 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 (is *ScaleIdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

func (*ScaleIdentityServer) GetPluginInfo 

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

func (*ScaleIdentityServer) Probe 

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

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 (ns *ScaleNodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*ScaleNodeServer) NodeGetCapabilities 

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

func (*ScaleNodeServer) NodeGetInfo 

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

func (*ScaleNodeServer) NodeGetVolumeStats 

func (ns *ScaleNodeServer) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*ScaleNodeServer) NodePublishVolume 

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

func (*ScaleNodeServer) NodeStageVolume 

func (ns *ScaleNodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (
	*csi.NodeStageVolumeResponse, error)

func (*ScaleNodeServer) NodeUnpublishVolume 

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

func (*ScaleNodeServer) NodeUnstageVolume 

func (ns *ScaleNodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (
	*csi.NodeUnstageVolumeResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.