localdisknode

Documentation

Index

• type DiskNodeHandler
  • func NewDiskNodeHelper(cli client.Client, recorder record.EventRecorder) *DiskNodeHandler
  • func (n *DiskNodeHandler) Disks() map[string]ldm.Disk
  • func (n *DiskNodeHandler) For(name types.NamespacedName) error
  • func (n *DiskNodeHandler) IsSameDisk(name string, newDisk ldm.Disk) bool
  • func (n *DiskNodeHandler) ListNodeDisks() (map[string]ldm.Disk, error)
  • func (n *DiskNodeHandler) UpdateDiskLists(updateDisks, removedDisks map[string]ldm.Disk)
  • func (n *DiskNodeHandler) UpdateDiskStats()
  • func (n *DiskNodeHandler) UpdateStatus() error

Types

type DiskNodeHandler

type DiskNodeHandler struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

func NewDiskNodeHelper

func NewDiskNodeHelper(cli client.Client, recorder record.EventRecorder) *DiskNodeHandler

func (*DiskNodeHandler) Disks

func (n *DiskNodeHandler) Disks() map[string]ldm.Disk

func (*DiskNodeHandler) For

func (n *DiskNodeHandler) For(name types.NamespacedName) error

func (*DiskNodeHandler) IsSameDisk

func (n *DiskNodeHandler) IsSameDisk(name string, newDisk ldm.Disk) bool

IsSameDisk judge the disk in LocalDiskNode is same as disk in LocalDisk

func (*DiskNodeHandler) ListNodeDisks

func (n *DiskNodeHandler) ListNodeDisks() (map[string]ldm.Disk, error)

func (*DiskNodeHandler) UpdateDiskLists

func (n *DiskNodeHandler) UpdateDiskLists(updateDisks, removedDisks map[string]ldm.Disk)

func (*DiskNodeHandler) UpdateDiskStats

func (n *DiskNodeHandler) UpdateDiskStats()

func (*DiskNodeHandler) UpdateStatus

func (n *DiskNodeHandler) UpdateStatus() error