sfs

Documentation

Index

• func Mount(source, target, mountOptions string) error
• func Run(cmd string) (string, error)
• func Unmount(target string) error
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer
• type SfsDriver
  • func NewDriver(nodeID, endpoint, shareProto string, cloud config.CloudCredentials) *SfsDriver
  • func (d *SfsDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *SfsDriver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type)
  • func (d *SfsDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *SfsDriver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode
  • func (d *SfsDriver) Run()
  • func (d *SfsDriver) SetupDriver(mount mounts.IMount)
  • func (d *SfsDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

Functions

func Mount

func Mount(source, target, mountOptions string) error

func Run

func Run(cmd string) (string, error)

func Unmount

func Unmount(target string) 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()
}

NonBlockingGRPCServer defines Non blocking GRPC server interfaces

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer

type SfsDriver

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

func NewDriver

func NewDriver(nodeID, endpoint, shareProto string, cloud config.CloudCredentials) *SfsDriver

func (*SfsDriver) AddControllerServiceCapabilities

func (d *SfsDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)

func (*SfsDriver) AddNodeServiceCapabilities

func (d *SfsDriver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type)

func (*SfsDriver) AddVolumeCapabilityAccessModes

func (d *SfsDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode

func (*SfsDriver) GetVolumeCapabilityAccessModes

func (d *SfsDriver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode

func (*SfsDriver) Run

func (d *SfsDriver) Run()

func (*SfsDriver) SetupDriver

func (d *SfsDriver) SetupDriver(mount mounts.IMount)

func (*SfsDriver) ValidateControllerServiceRequest

func (d *SfsDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error