driver

package
v1.1.3 Latest Latest
Warning

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

Go to latest
Published: Nov 8, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DriverName    = "csi.san.synology.com" // CSI dirver name
	DriverVersion = "1.1.3"
)
View Source
const (
	ISCSIPort = 3260
)

Variables

View Source
var (
	MultipathEnabled = true
)

Functions

func IsMultipathEnabled added in v1.1.1

func IsMultipathEnabled() bool

func NewControllerServer

func NewControllerServer(d *Driver) *controllerServer

func NewIdentityServer

func NewIdentityServer(d *Driver) *identityServer

func NewNodeServer

func NewNodeServer(d *Driver) *nodeServer

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 added in v1.1.1

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 added in v1.1.1

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

Jump to

Keyboard shortcuts

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