cinder

Documentation

Index

• Constants
• Variables
• func NewControllerServer(d *CinderDriver, cloud openstack.IOpenStack) *controllerServer
• func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewIdentityServer(d *CinderDriver) *identityServer
• func NewNodeServer(d *CinderDriver, mount mount.IMount, metadata metadata.IMetadata, ...) *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, ids csi.IdentityServer, cs csi.ControllerServer, ...)
• type CinderDriver
  • func NewDriver(endpoint, cluster string) *CinderDriver
  • func (d *CinderDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *CinderDriver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type) error
  • func (d *CinderDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *CinderDriver) GetVolumeCapabilityAccessModes() []*csi.VolumeCapability_AccessMode
  • func (d *CinderDriver) Run()
  • func (d *CinderDriver) SetupDriver(cloud openstack.IOpenStack, mount mount.IMount, metadata metadata.IMetadata)
  • func (d *CinderDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const FakeMaxVolume int64 = 256

Variables

var FakeAttachment = volumes.Attachment{
	ServerID: FakeNodeID,
}

var FakeAvailability = "nova"

var FakeBlockDeviceStats = &mount.DeviceStats{
	Block: true,

	TotalBytes: 536870912,
}

var FakeCapacityGiB = 1

var FakeCluster = "cluster"

var FakeConfig = "/etc/cloud.conf"

var FakeCtx = context.Background()

var FakeDevicePath = "/dev/xxx"

var FakeEndpoint = "tcp://127.0.0.1:10000"

var FakeFsStats = &mount.DeviceStats{
	Block: false,

	AvailableBytes:  2100,
	TotalBytes:      2121,
	UsedBytes:       21,
	AvailableInodes: 150,
	TotalInodes:     200,
	UsedInodes:      50,
}

var FakeInstanceID = "321a8b81-3660-43e5-bab8-6470b65ee4e8"

var FakeNodeID = "CSINodeID"

var FakePVCName = "fakepvc-1"

var FakePVCNamespace = "fakepvc-ns"

var FakePVName = "fakepv-1"

var FakeSnapshotContentName = "fake-content"

var FakeSnapshotID = "261a8b81-3660-43e5-bab8-6470b65ee4e8"

var FakeSnapshotListEmpty = []snapshots.Snapshot{}

var FakeSnapshotName = "CSISnapshotName"

var FakeSnapshotNamespace = "fakesnapshot-ns"

var FakeSnapshotRes = snapshots.Snapshot{
	ID:       FakeSnapshotID,
	Name:     "fake-snapshot",
	VolumeID: FakeVolID,
	Size:     1,
}

var FakeSnapshotsRes = []snapshots.Snapshot{FakeSnapshotRes}

var FakeStagingTargetPath = "/mnt/globalmount"

var FakeTargetPath = "/mnt/cinder"

var FakeVol = volumes.Volume{
	ID:               FakeVolID,
	Name:             FakeVolName,
	Size:             FakeCapacityGiB,
	AvailabilityZone: FakeAvailability,
}

var FakeVol1 = volumes.Volume{
	ID:               FakeVolID,
	Name:             "fake-duplicate",
	Status:           "available",
	AvailabilityZone: FakeAvailability,
	Size:             FakeCapacityGiB,
	Attachments:      []volumes.Attachment{FakeAttachment},
}

var FakeVol2 = volumes.Volume{
	ID:               "261a8b81-3660-43e5-bab8-6470b65ee4e9",
	Name:             "fake-duplicate",
	Status:           "available",
	AvailabilityZone: "",
}

var FakeVol3 = volumes.Volume{
	ID:               "261a8b81-3660-43e5-bab8-6470b65ee4e9",
	Name:             "fake-3",
	Status:           "available",
	Size:             2,
	AvailabilityZone: "",
}

var FakeVolFromSnapshot = volumes.Volume{
	ID:               FakeVolID,
	Name:             FakeVolName,
	Size:             FakeCapacityGiB,
	AvailabilityZone: FakeAvailability,
	SnapshotID:       FakeSnapshotID,
}

var FakeVolFromSourceVolume = volumes.Volume{
	ID:               "test-clone-id",
	Name:             FakeVolName,
	Size:             FakeCapacityGiB,
	AvailabilityZone: FakeAvailability,
	SourceVolID:      FakeVolID,
}

var FakeVolID = "CSIVolumeID"

var FakeVolList = []volumes.Volume{FakeVol1}

var FakeVolListEmpty = []volumes.Volume{}

var FakeVolListMultiple = []volumes.Volume{FakeVol1, FakeVol3}

var FakeVolName = "CSIVolumeName"

var FakeVolType = ""

var (

	// Driver version
	// Version history:
	// * 1.3.0: Up to version 1.3.0 driver version was the same as CSI spec version
	// * 1.3.1: Bump for 1.21 release
	// * 1.3.2: Allow --cloud-config to be given multiple times
	// * 1.3.3: Bump for 1.22 release
	// * 2.0.0: Bump for 1.23 release
	Version = "2.0.0"
)

Functions

func NewControllerServer

func NewControllerServer(d *CinderDriver, cloud openstack.IOpenStack) *controllerServer

func NewControllerServiceCapability

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

func NewIdentityServer

func NewIdentityServer(d *CinderDriver) *identityServer

func NewNodeServer

func NewNodeServer(d *CinderDriver, mount mount.IMount, metadata metadata.IMetadata, cloud openstack.IOpenStack) *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, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

Types

type CinderDriver

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

func NewDriver

func NewDriver(endpoint, cluster string) *CinderDriver

func (*CinderDriver) AddControllerServiceCapabilities

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

func (*CinderDriver) AddNodeServiceCapabilities

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

func (*CinderDriver) AddVolumeCapabilityAccessModes

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

func (*CinderDriver) GetVolumeCapabilityAccessModes

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

func (*CinderDriver) Run

func (d *CinderDriver) Run()

func (*CinderDriver) SetupDriver

func (d *CinderDriver) SetupDriver(cloud openstack.IOpenStack, mount mount.IMount, metadata metadata.IMetadata)

func (*CinderDriver) ValidateControllerServiceRequest

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

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