Documentation
¶
Index ¶
- Constants
- func DmsetupCreate(dmDeviceName, table string, executor *commonNs.Executor) error
- func DmsetupDeps(dmDeviceName string, executor *commonNs.Executor) ([]string, error)
- func DmsetupReload(dmDeviceName, table string, executor *commonNs.Executor) error
- func DmsetupRemove(dmDeviceName string, force, deferred bool, executor *commonNs.Executor) error
- func DmsetupResume(dmDeviceName string, executor *commonNs.Executor) error
- func DmsetupSuspend(dmDeviceName string, noflush, nolockfs bool, executor *commonNs.Executor) error
- func DuplicateDevice(dev *KernelDevice, dest string) error
- func GetDeviceNumbers(devPath string, executor *commonNs.Executor) (int, int, error)
- func GetDeviceSectorSize(devPath string, executor *commonNs.Executor) (int64, error)
- func GetHostNamespacePath(hostProcPath string) string
- func GetKnownDevices(executor *commonNs.Executor) (map[string]*KernelDevice, error)
- func GetLonghornDevicePath(name string) string
- func GetNvmeControllerNameFromNamespaceName(nsName string) string
- func GetNvmeDevicePath(name string) string
- func GetNvmeNamespaceNameFromControllerName(controllerName string, nsID int) string
- func IsBlockDevice(path string) (bool, error)
- func NewExecutor(hostProc string) (*commonNs.Executor, error)
- func PrintObject(v interface{}) error
- func RemoveDevice(dev string) error
- type BlockDevice
- type BlockDevices
- type KernelDevice
- type ProcessFinder
Constants ¶
const ( DevPath = "/dev" LonghornDevDir = "/longhorn" DefaultNVMeNamespaceID = 1 )
const ( DockerdProcess = "dockerd" ContainerdProcess = "containerd" ContainerdShimProcess = "containerd-shim" )
const (
BlockdevBinary = "blockdev"
)
Variables ¶
This section is empty.
Functions ¶
func DmsetupCreate ¶
DmsetupCreate creates a device mapper device with the given name and table
func DmsetupDeps ¶
DmsetupDeps returns the dependent devices of the device mapper device with the given name
func DmsetupReload ¶
DmsetupReload reloads the table of the device mapper device with the given name and table
func DmsetupRemove ¶
DmsetupRemove removes the device mapper device with the given name
func DmsetupResume ¶
DmsetupResume removes the device mapper device with the given name
func DmsetupSuspend ¶
DmsetupSuspend suspends the device mapper device with the given name
func DuplicateDevice ¶
func DuplicateDevice(dev *KernelDevice, dest string) error
DuplicateDevice creates a device node for the given device
func GetDeviceNumbers ¶
GetDeviceNumbers returns the major and minor numbers of the given device
func GetDeviceSectorSize ¶
GetDeviceSectorSize returns the sector size of the given device
func GetHostNamespacePath ¶
func GetKnownDevices ¶
func GetKnownDevices(executor *commonNs.Executor) (map[string]*KernelDevice, error)
GetKnownDevices returns the path of the device with the given major and minor numbers
func GetLonghornDevicePath ¶
func GetNvmeDevicePath ¶
func IsBlockDevice ¶
IsBlockDevice returns true if the given path is a block device
func NewExecutor ¶
NewExecutor creates a new namespaced executor
func PrintObject ¶
func PrintObject(v interface{}) error
Types ¶
type BlockDevice ¶
type BlockDevices ¶
type BlockDevices struct {
Devices []BlockDevice `json:"blockdevices"`
}
type KernelDevice ¶
type KernelDevice struct {
Nvme BlockDevice
Export BlockDevice
}
func DetectDevice ¶
func DetectDevice(path string, executor *commonNs.Executor) (*KernelDevice, error)
DetectDevice detects the device with the given path
type ProcessFinder ¶
type ProcessFinder struct {
// contains filtered or unexported fields
}
func NewProcessFinder ¶
func NewProcessFinder(procPath string) *ProcessFinder
func (*ProcessFinder) FindAncestorByName ¶
func (p *ProcessFinder) FindAncestorByName(ancestorProcess string) (*linuxproc.ProcessStatus, error)
func (*ProcessFinder) FindPid ¶
func (p *ProcessFinder) FindPid(pid int64) (*linuxproc.ProcessStatus, error)
func (*ProcessFinder) FindSelf ¶
func (p *ProcessFinder) FindSelf() (*linuxproc.ProcessStatus, error)
Source Files