driver

Documentation

Index

• Constants
• Variables
• func IsMultipathEnabled() bool
• func NewControllerServer(d *Driver) *controllerServer
• func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewIdentityServer(d *Driver) *identityServer
• func NewNodeServer(d *Driver) *nodeServer
• func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
• func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
• func ParseEndpoint(ep string) (string, string, error)
• func RunControllerandNodePublishServer(endpoint string, d *Driver, cs csi.ControllerServer, ns csi.NodeServer)
• type Device
  • func GetMultipathDevice(devices []Device) (*Device, error)
• type Driver
  • func NewControllerAndNodeDriver(nodeID string, endpoint string, dsmService interfaces.IDsmService) (*Driver, error)
  • func (d *Driver) Activate()
• type IDriver
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const (
	DriverName    = "csi.san.synology.com" // CSI dirver name
	DriverVersion = "1.2.0"
)

const (
	ISCSIPort = 3260
)

Variables

var (
	MultipathEnabled = true
)

Functions

func IsMultipathEnabled

func IsMultipathEnabled() bool

func NewControllerServer

func NewControllerServer(d *Driver) *controllerServer

func NewControllerServiceCapability

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

func NewIdentityServer

func NewIdentityServer(d *Driver) *identityServer

func NewNodeServer

func NewNodeServer(d *Driver) *nodeServer

func NewNodeServiceCapability

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

func NewVolumeCapabilityAccessMode

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

func ParseEndpoint

func ParseEndpoint(ep string) (string, string, error)

func RunControllerandNodePublishServer

func RunControllerandNodePublishServer(endpoint string, d *Driver, cs csi.ControllerServer, ns csi.NodeServer)

Types

type Device

type Device struct {
	Name      string   `json:"name"`
	Hctl      string   `json:"hctl"`
	Children  []Device `json:"children"`
	Type      string   `json:"type"`
	Transport string   `json:"tran"`
	Size      string   `json:"size,omitempty"`
}

Device contains information about a device

func GetMultipathDevice

func GetMultipathDevice(devices []Device) (*Device, error)

returns a multipath device for the configured targets if it exists

type Driver

type Driver struct {
	DsmService interfaces.IDsmService
	// contains filtered or unexported fields
}

func NewControllerAndNodeDriver

func NewControllerAndNodeDriver(nodeID string, endpoint string, dsmService interfaces.IDsmService) (*Driver, error)

func (*Driver) Activate

func (d *Driver) Activate()

type IDriver

type IDriver interface {
	Activate()
}

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