Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

muxfys

package module

Go to main page

Versions in this module

v1

v1.0.0

May 19, 2017

v0

v0.0.3

May 13, 2017

v0.0.2

May 12, 2017

Changes in this version

+ type RemoteAccessor interface

+ CopyFile func(source, dest string) error

+ DeleteFile func(path string) error

+ DownloadFile func(source, dest string) error

+ ErrorIsNotExists func(err error) bool

+ ListEntries func(dir string) ([]RemoteAttr, error)

+ LocalPath func(baseDir, remotePath string) (localPath string)

+ OpenFile func(path string) (io.ReadCloser, error)

+ RemotePath func(relPath string) (absPath string)

+ Seek func(rc io.ReadCloser, offset int64) error

+ Target func() string

+ UploadFile func(source, dest, contentType string) error

+ type RemoteAttr struct

+ MD5 string

+ MTime time.Time

+ Name string

+ Size int64

+ type RemoteConfig struct

+ Accessor RemoteAccessor

+ CacheData bool

+ CacheDir string

+ Write bool

+ type S3Accessor struct

+ func NewS3Accessor(config *S3Config) (a *S3Accessor, err error)

+ func (a *S3Accessor) CopyFile(source, dest string) error

+ func (a *S3Accessor) DeleteFile(path string) error

+ func (a *S3Accessor) DownloadFile(source, dest string) error

+ func (a *S3Accessor) ErrorIsNotExists(err error) bool

+ func (a *S3Accessor) ListEntries(dir string) (ras []RemoteAttr, err error)

+ func (a *S3Accessor) LocalPath(baseDir, remotePath string) string

+ func (a *S3Accessor) OpenFile(path string) (io.ReadCloser, error)

+ func (a *S3Accessor) RemotePath(relPath string) string

+ func (a *S3Accessor) Seek(rc io.ReadCloser, offset int64) error

+ func (a *S3Accessor) Target() string

+ func (a *S3Accessor) UploadFile(source, dest, contentType string) error

+ type S3Config struct

+ AccessKey string

+ Region string

+ SecretKey string

+ Target string

+ func S3ConfigFromEnvironment(profile, path string) (c *S3Config, err error)

v0.0.1

May 11, 2017

Changes in this version

+ func NewCachedFile(r *remote, remotePath, localPath string, attr *fuse.Attr, flags uint32, ...) nodefs.File

+ func NewS3File(r *remote, path string, size uint64) nodefs.File

+ func SetLogHandler(h log15.Handler)

+ type CacheTracker struct

+ func NewCacheTracker() *CacheTracker

+ func (c *CacheTracker) CacheDelete(path string)

+ func (c *CacheTracker) CacheOverride(path string, iv Interval)

+ func (c *CacheTracker) CacheRename(oldPath, newPath string)

+ func (c *CacheTracker) CacheTruncate(path string, offset int64)

+ func (c *CacheTracker) CacheWipe()

+ func (c *CacheTracker) Cached(path string, iv Interval)

+ func (c *CacheTracker) Uncached(path string, iv Interval) Intervals

+ type CachedFile struct

+ func (f *CachedFile) InnerFile() nodefs.File

+ func (f *CachedFile) Read(buf []byte, offset int64) (fuse.ReadResult, fuse.Status)

+ func (f *CachedFile) Utimens(Atime *time.Time, Mtime *time.Time) (status fuse.Status)

+ func (f *CachedFile) Write(data []byte, offset int64) (uint32, fuse.Status)

+ type Config struct

+ CacheBase string

+ Mount string

+ Retries int

+ Targets []*Target

+ Verbose bool

+ type Interval struct

+ End int64

+ Start int64

+ func NewInterval(start, length int64) Interval

+ func (i *Interval) Length() int64

+ func (i *Interval) Merge(j Interval) bool

+ func (i *Interval) Overlaps(j Interval) bool

+ func (i *Interval) OverlapsOrAdjacent(j Interval) bool

+ type Intervals []Interval

+ func (ivs Intervals) Difference(iv Interval) Intervals

+ func (ivs Intervals) Merge(iv Interval) Intervals

+ func (ivs Intervals) Truncate(pos int64) Intervals

+ type MuxFys struct

+ func New(config *Config) (fs *MuxFys, err error)

+ func (fs *MuxFys) Access(name string, mode uint32, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Chmod(name string, mode uint32, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Chown(name string, uid uint32, gid uint32, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Create(name string, flags uint32, mode uint32, context *fuse.Context) (nodefs.File, fuse.Status)

+ func (fs *MuxFys) GetAttr(name string, context *fuse.Context) (attr *fuse.Attr, status fuse.Status)

+ func (fs *MuxFys) Logs() []string

+ func (fs *MuxFys) Mkdir(name string, mode uint32, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Mount() (err error)

+ func (fs *MuxFys) OnMount(nodeFs *pathfs.PathNodeFs)

+ func (fs *MuxFys) Open(name string, flags uint32, context *fuse.Context) (file nodefs.File, status fuse.Status)

+ func (fs *MuxFys) OpenDir(name string, context *fuse.Context) ([]fuse.DirEntry, fuse.Status)

+ func (fs *MuxFys) Readlink(name string, context *fuse.Context) (out string, status fuse.Status)

+ func (fs *MuxFys) Rename(oldPath string, newPath string, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Rmdir(name string, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) SetXAttr(name string, attr string, data []byte, flags int, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) StatFs(name string) *fuse.StatfsOut

+ func (fs *MuxFys) Symlink(source string, dest string, context *fuse.Context) (status fuse.Status)

+ func (fs *MuxFys) Truncate(name string, offset uint64, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Unlink(name string, context *fuse.Context) fuse.Status

+ func (fs *MuxFys) Unmount(doNotUpload ...bool) (err error)

+ func (fs *MuxFys) UnmountOnDeath()

+ func (fs *MuxFys) Utimens(name string, Atime *time.Time, Mtime *time.Time, context *fuse.Context) (status fuse.Status)

+ type S3File struct

+ func (f *S3File) Fsync(flags int) fuse.Status

+ func (f *S3File) Read(buf []byte, offset int64) (fuse.ReadResult, fuse.Status)

+ func (f *S3File) Release()

+ type Target struct

+ AccessKey string

+ CacheData bool

+ CacheDir string

+ Region string

+ SecretKey string

+ Target string

+ Write bool

+ func (t *Target) CreateRemote(cacheBase string, maxAttempts int, logger log15.Logger) (r *remote, err error)

+ func (t *Target) ReadEnvironment(profile, path string) error

Incompatible versions in this module

v3.0.5+incompatible

Sep 3, 2018

v3.0.4+incompatible

Aug 28, 2018

v3.0.3+incompatible

Jul 25, 2018

v3.0.2+incompatible

Apr 13, 2018

v3.0.1+incompatible

Apr 6, 2018

v3.0.0+incompatible

Mar 17, 2018

v2.0.6+incompatible

Jan 17, 2018

v2.0.5+incompatible

Nov 13, 2017

v2.0.4+incompatible

Sep 20, 2017

v2.0.3+incompatible

Aug 11, 2017

v2.0.2+incompatible

Aug 1, 2017

v2.0.1+incompatible

Jul 19, 2017

v2.0.0+incompatible

Jun 29, 2017

Other modules containing this package

github.com/VertebrateResequencing/muxfys/v4