blockdevice

Documentation

Index

• Constants
• 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) OnBlockDeviceChange(_ string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)
  • func (c *Controller) OnBlockDeviceDelete(_ string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)
• type DiskTags
  • func (d *DiskTags) DeleteDiskTags(dev string)
  • func (d *DiskTags) DevExist(dev string) bool
  • func (d *DiskTags) GetDiskTags(dev string) []string
  • func (d *DiskTags) Initialized() bool
  • func (d *DiskTags) UpdateDiskTags(dev string, tags []string)
  • func (d *DiskTags) UpdateInitialized()
• type NeedMountUpdateOP
  • func (f NeedMountUpdateOP) Has(flag NeedMountUpdateOP) bool
• type Scanner
  • func NewScanner(nodeName, namespace string, bds ctldiskv1.BlockDeviceController, ...) *Scanner
  • func (s *Scanner) ApplyAutoProvisionFiltersForDisk(disk *block.Disk) bool
  • func (s *Scanner) ApplyExcludeFiltersForDisk(disk *block.Disk) bool
  • func (s *Scanner) ApplyExcludeFiltersForPartition(part *block.Partition) bool
  • func (s *Scanner) NeedsAutoProvision(oldBd *diskv1.BlockDevice, autoProvisionPatternMatches bool) bool
  • func (s *Scanner) SaveBlockDevice(bd *diskv1.BlockDevice, autoProvisioned bool) (*diskv1.BlockDevice, error)
  • func (s *Scanner) Start() 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 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,
	scanner *Scanner,
) 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.BlockDeviceController
	BlockdeviceCache ctldiskv1.BlockDeviceCache
	BlockInfo        block.Info
	// contains filtered or unexported fields
}

func (*Controller) OnBlockDeviceChange

func (c *Controller) OnBlockDeviceChange(_ 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(_ string, device *diskv1.BlockDevice) (*diskv1.BlockDevice, error)

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

type DiskTags

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

var CacheDiskTags *DiskTags

func (*DiskTags) DeleteDiskTags

func (d *DiskTags) DeleteDiskTags(dev string)

func (*DiskTags) DevExist

func (d *DiskTags) DevExist(dev string) bool

func (*DiskTags) GetDiskTags

func (d *DiskTags) GetDiskTags(dev string) []string

func (*DiskTags) Initialized

func (d *DiskTags) Initialized() bool

func (*DiskTags) UpdateDiskTags

func (d *DiskTags) UpdateDiskTags(dev string, tags []string)

func (*DiskTags) UpdateInitialized

func (d *DiskTags) UpdateInitialized()

type NeedMountUpdateOP

type NeedMountUpdateOP int8

const (
	NeedMountUpdateNoOp NeedMountUpdateOP = 1 << iota
	NeedMountUpdateMount
	NeedMountUpdateUnmount
)

func (NeedMountUpdateOP) Has

func (f NeedMountUpdateOP) Has(flag NeedMountUpdateOP) bool

type Scanner

type Scanner struct {
	NodeName             string
	Namespace            string
	Blockdevices         ctldiskv1.BlockDeviceController
	BlockInfo            block.Info
	ExcludeFilters       []*filter.Filter
	AutoProvisionFilters []*filter.Filter
	Cond                 *sync.Cond
	Shutdown             bool
	TerminatedChannels   *chan bool
}

func NewScanner

func NewScanner(
	nodeName, namespace string,
	bds ctldiskv1.BlockDeviceController,
	block block.Info,
	excludeFilters, autoProvisionFilters []*filter.Filter,
	cond *sync.Cond,
	shutdown bool,
	ch *chan bool,
) *Scanner

func (*Scanner) ApplyAutoProvisionFiltersForDisk

func (s *Scanner) ApplyAutoProvisionFiltersForDisk(disk *block.Disk) bool

ApplyAutoProvisionFiltersForDisk check the status of disk for every registered auto-provision filters. If the disk meets one of the criteria, it returns true.

func (*Scanner) ApplyExcludeFiltersForDisk

func (s *Scanner) ApplyExcludeFiltersForDisk(disk *block.Disk) bool

ApplyExcludeFiltersForPartition check the status of disk for every registered exclude filters. If the disk meets one of the criteria, it returns true.

func (*Scanner) ApplyExcludeFiltersForPartition

func (s *Scanner) ApplyExcludeFiltersForPartition(part *block.Partition) bool

ApplyExcludeFiltersForPartition check the status of partition for every registered exclude filters. If the partition meets one of the criteria, it returns true.

func (*Scanner) NeedsAutoProvision

func (s *Scanner) NeedsAutoProvision(oldBd *diskv1.BlockDevice, autoProvisionPatternMatches bool) bool

NeedsAutoProvision returns true if the current block device needs to be auto-provisioned.

Criteria: - disk hasn't yet set to provisioned - disk hasn't yet been force formatted - disk matches auto-provisioned patterns

func (*Scanner) SaveBlockDevice

func (s *Scanner) SaveBlockDevice(bd *diskv1.BlockDevice, autoProvisioned bool) (*diskv1.BlockDevice, error)

SaveBlockDevice persists the blockedevice information.

func (*Scanner) Start

func (s *Scanner) Start() error