ios

package

v1.3.12 Latest Latest Go to latest Published: Nov 7, 2022 License: MIT Imports: 19 Imported by: 6

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NVIDIA/aistore

Links

Documentation ¶

Rendered for

Overview ¶

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2022, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2022, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package ios is a collection of interfaces to the local storage subsystem; the package includes OS-dependent implementations for those interfaces.

Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Index ¶

func DirFileCount(dirPath string) (int, error)
func DirSizeOnDisk(dirPath string) (uint64, error)
func DirSumFileSizes(dirPath string) (uint64, error)
func FinfoAtime(fqn string) (finfo os.FileInfo, atime int64, err error)
func GetATime(osfi os.FileInfo) time.Time
func GetFSStats(path string) (blocks, bavail uint64, bsize int64, err error)
func GetFSUsedPercentage(path string) (usedPercentage int64, ok bool)
type AllDiskStats
type BlockDevice
type DiskStats
type FsDisks
type IOStater
- func New() IOStater
type LsBlk
type MpathUtil
- func (x *MpathUtil) Get(mpath string) int64
- func (x *MpathUtil) Set(mpath string, util int64)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DirFileCount ¶

func DirFileCount(dirPath string) (int, error)

func DirSizeOnDisk ¶

func DirSizeOnDisk(dirPath string) (uint64, error)

- on-disk size is sometimes referred to as "apparent size" - ignore errors since `du` exits with status 1 if it encounters a file that couldn't be accessed (permissions)

func DirSumFileSizes ¶

func DirSumFileSizes(dirPath string) (uint64, error)

func FinfoAtime ¶

func FinfoAtime(fqn string) (finfo os.FileInfo, atime int64, err error)

func GetATime ¶

func GetATime(osfi os.FileInfo) time.Time

func GetFSStats ¶

func GetFSStats(path string) (blocks, bavail uint64, bsize int64, err error)

func GetFSUsedPercentage ¶

func GetFSUsedPercentage(path string) (usedPercentage int64, ok bool)

Types ¶

type AllDiskStats ¶

type AllDiskStats map[string]DiskStats

type BlockDevice ¶

type BlockDevice struct {
	Name         string          `json:"name"`
	PhySec       jsoniter.Number `json:"phy-sec"`
	BlockDevices []*BlockDevice  `json:"children"`
}

`lsblk -Jt` structure

type DiskStats ¶

type DiskStats struct{ RBps, Ravg, WBps, Wavg, Util int64 }

type FsDisks ¶

type FsDisks map[string]int64 // disk name => sector size

type IOStater ¶

type IOStater interface {
	GetAllMpathUtils() *MpathUtil
	GetMpathUtil(mpath string) int64
	AddMpath(mpath string, fs string) (FsDisks, error)
	RemoveMpath(mpath string)
	FillDiskStats(m AllDiskStats)
}

func New ¶

func New() IOStater

type LsBlk ¶

type LsBlk struct {
	BlockDevices []*BlockDevice `json:"blockdevices"`
}

type MpathUtil ¶

type MpathUtil sync.Map

func (*MpathUtil) Get ¶

func (x *MpathUtil) Get(mpath string) int64

func (*MpathUtil) Set ¶

func (x *MpathUtil) Set(mpath string, util int64)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL