localdisk

Documentation

Index

• Constants
• type Controller
  • func NewController(mgr crmanager.Manager) Controller
  • func (ctr Controller) ConvertDiskToLocalDisk(disk manager.DiskInfo) (ld ldm.LocalDisk)
  • func (ctr Controller) CreateLocalDisk(ld ldm.LocalDisk) error
  • func (ctr Controller) GenLocalDiskName(disk manager.DiskInfo) string
  • func (ctr Controller) GetLocalDisk(key client.ObjectKey) (ldm.LocalDisk, error)
  • func (ctr Controller) IsAlreadyExist(ld ldm.LocalDisk) bool
  • func (ctr Controller) UpdateLocalDisk(ld ldm.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 ldm is installed
	NameSpace string

	// NodeName is the node in which ldm 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

NewController

func (Controller) ConvertDiskToLocalDisk

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

ConvertDiskToLocalDisk

func (Controller) CreateLocalDisk

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

CreateLocalDisk

func (Controller) GenLocalDiskName

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

func (Controller) GetLocalDisk

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

GetLocalDisk

func (Controller) IsAlreadyExist

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

IsAlreadyExist

func (Controller) UpdateLocalDisk

func (ctr Controller) UpdateLocalDisk(ld ldm.LocalDisk) error

CreateLocalDisk