fs

package

Go to main page

Versions in this module

v1

v1.3.27

Feb 14, 2025

v1.3.26

Feb 7, 2025

Changes in this version

+ const MaxThrottlePct

+ const Throttle100ms

+ const Throttle10ms

+ const Throttle1ms

+ func ContainsCT(fqn, bname string) bool

+ func GetMaxUtil() (util int64)

+ func HasPrefixFntl(s string) bool

+ func IsFntl(objName string) bool

+ func IsMicroThrottle(n int64) bool

+ func IsMiniThrottle(n int64) bool

+ func IsThrottle(n int64) bool

+ func LikelyCT(s string) bool

+ func ShortenFntl(s string) string

+ func ThrottlePct() (int, int64, float64)

type Mountpath

+ LomCaches cos.MultiHashMap

+ func (mi *Mountpath) GetUtil() int64

v1.3.25

Oct 6, 2024

v1.3.24

Sep 27, 2024

Changes in this version

+ const Disk2Detach

+ const Disk2Disable

+ const DiskDetached

+ const DiskDisabled

+ const DiskFault

+ const DiskHighWM

+ const DiskOOS

+ const FlagDisabledByFSHC

+ func DiskStats(allds ios.AllDiskStats, tcdf *Tcdf, config *cmn.Config, refreshCap bool)

+ func HasAlert(disks []string) (alert string, idx int)

+ func ToMPL() (mpl *apc.MountpathList)

+ type HC interface

+ FSHC func(err error, mi *Mountpath, fqn string)

+ SoftFSHC func()

type Mountpath

+ func (mi *Mountpath) CheckFS() (err error)

+ func (mi *Mountpath) IsAvail() bool

+ func (mi *Mountpath) RescanDisks() (warn, err error)

+ func (mi *Mountpath) SetFlags(flags uint64) (ok bool)

+ type Tcdf struct

+ CsErr string

+ Mountpaths map[string]*CDF

+ PctAvg int32

+ PctMax int32

+ PctMin int32

+ TotalAvail uint64

+ TotalUsed uint64

+ func (tcdf *Tcdf) HasAlerts() bool

+ type TcdfExt struct

v1.3.23

May 27, 2024

Changes in this version

+ func ExpireCapCache()

+ func InitCDF(tcdf *TargetCDF)

+ func NoneShared(numMpaths int) bool

type CDF

+ Label ios.Label

+ type CDFv322 struct

+ Disks []string

+ FS string

+ type MFS struct

type Mountpath

+ Label ios.Label

type ParsedFQN

+ func (parsed *ParsedFQN) Init(fqn string) (err error)

type TargetCDF

+ TotalAvail uint64

+ TotalUsed uint64

+ type TargetCDFv322 struct

+ CsErr string

+ Mountpaths map[string]*CDFv322

+ PctAvg int32

+ PctMax int32

+ PctMin int32

type WalkBckOpts

+ ValidateCb walkFunc

type WalkOpts

+ Prefix string

v1.3.22

Feb 25, 2024

v1.3.21

Nov 5, 2023

Changes in this version

+ func ComputeDiskSize()

+ func GetDiskSize() uint64

+ func OnDiskSize(bck *cmn.Bck, prefix string) (size uint64)

type CapStatus

+ HighWM int64

+ PctMin int32

+ func (cs *CapStatus) IsOOS() bool

type Mountpath

+ func Hrw(uname string) (mi *Mountpath, digest uint64, err error)

type TargetCDF

+ PctMin int32

v1.3.20

Sep 12, 2023

v1.3.19

Aug 29, 2023

v1.3.18

Jul 9, 2023

Changes in this version

+ func Clblk()

+ func CleanPathErr(err error)

+ func RemoveAll(dir string) (err error)

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

Changes in this version

+ type CDF struct

+ Disks []string

+ FS string

type CapStatus

+ func Cap() (cs CapStatus)

+ func CapRefresh(config *cmn.Config, tcdf *TargetCDF) (cs CapStatus, err error)

+ type Mountpath struct

+ Disks []string

+ Path string

+ PathDigest uint64

+ func (mi *Mountpath) AddDisabled(disabledPaths MPI)

+ func (mi *Mountpath) AddEnabled(tid string, availablePaths MPI, config *cmn.Config) (err error)

+ func (mi *Mountpath) CheckDisks() (err error)

+ func (mi *Mountpath) ClearDD()

+ func (mi *Mountpath) ClearMDs()

+ func (mi *Mountpath) CreateMissingBckDirs(bck *cmn.Bck) (err error)

+ func (mi *Mountpath) DeletedRoot() string

+ func (mi *Mountpath) EvictLomCache()

+ func (mi *Mountpath) IsAnySet(flags uint64) bool

+ func (mi *Mountpath) IsIdle(config *cmn.Config) bool

+ func (mi *Mountpath) LomCache(idx int) *sync.Map

+ func (mi *Mountpath) MakePathBck(bck *cmn.Bck) string

+ func (mi *Mountpath) MakePathCT(bck *cmn.Bck, contentType string) string

+ func (mi *Mountpath) MakePathFQN(bck *cmn.Bck, contentType, objName string) string

+ func (mi *Mountpath) MoveToDeleted(dir string) (err error)

+ func (mi *Mountpath) Remove(path string) error

+ func (mi *Mountpath) RemoveDeleted(who string) (rerr error)

+ func (mi *Mountpath) SetDaemonIDXattr(tid string) error

+ func (mi *Mountpath) String() string

+ func (mi *Mountpath) TempDir(dir string) string

type ParsedFQN

+ Mountpath *Mountpath

type PartsFQN

+ Mountpath func() *Mountpath

+ type TargetCDF struct

+ CsErr string

+ Mountpaths map[string]*CDF

+ PctAvg int32

+ PctMax int32

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

v1.3.12

Nov 7, 2022

Changes in this version

+ const ECMetaType

+ const ECSliceType

+ const FlagBeingDetached

+ const FlagBeingDisabled

+ const FlagWaitingDD

+ const ObjectType

+ const SieFsDiffers

+ const SieMetaCorrupted

+ const SieMpathIDMismatch

+ const SieMpathNotFound

+ const SieNotEqVMD

+ const SieTargetIDMismatch

+ const WorkfileAppend

+ const WorkfileAppendToArch

+ const WorkfileColdget

+ const WorkfileCopy

+ const WorkfileCreateArch

+ const WorkfilePut

+ const WorkfileRemote

+ const WorkfileType

+ var CSM *contentSpecMgr

+ func AllMpathBcks(opts *WalkOpts) (bcks []cmn.Bck, err error)

+ func CapStatusGetWhat() (fsInfo apc.CapacityInfo)

+ func CountPersisted(fname string) (cnt int)

+ func CreateBucket(op string, bck *cmn.Bck, nilbmd bool) (errs []error)

+ func Decommission(mdOnly bool)

+ func DestroyBucket(op string, bck *cmn.Bck, bid uint64) (err error)

+ func DirectOpen(path string, flag int, perm os.FileMode) (*os.File, error) — darwin/amd64, linux/amd64

+ func FillDiskStats(m ios.AllDiskStats)

+ func Get() (MPI, MPI)

+ func GetAllMpathUtils() (utils *ios.MpathUtil)

+ func GetMpathUtil(mpath string) int64

+ func GetTotalDisksSize() (uint64, error)

+ func GetXattr(fqn, attrName string) ([]byte, error)

+ func GetXattrBuf(fqn, attrName string, buf []byte) (b []byte, err error)

+ func IsDirEmpty(dir string) (names []string, empty bool, err error)

+ func LcacheIdx(digest uint64) int

+ func LoadNodeID(mpaths cos.StrSet) (mDaeID string, err error)

+ func MarkerExists(marker string) bool

+ func MountpathsToLists() (mpl *apc.MountpathList)

+ func New(allowSharedDisksAndNoDisks bool)

+ func NumAvail() int

+ func PersistMarker(marker string) (fatalErr, writeErr error)

+ func PersistOnMpaths(fname, backupName string, meta jsp.Opts, atMost int, b []byte, sgl *memsys.SGL) (cnt, availCnt int)

+ func PutMPI(available, disabled MPI)

+ func RemoveDaemonIDs()

+ func RemoveMarker(marker string) (err error)

+ func RenameBucketDirs(bidFrom uint64, bckFrom, bckTo *cmn.Bck) (err error)

+ func SetXattr(fqn, attrName string, data []byte) (err error)

+ func TestDisableValidation()

+ func TestNew(iostater ios.IOStater)

+ func ValidateNCopies(tname string, copies int) (err error)

+ func Walk(opts *WalkOpts) error

+ func WalkBck(opts *WalkBckOpts) error

+ func WalkDir(dir string, ucb func(string, DirEntry) error) error

+ type CapStatus struct

+ Err error

+ OOS bool

+ PctAvg int32

+ PctMax int32

+ TotalAvail uint64

+ TotalUsed uint64

+ func CapPeriodic(now int64, config *cmn.Config, mpcap MPCap) (cs CapStatus, updated bool, err error)

+ func GetCapStatus() (cs CapStatus)

+ func RefreshCapStatus(config *cmn.Config, mpcap MPCap) (cs CapStatus, err error)

+ func (cs *CapStatus) IsNil() bool

+ func (cs *CapStatus) String() (str string)

+ type Capacity struct

+ Avail uint64

+ PctUsed int32

+ Used uint64

+ type ContentInfo struct

+ Base string

+ Dir string

+ Old bool

+ Type string

+ type ContentResolver interface

+ GenUniqueFQN func(base, prefix string) (ufqn string)

+ ParseUniqueFQN func(base string) (orig string, old, ok bool)

+ PermToEvict func() bool

+ PermToMove func() bool

+ PermToProcess func() bool

+ type DirEntry interface

+ IsDir func() bool

+ type ECMetaContentResolver struct

+ func (*ECMetaContentResolver) GenUniqueFQN(base, _ string) string

+ func (*ECMetaContentResolver) ParseUniqueFQN(base string) (orig string, old, ok bool)

+ func (*ECMetaContentResolver) PermToEvict() bool

+ func (*ECMetaContentResolver) PermToMove() bool

+ func (*ECMetaContentResolver) PermToProcess() bool

+ type ECSliceContentResolver struct

+ func (*ECSliceContentResolver) GenUniqueFQN(base, _ string) string

+ func (*ECSliceContentResolver) ParseUniqueFQN(base string) (orig string, old, ok bool)

+ func (*ECSliceContentResolver) PermToEvict() bool

+ func (*ECSliceContentResolver) PermToMove() bool

+ func (*ECSliceContentResolver) PermToProcess() bool

+ type ErrMountpathNoDisks struct

+ Mi *MountpathInfo

+ func (e *ErrMountpathNoDisks) Error() string

+ type ErrStorageIntegrity struct

+ Code int

+ Msg string

+ func (sie *ErrStorageIntegrity) Error() string

+ type FilesystemInfo struct

+ Fs string

+ FsID cos.FsID

+ FsType string

+ func (fsi *FilesystemInfo) Equal(otherFsi FilesystemInfo) bool

+ type MPCap map[string]Capacity

+ type MPI map[string]*MountpathInfo

+ func GetAvail() MPI

+ func (mpi MPI) String() string

+ type MountedFS struct

+ type MountpathInfo struct

+ Disks []string

+ Path string

+ PathDigest uint64

+ func Add(mpath, tid string) (mi *MountpathInfo, err error)

+ func AddMpath(mpath, tid string, cb func(), force bool) (mi *MountpathInfo, err error)

+ func BeginDD(action string, flags uint64, mpath string) (mi *MountpathInfo, numAvail int, err error)

+ func Disable(mpath string, cb ...func()) (disabledMpath *MountpathInfo, err error)

+ func Enable(mpath string) (enabledMpath *MountpathInfo, err error)

+ func EnableMpath(mpath, tid string, cb func()) (enabledMpath *MountpathInfo, err error)

+ func FQN2Mpath(fqn string) (found *MountpathInfo, relativePath string, err error)

+ func NewMountpath(mpath string) (mi *MountpathInfo, err error)

+ func Path2Mpath(path string) (found *MountpathInfo, err error)

+ func Remove(mpath string, cb ...func()) (*MountpathInfo, error)

+ func (mi *MountpathInfo) AddDisabled(disabledPaths MPI)

+ func (mi *MountpathInfo) AddEnabled(tid string, availablePaths MPI, config *cmn.Config) (err error)

+ func (mi *MountpathInfo) CheckDisks() (err error)

+ func (mi *MountpathInfo) ClearDD()

+ func (mi *MountpathInfo) ClearMDs()

+ func (mi *MountpathInfo) CreateMissingBckDirs(bck *cmn.Bck) (err error)

+ func (mi *MountpathInfo) DeletedRoot() string

+ func (mi *MountpathInfo) EvictLomCache()

+ func (mi *MountpathInfo) IsAnySet(flags uint64) bool

+ func (mi *MountpathInfo) IsIdle(config *cmn.Config) bool

+ func (mi *MountpathInfo) LomCache(idx int) *sync.Map

+ func (mi *MountpathInfo) MakePathBck(bck *cmn.Bck) string

+ func (mi *MountpathInfo) MakePathCT(bck *cmn.Bck, contentType string) string

+ func (mi *MountpathInfo) MakePathFQN(bck *cmn.Bck, contentType, objName string) string

+ func (mi *MountpathInfo) MoveToDeleted(dir string) (err error)

+ func (mi *MountpathInfo) Remove(path string) error

+ func (mi *MountpathInfo) RemoveDeleted(who string) (rerr error)

+ func (mi *MountpathInfo) SetDaemonIDXattr(tid string) error

+ func (mi *MountpathInfo) String() string

+ func (mi *MountpathInfo) TempDir(dir string) string

+ type ObjectContentResolver struct

+ func (*ObjectContentResolver) GenUniqueFQN(base, _ string) string

+ func (*ObjectContentResolver) ParseUniqueFQN(base string) (orig string, old, ok bool)

+ func (*ObjectContentResolver) PermToEvict() bool

+ func (*ObjectContentResolver) PermToMove() bool

+ func (*ObjectContentResolver) PermToProcess() bool

+ type ParsedFQN struct

+ Bck cmn.Bck

+ ContentType string

+ Digest uint64

+ MpathInfo *MountpathInfo

+ ObjName string

+ func ParseFQN(fqn string) (parsed ParsedFQN, err error)

+ type PartsFQN interface

+ Bucket func() *cmn.Bck

+ CacheIdx func() int

+ MpathInfo func() *MountpathInfo

+ ObjectName func() string

+ type WalkBckOpts struct

+ ValidateCallback walkFunc

+ type WalkOpts struct

+ Bck cmn.Bck

+ CTs []string

+ Callback walkFunc

+ Dir string

+ Mi *MountpathInfo

+ Sorted bool

+ type WorkfileContentResolver struct

+ func (*WorkfileContentResolver) GenUniqueFQN(base, prefix string) string

+ func (*WorkfileContentResolver) ParseUniqueFQN(base string) (orig string, old, ok bool)

+ func (*WorkfileContentResolver) PermToEvict() bool

+ func (*WorkfileContentResolver) PermToMove() bool

+ func (*WorkfileContentResolver) PermToProcess() bool

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