fio

Nov 17, 2024

Changes in this version

type Info

+ func (ii *Info) Marshal() ([]byte, error)

Nov 13, 2024

Changes in this version

+ type FioMap = xsync.MapOf[string, *Info]

+ func NewFioMap() *FioMap

+ type FioPairMap = xsync.MapOf[string, Pair]

+ func NewFioPairMap() *FioPairMap

+ type Pair struct

+ Dst *Info

+ Src *Info

Nov 4, 2024

Changes in this version

+ var ErrCompleted = errors.New("workpool: workpool closed")

+ var ErrNotClosed = errors.New("workpool: workpool not closed before waiting")

+ type CopyError struct

+ Dst string

+ Err error

+ Op string

+ Src string

+ func (e *CopyError) Error() string

+ func (e *CopyError) Unwrap() error

+ type WorkPool struct

+ func NewWorkPool[Work any](nworkers int, fp func(i int, w Work) error) *WorkPool[Work]

+ func (wp *WorkPool[Work]) Close()

+ func (wp *WorkPool[Work]) Err(err error)

+ func (wp *WorkPool[Work]) Submit(w Work)

+ func (wp *WorkPool[Work]) Wait() error

Oct 24, 2024

Changes in this version

type Info

+ func (a *Info) IsSameFS(b *Info) bool

Oct 23, 2024

Changes in this version

+ func CloneMetadata(dst, src string) error

+ func UpdateMetadata(dst string, fi *Info) error

Oct 22, 2024

Changes in this version

+ var ErrTooSmall = errors.New("buffer is not big enough")

+ func ClearXattr(nm string) error

+ func DelXattr(nm string, keys ...string) error

+ func LclearXattr(nm string) error

+ func LdelXattr(nm string, keys ...string) error

+ func LreplaceXattr(nm string, x Xattr) error

+ func LsetXattr(nm string, x Xattr) error

+ func Lstatm(nm string, fi *Info) error

+ func ReplaceXattr(nm string, x Xattr) error

+ func SetXattr(nm string, x Xattr) error

+ func Statm(nm string, fi *Info) error

+ type Info struct

+ Atim time.Time

+ Ctim time.Time

+ Dev uint64

+ Gid uint32

+ Ino uint64

+ Mod fs.FileMode

+ Mtim time.Time

+ Nam string

+ Nlink uint32

+ Rdev uint64

+ Siz int64

+ Uid uint32

+ Xattr Xattr

+ func Lstat(nm string) (*Info, error)

+ func Stat(nm string) (*Info, error)

+ func (ii *Info) IsDir() bool

+ func (ii *Info) IsRegular() bool

+ func (ii *Info) MarshalSize() int

+ func (ii *Info) MarshalTo(b []byte) (int, error)

+ func (ii *Info) ModTime() time.Time

+ func (ii *Info) Mode() fs.FileMode

+ func (ii *Info) Name() string

+ func (ii *Info) Size() int64

+ func (ii *Info) String() string

+ func (ii *Info) Sys() any

+ func (ii *Info) Unmarshal(b []byte) (int, error)

type Xattr

+ func GetXattr(nm string) (Xattr, error)

+ func LgetXattr(nm string) (Xattr, error)

+ func (x Xattr) Equal(y Xattr) bool

Oct 14, 2024

Changes in this version

+ const OPT_COW

+ const OPT_OVERWRITE

+ func CloneFile(src, dst string) error

+ func CopyFd(src, dst *os.File) error

+ func CopyFile(src, dst string, perm fs.FileMode) error

+ type SafeFile struct

+ func NewSafeFile(nm string, opts uint32, flag int, perm os.FileMode) (*SafeFile, error)

+ func (sf *SafeFile) Abort()

+ func (sf *SafeFile) Close() error

+ func (sf *SafeFile) Write(b []byte) (int, error)

+ func (sf *SafeFile) WriteAt(b []byte, off int64) (int, error)

+ type Xattr map[string]string

+ func (x Xattr) String() string