blockdevice

Documentation

Index

• Constants
• func ConvertBlockDevicesToMap(bds []*diskv1.BlockDevice) map[string]*diskv1.BlockDevice
• func GetDiskBlockDevice(disk *block.Disk, nodeName, namespace string) *diskv1.BlockDevice
• func GetPartitionBlockDevice(part *block.Partition, nodeName, namespace string) *diskv1.BlockDevice
• func Register(ctx context.Context, nodes ctllonghornv1.NodeController, ...) error
• type Controller
  • func (c *Controller) ApplyFilter(disk *block.Disk) bool
  • func (c *Controller) MakeGPTPartitionIfNeeded(device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)
  • func (c *Controller) OnBlockDeviceChange(key string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)
  • func (c *Controller) OnBlockDeviceDelete(key string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)
  • func (c *Controller) SaveBlockDevice(bd *diskv1.BlockDevice, oldBds map[string]*diskv1.BlockDevice) (*diskv1.BlockDevice, error)
  • func (c *Controller) ScanBlockDevicesOnNode() error

Constants

const (
	// ParentDeviceLabel stores the parent device name of a device
	ParentDeviceLabel = "ndm.harvesterhci.io/parent-device"
	// DeviceTypeLabel indicates whether the device is a disk or a partition
	DeviceTypeLabel = "ndm.harvesterhci.io/device-type"
)

Functions

func ConvertBlockDevicesToMap

func ConvertBlockDevicesToMap(bds []*diskv1.BlockDevice) map[string]*diskv1.BlockDevice

ConvertBlockDevicesToMap converts a BlockDeviceList to a map with GUID (Name) as keys.

func GetDiskBlockDevice

func GetDiskBlockDevice(disk *block.Disk, nodeName, namespace string) *diskv1.BlockDevice

GetDiskBlockDevice gets a blockdevice from a given disk.

func GetPartitionBlockDevice

func GetPartitionBlockDevice(part *block.Partition, nodeName, namespace string) *diskv1.BlockDevice

GetPartitionBlockDevice gets a blockdevice from a given partition.

func Register

func Register(ctx context.Context, nodes ctllonghornv1.NodeController, bds ctldiskv1.BlockDeviceController, block block.Info,
	opt *option.Option, filters []*filter.Filter) error

Register register the block device CRD controller

Types

type Controller

type Controller struct {
	Namespace string
	NodeName  string

	NodeCache ctllonghornv1.NodeCache
	Nodes     ctllonghornv1.NodeClient

	Blockdevices     ctldiskv1.BlockDeviceClient
	BlockdeviceCache ctldiskv1.BlockDeviceCache
	BlockInfo        block.Info
	Filters          []*filter.Filter

	AutoGPTGenerate bool
}

func (*Controller) ApplyFilter

func (c *Controller) ApplyFilter(disk *block.Disk) bool

ApplyFilter check the status of every register filters if the disk meets the filter criteria it will return true else it will return false

func (*Controller) MakeGPTPartitionIfNeeded

func (c *Controller) MakeGPTPartitionIfNeeded(device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)

MakeGPTPartitionIfNeeded makes GPT partition on given device if needed.

Currently only making GPT partition on devices without a name (GUID).

func (*Controller) OnBlockDeviceChange

func (c *Controller) OnBlockDeviceChange(key string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)

OnBlockDeviceChange watch the block device CR on change and performing disk operations like mounting the disks to a desired path via ext4

func (*Controller) OnBlockDeviceDelete

func (c *Controller) OnBlockDeviceDelete(key string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)

OnBlockDeviceDelete will delete the block devices that belongs to the same parent device

func (*Controller) SaveBlockDevice

func (c *Controller) SaveBlockDevice(bd *diskv1.BlockDevice, oldBds map[string]*diskv1.BlockDevice) (*diskv1.BlockDevice, error)

SaveBlockDevice persists the blockedevice information. If oldBds contains a blockedevice under the same name (GUID), it will only do an update, otherwise create a new one.

Note that this method also activate the device if it's previously inactive.

func (*Controller) ScanBlockDevicesOnNode

func (c *Controller) ScanBlockDevicesOnNode() error

ScanBlockDevicesOnNode scans block devices on the node, and it will either create or update them.