driver

Documentation

Index

• func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
• func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
• type GCFSDriver
  • func NewGCFSDriver(config *GCFSDriverConfig) (*GCFSDriver, error)
  • func (driver *GCFSDriver) Run(endpoint string)
  • func (driver *GCFSDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error
• type GCFSDriverConfig
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Functions

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 GCFSDriver

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

func NewGCFSDriver

func NewGCFSDriver(config *GCFSDriverConfig) (*GCFSDriver, error)

func (*GCFSDriver) Run

func (driver *GCFSDriver) Run(endpoint string)

func (*GCFSDriver) ValidateControllerServiceRequest

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

type GCFSDriverConfig

type GCFSDriverConfig struct {
	Name          string          // Driver name
	Version       string          // Driver version
	NodeID        string          // Node name
	RunController bool            // Run CSI controller service
	RunNode       bool            // Run CSI node service
	Mounter       mount.Interface // Mount library
	Cloud         *cloud.Cloud    // Cloud provider
}

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