storage

Mar 11, 2015

Changes in this version

+ func LockedMutate(a Accessor, l sync.Locker, f func() error) (err error)

+ func Mutate(a Accessor, f func() error) (err error)

+ type Accessor interface

+ BeginUpdate func() error

+ Close func() error

+ EndUpdate func() error

+ Name func() string

+ ReadAt func(b []byte, off int64) (n int, err error)

+ Stat func() (fi os.FileInfo, err error)

+ Sync func() (err error)

+ Truncate func(size int64) error

+ WriteAt func(b []byte, off int64) (n int, err error)

+ func NewFile(name string, flag int, perm os.FileMode) (store Accessor, err error)

+ func NewMem(f *os.File) (store Accessor, err error)

+ func OpenFile(name string, flag int, perm os.FileMode) (store Accessor, err error)

+ func OpenMem(f *os.File) (store Accessor, err error)

+ type Cache struct

+ Load int64

+ Purge int64

+ Rq int64

+ Top int

+ func NewCache(store Accessor, maxcache int64, advise func(int64, int, bool)) (c *Cache, err error)

+ func (c *Cache) Accessor() Accessor

+ func (c *Cache) BeginUpdate() error

+ func (c *Cache) Close() (err error)

+ func (c *Cache) EndUpdate() error

+ func (c *Cache) Name() (s string)

+ func (c *Cache) ReadAt(b []byte, off int64) (n int, err error)

+ func (c *Cache) Stat() (fi os.FileInfo, err error)

+ func (c *Cache) Sync() (err error)

+ func (c *Cache) Truncate(size int64) (err error)

+ func (c *Cache) WriteAt(b []byte, off int64) (n int, err error)

+ type FileAccessor struct

+ func (f *FileAccessor) BeginUpdate() error

+ func (f *FileAccessor) EndUpdate() error

+ type FileInfo struct

+ FIsDir bool

+ FModTime time.Time

+ FMode os.FileMode

+ FName string

+ FSize int64

+ func NewFileInfo(fi os.FileInfo, sys interface{}) *FileInfo

+ func (fi *FileInfo) IsDir() bool

+ func (fi *FileInfo) ModTime() time.Time

+ func (fi *FileInfo) Mode() os.FileMode

+ func (fi *FileInfo) Name() string

+ func (fi *FileInfo) Size() int64

+ func (fi *FileInfo) Sys() interface{}

+ type Probe struct

+ BytesRd int64

+ BytesWr int64

+ Chain *Probe

+ OpsRd int64

+ OpsWr int64

+ SectorsRd int64

+ SectorsWr int64

+ func NewProbe(src Accessor, chain *Probe) *Probe

+ func (p *Probe) ReadAt(b []byte, off int64) (n int, err error)

+ func (p *Probe) Reset()

+ func (p *Probe) WriteAt(b []byte, off int64) (n int, err error)