taskfs

Documentation

Index

• func IsSubPath(parent, sub string) (bool, error)
• type DiskFS
  • func CreateDiskFS() (*DiskFS, error)
  • func (self *DiskFS) AddInput(input *taskstorage.FileUrl) error
  • func (self *DiskFS) AddOutput(output *taskstorage.FileUrl) error
  • func (self *DiskFS) Close() error
  • func (self *DiskFS) Flush() error
  • func (self *DiskFS) RootPath() string
  • func (self *DiskFS) ToFullPath(file *taskstorage.FileUrl) (string, error)
• type FileSystem
• type VirtualFS
  • func CreateVirtualFS() (*VirtualFS, error)
  • func (self *VirtualFS) AddInput(input *taskstorage.FileUrl) error
  • func (self *VirtualFS) AddOutput(output *taskstorage.FileUrl) error
  • func (self *VirtualFS) Close() error
  • func (self *VirtualFS) Flush() error
  • func (self *VirtualFS) RootPath() string
  • func (self *VirtualFS) ToFullPath(file *taskstorage.FileUrl) (string, error)

Functions

func IsSubPath

func IsSubPath(parent, sub string) (bool, error)

Types

type DiskFS

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

func CreateDiskFS

func CreateDiskFS() (*DiskFS, error)

func (*DiskFS) AddInput

func (self *DiskFS) AddInput(input *taskstorage.FileUrl) error

func (*DiskFS) AddOutput

func (self *DiskFS) AddOutput(output *taskstorage.FileUrl) error

func (*DiskFS) Close

func (self *DiskFS) Close() error

func (*DiskFS) Flush

func (self *DiskFS) Flush() error

func (*DiskFS) RootPath

func (self *DiskFS) RootPath() string

func (*DiskFS) ToFullPath

func (self *DiskFS) ToFullPath(file *taskstorage.FileUrl) (string, error)

type FileSystem

type FileSystem interface {
	AddInput(input *taskstorage.FileUrl) error
	AddOutput(output *taskstorage.FileUrl) error

	RootPath() string
	ToFullPath(file *taskstorage.FileUrl) (string, error)

	// Flush will ensure all the files have been uploaded
	Flush() error
	// Close will close the filesystem entirely
	Close() error
}

type VirtualFS

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

func CreateVirtualFS

func CreateVirtualFS() (*VirtualFS, error)

func (*VirtualFS) AddInput

func (self *VirtualFS) AddInput(input *taskstorage.FileUrl) error

func (*VirtualFS) AddOutput

func (self *VirtualFS) AddOutput(output *taskstorage.FileUrl) error

func (*VirtualFS) Close

func (self *VirtualFS) Close() error

func (*VirtualFS) Flush

func (self *VirtualFS) Flush() error

Flush is a no-op in virtual fs

func (*VirtualFS) RootPath

func (self *VirtualFS) RootPath() string

func (*VirtualFS) ToFullPath

func (self *VirtualFS) ToFullPath(file *taskstorage.FileUrl) (string, error)