driver

Documentation

Index

• Constants
• func GetAttachmentDiskPath(ctx context.Context, client *gobizfly.Client, serverID string, volumeID string) (string, error)
• func GetSnapshotByNameAndVolumeID(ctx context.Context, client *gobizfly.Client, volumeId string, name string) ([]*gobizfly.Snapshot, error)
• func GetVolumesByName(ctx context.Context, client *gobizfly.Client, name string) (*gobizfly.Volume, error)
• func NewControllerServer(d *VolumeDriver, client *gobizfly.Client) *controllerServer
• func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability
• func NewIdentityServer(d *VolumeDriver) *identityServer
• func NewNodeServer(d *VolumeDriver, 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, ...)
• func WaitDiskAttached(ctx context.Context, client *gobizfly.Client, serverId string, volumeID string) error
• func WaitDiskDetached(ctx context.Context, client *gobizfly.Client, serverId string, volumeID string) error
• func WaitSnapshotReady(ctx context.Context, client *gobizfly.Client, snapshotID string) error
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer
• type VolumeDriver
  • func NewDriver(endpoint, cluster string) *VolumeDriver
  • func (d *VolumeDriver) AddControllerServiceCapabilities(cl []csi.ControllerServiceCapability_RPC_Type)
  • func (d *VolumeDriver) AddNodeServiceCapabilities(nl []csi.NodeServiceCapability_RPC_Type) error
  • func (d *VolumeDriver) AddVolumeCapabilityAccessModes(vc []csi.VolumeCapability_AccessMode_Mode) []*csi.VolumeCapability_AccessMode
  • func (d *VolumeDriver) Run()
  • func (d *VolumeDriver) SetupControlDriver(client *gobizfly.Client, mount mount.IMount, metadata metadata.IMetadata)
  • func (d *VolumeDriver) SetupNodeDriver(mount mount.IMount, metadata metadata.IMetadata)

Constants

const RFC3339MilliNoZ = "2006-01-02T15:04:05.999999"

Functions

func GetAttachmentDiskPath

func GetAttachmentDiskPath(ctx context.Context, client *gobizfly.Client, serverID string, volumeID string) (string, error)

GetAttachmentDiskPath gets disk path in a server

func GetSnapshotByNameAndVolumeID

func GetSnapshotByNameAndVolumeID(ctx context.Context, client *gobizfly.Client, volumeId string, name string) ([]*gobizfly.Snapshot, error)

func GetVolumesByName

func GetVolumesByName(ctx context.Context, client *gobizfly.Client, name string) (*gobizfly.Volume, error)

GetVolumesByName gets volumes by name of volume

func NewControllerServer

func NewControllerServer(d *VolumeDriver, client *gobizfly.Client) *controllerServer

func NewControllerServiceCapability

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

func NewIdentityServer

func NewIdentityServer(d *VolumeDriver) *identityServer

func NewNodeServer

func NewNodeServer(d *VolumeDriver, mount mount.IMount, metadata metadata.IMetadata) *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)

RunControllerAndNodePublishServer run controller

func WaitDiskAttached

func WaitDiskAttached(ctx context.Context, client *gobizfly.Client, serverId string, volumeID string) error

func WaitDiskDetached

func WaitDiskDetached(ctx context.Context, client *gobizfly.Client, serverId string, volumeID string) error

WaitDiskDetached waits for detached

func WaitSnapshotReady

func WaitSnapshotReady(ctx context.Context, client *gobizfly.Client, snapshotID string) error

Types

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

type VolumeDriver

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

func NewDriver

func NewDriver(endpoint, cluster string) *VolumeDriver

NewDriver create new driver

func (*VolumeDriver) AddControllerServiceCapabilities

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

AddControllerServiceCapabilities add capabilities for driver

func (*VolumeDriver) AddNodeServiceCapabilities

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

AddNodeServiceCapabilities add node service capabilities

func (*VolumeDriver) AddVolumeCapabilityAccessModes

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

AddVolumeCapabilityAccessModes add access mode capability for volume driver

func (*VolumeDriver) Run

func (d *VolumeDriver) Run()

Run run driver

func (*VolumeDriver) SetupControlDriver

func (d *VolumeDriver) SetupControlDriver(client *gobizfly.Client, mount mount.IMount, metadata metadata.IMetadata)

SetupControlDriver setups driver for control plane

func (*VolumeDriver) SetupNodeDriver

func (d *VolumeDriver) SetupNodeDriver(mount mount.IMount, metadata metadata.IMetadata)

SetupControlDriver setups driver for control plane