blockstorage

Documentation

Index

• Constants
• Variables
• func DetermineMaxVolumesByFlavor(flavor string) int64
• func NewControllerServer(d *Driver, instance stackit.IaasClient) *controllerServer
• func NewControllerServiceCapability(rpcType csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewIdentityServer(d *Driver) *identityServer
• func NewNodeServer(d *Driver, mountProvider mount.IMount, metadataProvider metadata.IMetadata, ...) *nodeServer
• func NewNodeServiceCapability(rpcType csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability
• func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
• func ParseEndpoint(ep string) (proto, addr string, err error)
• func RunServicesInitialized(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)
• type Driver
  • func NewDriver(o *DriverOpts) *Driver
  • func (d *Driver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *Driver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type) error
  • func (d *Driver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *Driver) Run()
  • func (d *Driver) SetupControllerService(instance stackit.IaasClient)
  • func (d *Driver) SetupNodeService(mountProvider mount.IMount, metadataProvider metadata.IMetadata, ...)
• type DriverOpts
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const (

	// ResizeRequired parameter, if set to true, will trigger a resize on mount operation
	ResizeRequired = driverName + "/resizeRequired"
)

Variables

var (
	Version = "1.0.0"
)

Functions

func DetermineMaxVolumesByFlavor

func DetermineMaxVolumesByFlavor(flavor string) int64

func NewControllerServer

func NewControllerServer(d *Driver, instance stackit.IaasClient) *controllerServer

func NewControllerServiceCapability

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

func NewIdentityServer

func NewIdentityServer(d *Driver) *identityServer

func NewNodeServer

func NewNodeServer(d *Driver, mountProvider mount.IMount, metadataProvider metadata.IMetadata, opts stackitconfig.BlockStorageOpts) *nodeServer

func NewNodeServiceCapability

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

func NewVolumeCapabilityAccessMode

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

func ParseEndpoint

func ParseEndpoint(ep string) (proto, addr string, err error)

func RunServicesInitialized

func RunServicesInitialized(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

Types

type Driver

type Driver struct {
	csi.UnimplementedNodeServer
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(o *DriverOpts) *Driver

func (*Driver) AddControllerServiceCapabilities

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

func (*Driver) AddNodeServiceCapabilities

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

func (*Driver) AddVolumeCapabilityAccessModes

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

func (*Driver) Run

func (d *Driver) Run()

func (*Driver) SetupControllerService

func (d *Driver) SetupControllerService(instance stackit.IaasClient)

func (*Driver) SetupNodeService

func (d *Driver) SetupNodeService(mountProvider mount.IMount, metadataProvider metadata.IMetadata, opts stackitconfig.BlockStorageOpts)

type DriverOpts

type DriverOpts struct {
	ClusterID string
	Endpoint  string

	PVCLister corev1.PersistentVolumeClaimLister
}

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