lvm

Documentation

Index

• Constants
• func NewControllerServer(d *csicommon.CSIDriver, c client.Client, cache cache.Cache, conf *PluginConf) *controllerServer
• func NewIdentityServer(d *csicommon.CSIDriver) *identityServer
• func NewNodeServer(d *csicommon.CSIDriver, c client.Client, conf *PluginConf) *nodeServer
• type Driver
  • func NewDriver(client client.Client) *Driver
  • func (lvm *Driver) Run(cache cache.Cache, conf *PluginConf)
• type NodeAllocator
  • func NewNodeAllocator(c cache.Cache, vgName, labelKey, labelValue string) *NodeAllocator
  • func (a *NodeAllocator) AllocateNodeForRequest(pvcUID string, size uint64) (node string, err error)
  • func (a *NodeAllocator) OnCreate(e event.CreateEvent) (handler.Result, error)
  • func (a *NodeAllocator) OnDelete(e event.DeleteEvent) (handler.Result, error)
  • func (a *NodeAllocator) OnGeneric(e event.GenericEvent) (handler.Result, error)
  • func (a *NodeAllocator) OnUpdate(e event.UpdateEvent) (handler.Result, error)
  • func (a *NodeAllocator) Release(name string, size uint64)
• type PluginConf
• type StatefulSet
• type StatefulSetList

Constants

const (
	DefaultFS      = "ext4"
	ConnectTimeout = 3 * time.Second
	Gigabytes      = int64(1024 * 1024 * 1024)
)

const (
	NodeLabelKey = apis.LabelHostname
)

Functions

func NewControllerServer

func NewControllerServer(d *csicommon.CSIDriver, c client.Client, cache cache.Cache, conf *PluginConf) *controllerServer

func NewIdentityServer

func NewIdentityServer(d *csicommon.CSIDriver) *identityServer

func NewNodeServer

func NewNodeServer(d *csicommon.CSIDriver, c client.Client, conf *PluginConf) *nodeServer

Types

type Driver

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

func NewDriver

func NewDriver(client client.Client) *Driver

func (*Driver) Run

func (lvm *Driver) Run(cache cache.Cache, conf *PluginConf)

type NodeAllocator

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

func NewNodeAllocator

func NewNodeAllocator(c cache.Cache, vgName, labelKey, labelValue string) *NodeAllocator

func (*NodeAllocator) AllocateNodeForRequest

func (a *NodeAllocator) AllocateNodeForRequest(pvcUID string, size uint64) (node string, err error)

func (*NodeAllocator) OnCreate

func (a *NodeAllocator) OnCreate(e event.CreateEvent) (handler.Result, error)

func (*NodeAllocator) OnDelete

func (a *NodeAllocator) OnDelete(e event.DeleteEvent) (handler.Result, error)

func (*NodeAllocator) OnGeneric

func (a *NodeAllocator) OnGeneric(e event.GenericEvent) (handler.Result, error)

func (*NodeAllocator) OnUpdate

func (a *NodeAllocator) OnUpdate(e event.UpdateEvent) (handler.Result, error)

func (*NodeAllocator) Release

func (a *NodeAllocator) Release(name string, size uint64)

type PluginConf

type PluginConf struct {
	Endpoint   string
	DriverName string
	NodeID     string
	VgName     string
	PoolName   string
	LabelKey   string
	LabelValue string
}

type StatefulSet

type StatefulSet struct {
	Name          string
	PodAndNode    map[string]string
	LVMVolumeName string
}

type StatefulSetList

type StatefulSetList []*StatefulSet