deviceManager

Documentation

Overview

Copyright @ 2021 fushaosong <fushaosong@beyondlet.com>.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type DeviceManager
  • func NewDeviceManager(nodeName string, cache cache.Cache, stopChan <-chan struct{}) *DeviceManager
  • func (dm *DeviceManager) AddAndRemoveDevice()
  • func (dm *DeviceManager) DeviceCheckTask()
  • func (dm *DeviceManager) DiscoverDisk() (map[string][]string, error)
  • func (dm *DeviceManager) DiscoverPv() (map[string][]string, error)
  • func (dm *DeviceManager) VolumeConsistencyCheck()

Types

type DeviceManager

type DeviceManager struct {

	// The implementation of executing a console command
	Executor exec.Executor
	// 所有操作本地卷均需获取锁
	Mutex *mutx.GlobalLocks
	// 磁盘操作
	DiskManager device.LocalDevice
	// LVM 操作
	LvmManager lvmd.Lvm2
	// Volume 操作
	VolumeManager volume.LocalVolume
	// contains filtered or unexported fields
}

func NewDeviceManager

func NewDeviceManager(nodeName string, cache cache.Cache, stopChan <-chan struct{}) *DeviceManager

func (*DeviceManager) AddAndRemoveDevice

func (dm *DeviceManager) AddAndRemoveDevice()

定时巡检磁盘，是否有新磁盘加入

func (*DeviceManager) DeviceCheckTask

func (dm *DeviceManager) DeviceCheckTask()

func (*DeviceManager) DiscoverDisk

func (dm *DeviceManager) DiscoverDisk() (map[string][]string, error)

查找是否有符合条件的块设备加入

func (*DeviceManager) DiscoverPv

func (dm *DeviceManager) DiscoverPv() (map[string][]string, error)

支持发现Pv，由于某些异常情况，只创建成功了PV,并未创建成功VG

func (*DeviceManager) VolumeConsistencyCheck

func (dm *DeviceManager) VolumeConsistencyCheck()