driver

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
  • func (c *ControllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
  • func (c *ControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)
  • func (c *ControllerServer) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)
  • func (c *ControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)
  • func (c *ControllerServer) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)
  • func (c *ControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)
  • func (c *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
  • func (c *ControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)
  • func (c *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)
  • func (c *ControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)
  • func (c *ControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)
  • func (c *ControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)
  • func (c *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, request *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)
• type Driver
  • func NewDriver(nodeId, version, endpoint string, cloud openstack.IOpenstack, ...) *Driver
  • func (d *Driver) AddControllerCapability(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *Driver) AddVolumeCapability(va []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *Driver) GetVolumeCapability() []*csi.VolumeCapability_AccessMode
  • func (d *Driver) Run()
  • func (d *Driver) ValidateControllerCapability(ca csi.ControllerServiceCapability_RPC_Type) error
• type NonBlockingStorageServer
  • func NewNonBlockingStorageServer(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...) NonBlockingStorageServer

Constants

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

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