diskmanager

type Disk struct {
	// AttachNode represent where disk is attached
	AttachNode string `json:"attachNode,omitempty"`

	// Name unique identification for a disk
	Name string `json:"name,omitempty"`

	// DevPath
	DevPath string `json:"devPath,omitempty"`

	// Capacity
	Capacity int64 `json:"capacity,omitempty"`

	// DiskType SSD/HDD/NVME...
	DiskType string `json:"diskType,omitempty"`

	// Status
	Status DiskStatus `json:"status,omitempty"`
}

type DiskManager interface {
	// GetClusterDisks list all disks by node
	GetClusterDisks() (map[string][]*Disk, error)

	// GetNodeDisks list all disk located on the node
	GetNodeDisks(node string) ([]*Disk, error)

	// ClaimDisk UpdateDiskStatus mark disk to TobeMount/Free/InUse... status
	ClaimDisk(*Disk) error

	// ReleaseDisk update disk to release status
	ReleaseDisk(diskName string) error

	// SelectFreeDisk use a disk and bind it to a volume
	SelectFreeDisk(Disk) (*Disk, error)

	// PreSelectFreeDisks only reserve disks, but not use
	PreSelectFreeDisks([]Disk) (bool, error)
}

type DiskStatus = string

type LocalDiskNodesManager struct {
	// GetClient for query LocalDiskNode resources from k8s
	GetClient func() (*localdisknode.Kubeclient, error)

	// DiskHandler manage LD resources in cluster
	DiskHandler *localdisk.LocalDiskHandler
	// contains filtered or unexported fields
}