cinder

package

v1.0.1 Latest Latest Go to latest Published: Dec 31, 2021 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fightdou/k8s-cinder-csi-plugin

Documentation ¶

Index ¶

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, cloud openstack.IOpenStack) *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
type NonBlockingGRPCServer
- func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants ¶

This section is empty.

Variables ¶

View Source

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
	Version = "1.3.3"
)

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, 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)

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
openstack Package openstack snapshots provides an implementation of Cinder Snapshot features cinder functions using Gophercloud.	Package openstack snapshots provides an implementation of Cinder Snapshot features cinder functions using Gophercloud.

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