localdisk

Documentation

Index

• Constants
• type Controller
  • func NewController(mgr crmanager.Manager) Controller
  • func (ctr Controller) ConvertDiskToLocalDisk(disk manager.DiskInfo) (ld v1alpha1.LocalDisk)
  • func (ctr Controller) CreateLocalDisk(ld v1alpha1.LocalDisk) error
  • func (ctr Controller) GenLocalDiskName(disk manager.DiskInfo) string
  • func (ctr Controller) GetLocalDisk(key client.ObjectKey) (v1alpha1.LocalDisk, error)
  • func (ctr Controller) IsAlreadyExist(ld v1alpha1.LocalDisk) bool
  • func (ctr Controller) UpdateLocalDiskAttr(newLocalDisk v1alpha1.LocalDisk) error

Constants

const (
	APIVersion          = "v1alpha1"
	LocalDiskKind       = "localDisk"
	LocalDiskAPIVersion = "localdiskmanager.hwameistor" + "/" + APIVersion
)

Types

type Controller

type Controller struct {
	// Mgr k8s runtime controller
	Mgr crmanager.Manager

	// Namespace is the namespace in which v1alpha1 is installed
	NameSpace string

	// NodeName is the node in which v1alpha1 is installed
	NodeName string
}

Controller The smallest unit to be processed here should be the disk. The main thing to do is how to convert the local disk into resources in the cluster

func NewController

func NewController(mgr crmanager.Manager) Controller

func (Controller) ConvertDiskToLocalDisk

func (ctr Controller) ConvertDiskToLocalDisk(disk manager.DiskInfo) (ld v1alpha1.LocalDisk)

func (Controller) CreateLocalDisk

func (ctr Controller) CreateLocalDisk(ld v1alpha1.LocalDisk) error

func (Controller) GenLocalDiskName

func (ctr Controller) GenLocalDiskName(disk manager.DiskInfo) string

func (Controller) GetLocalDisk

func (ctr Controller) GetLocalDisk(key client.ObjectKey) (v1alpha1.LocalDisk, error)

func (Controller) IsAlreadyExist

func (ctr Controller) IsAlreadyExist(ld v1alpha1.LocalDisk) bool

func (Controller) UpdateLocalDiskAttr

func (ctr Controller) UpdateLocalDiskAttr(newLocalDisk v1alpha1.LocalDisk) error