fsutils

package

v1.3.7 Latest Latest Go to latest Published: Apr 29, 2024 License: BSD-3-Clause Imports: 15 Imported by: 0

Details

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

Repository

github.com/TeaOSLab/EdgeNode

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CheckDiskIsFast() (speedMB float64, isFast bool, err error)
func CheckDiskWritingSpeed() (speedMB float64, err error)
func DiskIsExtremelyFast() bool
func DiskIsFast() bool
func ReadFile(filename string) (data []byte, err error)
func Remove(filename string) (err error)
func Rename(oldPath string, newPath string) (err error)
func WaitLoad(maxLoad float64, maxLoops int, delay time.Duration)
func WriteFile(filename string, data []byte, perm os.FileMode) (err error)
type DiskSpeedCache
type Limiter
- func NewLimiter(threads int) *Limiter
- func (this *Limiter) Ack()
- func (this *Limiter) FreeThreads() int
- func (this *Limiter) Release()
- func (this *Limiter) TryAck() bool
type Locker
- func NewLocker(path string) *Locker
- func (this *Locker) Lock() error
- func (this *Locker) Release() error
- func (this *Locker) TryLock() (ok bool, err error)
type Speed
- func (this Speed) String() string
type StatResult
- func NewStatResult(rawStat *unix.Statfs_t) *StatResult
- func StatDevice(path string) (*StatResult, error)
- func StatDeviceCache(path string) (*StatResult, error)
- func (this *StatResult) FreeSize() uint64
- func (this *StatResult) TotalSize() uint64
- func (this *StatResult) UsedSize() uint64

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DiskSpeed   = SpeedLow
	DiskSpeedMB float64
)

View Source

var IsInExtremelyHighLoad = false

View Source

var IsInHighLoad = false

View Source

var ReaderLimiter = NewLimiter(maxThreads)

View Source

var WriterLimiter = NewLimiter(maxThreads)

Functions ¶

func CheckDiskIsFast ¶ added in v1.2.5

func CheckDiskIsFast() (speedMB float64, isFast bool, err error)

CheckDiskIsFast check disk is 'fast' disk to write

func CheckDiskWritingSpeed ¶ added in v1.2.5

func CheckDiskWritingSpeed() (speedMB float64, err error)

CheckDiskWritingSpeed test disk writing speed

func DiskIsExtremelyFast ¶ added in v1.2.7

func DiskIsExtremelyFast() bool

func DiskIsFast ¶ added in v1.2.7

func DiskIsFast() bool

func ReadFile ¶ added in v1.3.7

func ReadFile(filename string) (data []byte, err error)

func Remove ¶ added in v1.3.7

func Remove(filename string) (err error)

func Rename ¶ added in v1.3.7

func Rename(oldPath string, newPath string) (err error)

func WaitLoad ¶ added in v1.3.5

func WaitLoad(maxLoad float64, maxLoops int, delay time.Duration)

WaitLoad wait system load to downgrade

func WriteFile ¶ added in v1.3.7

func WriteFile(filename string, data []byte, perm os.FileMode) (err error)

Types ¶

type DiskSpeedCache ¶ added in v1.2.10

type DiskSpeedCache struct {
	Speed   Speed   `json:"speed"`
	SpeedMB float64 `json:"speedMB"`
}

type Limiter ¶ added in v1.3.7

type Limiter struct {
	// contains filtered or unexported fields
}

func NewLimiter ¶ added in v1.3.7

func NewLimiter(threads int) *Limiter

func (*Limiter) Ack ¶ added in v1.3.7

func (this *Limiter) Ack()

func (*Limiter) FreeThreads ¶ added in v1.3.7

func (this *Limiter) FreeThreads() int

func (*Limiter) Release ¶ added in v1.3.7

func (this *Limiter) Release()

func (*Limiter) TryAck ¶ added in v1.3.7

func (this *Limiter) TryAck() bool

type Locker ¶ added in v1.2.7

type Locker struct {
	// contains filtered or unexported fields
}

func NewLocker ¶ added in v1.2.7

func NewLocker(path string) *Locker

func (*Locker) Lock ¶ added in v1.2.7

func (this *Locker) Lock() error

func (*Locker) Release ¶ added in v1.2.7

func (this *Locker) Release() error

func (*Locker) TryLock ¶ added in v1.2.7

func (this *Locker) TryLock() (ok bool, err error)

type Speed ¶ added in v1.2.7

type Speed int

const (
	SpeedExtremelyFast Speed = 1
	SpeedFast          Speed = 2
	SpeedLow           Speed = 3
	SpeedExtremelySlow Speed = 4
)

func (Speed) String ¶ added in v1.2.7

func (this Speed) String() string

type StatResult ¶

type StatResult struct {
	// contains filtered or unexported fields
}

func NewStatResult ¶

func NewStatResult(rawStat *unix.Statfs_t) *StatResult

func StatDevice ¶ added in v1.2.9

func StatDevice(path string) (*StatResult, error)

StatDevice device contains the path

func StatDeviceCache ¶ added in v1.2.9

func StatDeviceCache(path string) (*StatResult, error)

StatDeviceCache stat device with cache

func (*StatResult) FreeSize ¶

func (this *StatResult) FreeSize() uint64

func (*StatResult) TotalSize ¶

func (this *StatResult) TotalSize() uint64

func (*StatResult) UsedSize ¶

func (this *StatResult) UsedSize() uint64

Source Files ¶

View all Source files

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