partition

Documentation

Index

• Constants
• type LocalPartition
• type LocalPartitionImplement
  • func NewLocalPartitionImplement() *LocalPartitionImplement
  • func (ld *LocalPartitionImplement) CreatePartition(name, groups string, size uint64) error
  • func (ld *LocalPartitionImplement) DeletePartition(name, groups string) error
  • func (ld *LocalPartitionImplement) DeletePartitionByPartNumber(disk disko.Disk, number uint) error
  • func (ld *LocalPartitionImplement) GetDevice(deviceNumber string) (*types.LocalDisk, error)
  • func (ld *LocalPartitionImplement) GetDiskUsed(device string) (uint64, error)
  • func (ld *LocalPartitionImplement) GetPartition(name, groups string) (disko.Partition, error)
  • func (ld *LocalPartitionImplement) ListDevicesDetail(device string) ([]*types.LocalDisk, error)
  • func (ld *LocalPartitionImplement) ListDevicesDetailWithoutFilter(device string) ([]*types.LocalDisk, error)
  • func (ld *LocalPartitionImplement) PartProbe() error
  • func (ld *LocalPartitionImplement) ScanAllDisk(paths []string) (disko.DiskSet, error)
  • func (ld *LocalPartitionImplement) ScanAllDisks(filter disko.DiskFilter) (disko.DiskSet, error)
  • func (ld *LocalPartitionImplement) ScanDisk(groups string) (disko.Disk, error)
  • func (ld *LocalPartitionImplement) UdevSettle() error
  • func (ld *LocalPartitionImplement) UpdatePartition(name, groups string, size uint64) error
  • func (ld *LocalPartitionImplement) UpdatePartitionCache(name string, number uint) error
  • func (ld *LocalPartitionImplement) Wipe(name, groups string) error

Constants

const DISKMUTEX = "DiskMutex"

Types

type LocalPartition

type LocalPartition interface {
	ScanAllDisks(filter disko.DiskFilter) (disko.DiskSet, error)
	ScanAllDisk(paths []string) (disko.DiskSet, error)
	ScanDisk(groups string) (disko.Disk, error)
	CreatePartition(name, groups string, size uint64) error
	GetPartition(name, groups string) (disko.Partition, error)
	UpdatePartition(name, groups string, size uint64) error
	DeletePartition(name, groups string) error
	DeletePartitionByPartNumber(disk disko.Disk, number uint) error
	UpdatePartitionCache(name string, number uint) error
	Wipe(name, groups string) error
	UdevSettle() error
	PartProbe() error
	ListDevicesDetailWithoutFilter(device string) ([]*types.LocalDisk, error)
	ListDevicesDetail(device string) ([]*types.LocalDisk, error)
	GetDiskUsed(device string) (uint64, error)
	GetDevice(deviceNumber string) (*types.LocalDisk, error)
}

type LocalPartitionImplement

type LocalPartitionImplement struct {
	//	Bcache               bcache.Bcache
	Mutex            *mutx.GlobalLocks
	CacheParttionNum map[string]uint
	Executor         exec.Executor
}

func NewLocalPartitionImplement

func NewLocalPartitionImplement() *LocalPartitionImplement

func (*LocalPartitionImplement) CreatePartition

func (ld *LocalPartitionImplement) CreatePartition(name, groups string, size uint64) error

func (*LocalPartitionImplement) DeletePartition

func (ld *LocalPartitionImplement) DeletePartition(name, groups string) error

func (*LocalPartitionImplement) DeletePartitionByPartNumber

func (ld *LocalPartitionImplement) DeletePartitionByPartNumber(disk disko.Disk, number uint) error

func (*LocalPartitionImplement) GetDevice

func (ld *LocalPartitionImplement) GetDevice(deviceNumber string) (*types.LocalDisk, error)

func (*LocalPartitionImplement) GetDiskUsed

func (ld *LocalPartitionImplement) GetDiskUsed(device string) (uint64, error)

GetDiskUsed

# df /dev/sda 文件系统 1K-块 已用 可用 已用% 挂载点 udev 8193452 0 8193452 0% /dev

func (*LocalPartitionImplement) GetPartition

func (ld *LocalPartitionImplement) GetPartition(name, groups string) (disko.Partition, error)

func (*LocalPartitionImplement) ListDevicesDetail

func (ld *LocalPartitionImplement) ListDevicesDetail(device string) ([]*types.LocalDisk, error)

func (*LocalPartitionImplement) ListDevicesDetailWithoutFilter

func (ld *LocalPartitionImplement) ListDevicesDetailWithoutFilter(device string) ([]*types.LocalDisk, error)

func (*LocalPartitionImplement) PartProbe

func (ld *LocalPartitionImplement) PartProbe() error

func (*LocalPartitionImplement) ScanAllDisk

func (ld *LocalPartitionImplement) ScanAllDisk(paths []string) (disko.DiskSet, error)

func (*LocalPartitionImplement) ScanAllDisks

func (ld *LocalPartitionImplement) ScanAllDisks(filter disko.DiskFilter) (disko.DiskSet, error)

func (*LocalPartitionImplement) ScanDisk

func (ld *LocalPartitionImplement) ScanDisk(groups string) (disko.Disk, error)

func (*LocalPartitionImplement) UdevSettle

func (ld *LocalPartitionImplement) UdevSettle() error

func (*LocalPartitionImplement) UpdatePartition

func (ld *LocalPartitionImplement) UpdatePartition(name, groups string, size uint64) error

func (*LocalPartitionImplement) UpdatePartitionCache

func (ld *LocalPartitionImplement) UpdatePartitionCache(name string, number uint) error

func (*LocalPartitionImplement) Wipe

func (ld *LocalPartitionImplement) Wipe(name, groups string) error