driver

package

v0.0.0-...-e7d1ed3 Latest Latest Go to latest Published: Sep 6, 2022 License: Apache-2.0 Imports: 29 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/kungze/cinder-metal-csi

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewControllerServer(d *Driver, cloud openstack.IOpenstack) csi.ControllerServer
func NewControllerServerCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
func NewIdentityServer(d *Driver, cloud openstack.IOpenstack) csi.IdentityServer
func NewNodeServer(d *Driver, cloud openstack.IOpenstack, mount mount.IMount) csi.NodeServer
func NewVolumeCapabilityAccessMode(vap csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode
func ParseEndpoint(endpoint string) (string, string, error)
func RoundOffBytes(bytes int64) int
type ControllerServer
type Driver
- func NewDriver(nodeId, version, endpoint string, cloud openstack.IOpenstack, ...) *Driver
type NonBlockingStorageServer
- func NewNonBlockingStorageServer(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...) NonBlockingStorageServer

Constants ¶

View Source

const (
	FSTypeExt4 = "ext4"
	FSTypeXfs  = "xfs"
)

Variables ¶

This section is empty.

Functions ¶

func NewControllerServer ¶

func NewControllerServer(d *Driver, cloud openstack.IOpenstack) csi.ControllerServer

func NewControllerServerCapability ¶

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

func NewIdentityServer ¶

func NewIdentityServer(d *Driver, cloud openstack.IOpenstack) csi.IdentityServer

func NewNodeServer ¶

func NewNodeServer(d *Driver, cloud openstack.IOpenstack, mount mount.IMount) csi.NodeServer

func NewVolumeCapabilityAccessMode ¶

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

func ParseEndpoint ¶

func ParseEndpoint(endpoint string) (string, string, error)

func RoundOffBytes ¶

func RoundOffBytes(bytes int64) int

Types ¶

type ControllerServer ¶

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

func (*ControllerServer) ControllerExpandVolume ¶

func (c *ControllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

func (*ControllerServer) ControllerGetCapabilities ¶

func (c *ControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

func (*ControllerServer) ControllerGetVolume ¶

func (c *ControllerServer) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

func (*ControllerServer) ControllerPublishVolume ¶

func (c *ControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

func (*ControllerServer) ControllerUnpublishVolume ¶

func (c *ControllerServer) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

func (*ControllerServer) CreateSnapshot ¶

func (c *ControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*ControllerServer) CreateVolume ¶

func (c *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

func (*ControllerServer) DeleteSnapshot ¶

func (c *ControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*ControllerServer) DeleteVolume ¶

func (c *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

func (*ControllerServer) GetCapacity ¶

func (c *ControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

func (*ControllerServer) ListSnapshots ¶

func (c *ControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*ControllerServer) ListVolumes ¶

func (c *ControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

func (*ControllerServer) ValidateVolumeCapabilities ¶

func (c *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, request *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

type Driver ¶

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

func NewDriver ¶

func NewDriver(nodeId, version, endpoint string, cloud openstack.IOpenstack, mount mount.IMount) *Driver

func (*Driver) AddControllerCapability ¶

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

func (*Driver) AddVolumeCapability ¶

func (d *Driver) AddVolumeCapability(va []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode

func (*Driver) GetVolumeCapability ¶

func (d *Driver) GetVolumeCapability() []*csi.VolumeCapability_AccessMode

func (*Driver) Run ¶

func (d *Driver) Run()

func (*Driver) ValidateControllerCapability ¶

func (d *Driver) ValidateControllerCapability(ca csi.ControllerServiceCapability_RPC_Type) error

type NonBlockingStorageServer ¶

type NonBlockingStorageServer interface {
	Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
	Wait()
	Stop()
	ForceStop()
}

func NewNonBlockingStorageServer ¶

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

Source Files ¶

View all Source files

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