driver

Documentation

Index

• Constants
• func NewControllerServer(mgr manager.Manager) (csi.ControllerServer, error)
• func NewIdentityServer(ready func() (bool, error)) csi.IdentityServer
• func NewNodeServer(nodeName string, vgServiceClient proto.VGServiceClient, ...) (csi.NodeServer, error)
• type LockByID
  • func NewLockWithID() *LockByID
  • func (l *LockByID) LockByID(id string)
  • func (l *LockByID) UnlockByID(id string)

Constants

const (
	// DeviceDirectory is a directory where TopoLVM Node service creates device files.
	DeviceDirectory = "/dev/topolvm"
)

Functions

func NewControllerServer

func NewControllerServer(mgr manager.Manager) (csi.ControllerServer, error)

NewControllerServer returns a new ControllerServer.

func NewIdentityServer

func NewIdentityServer(ready func() (bool, error)) csi.IdentityServer

NewIdentityServer returns a new IdentityServer.

ready is a function to check the plugin status. It should return non-nil error if the plugin is not healthy. If the plugin is not yet ready, it should return (false, nil). Otherwise, return (true, nil).

func NewNodeServer

func NewNodeServer(nodeName string, vgServiceClient proto.VGServiceClient, lvServiceClient proto.LVServiceClient, mgr manager.Manager) (csi.NodeServer, error)

NewNodeServer returns a new NodeServer.

Types

type LockByID

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

LockByID is a mutex which takes lock with a given ID. If same id is given, only one process can take lock. If different id is given, each process can take lock separately.

func NewLockWithID

func NewLockWithID() *LockByID

func (*LockByID) LockByID

func (l *LockByID) LockByID(id string)

func (*LockByID) UnlockByID

func (l *LockByID) UnlockByID(id string)