Versions in this module Expand all Collapse all v1 v1.15.1 Feb 17, 2020 v1.15.0 Feb 17, 2020 Changes in this version + var Context = VFSContext + func AWSErrorCode(err error) string + func CopyFile(src, dest Path, acl ACL) error + func CopyTree(src Path, dest Path, aclOracle ACLOracle) error + func IsClusterReadable(p Path) bool + func IsDirectory(p Path) bool + func NewAliOSSClient() (*oss.Client, error) + func NewSwiftClient() (*gophercloud.ServiceClient, error) + func RelativePath(base Path, child Path) (string, error) + func RetryWithBackoff(backoff wait.Backoff, condition func() (bool, error)) (bool, error) + func SyncDir(src *VFSScan, destBase Path) error + func VFSPath(url string) (string, error) + type ACL interface + type ACLOracle func(Path) (ACL, error) + type Change struct + ChangeType ChangeType + Hash *hashing.Hash + Path Path + type ChangeType string + const ChangeType_Added + const ChangeType_Modified + const ChangeType_Removed + type FSPath struct + func NewFSPath(location string) *FSPath + func (p *FSPath) Base() string + func (p *FSPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *FSPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *FSPath) Join(relativePath ...string) Path + func (p *FSPath) Path() string + func (p *FSPath) PreferredHash() (*hashing.Hash, error) + func (p *FSPath) ReadDir() ([]Path, error) + func (p *FSPath) ReadFile() ([]byte, error) + func (p *FSPath) ReadTree() ([]Path, error) + func (p *FSPath) Remove() error + func (p *FSPath) String() string + func (p *FSPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *FSPath) WriteTo(out io.Writer) (int64, error) + type GSAcl struct + Acl []*storage.ObjectAccessControl + type GSPath struct + func NewGSPath(client *storage.Service, bucket string, key string) *GSPath + func (p *GSPath) Base() string + func (p *GSPath) Bucket() string + func (p *GSPath) Client() *storage.Service + func (p *GSPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *GSPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *GSPath) Join(relativePath ...string) Path + func (p *GSPath) Object() string + func (p *GSPath) Path() string + func (p *GSPath) PreferredHash() (*hashing.Hash, error) + func (p *GSPath) ReadDir() ([]Path, error) + func (p *GSPath) ReadFile() ([]byte, error) + func (p *GSPath) ReadTree() ([]Path, error) + func (p *GSPath) Remove() error + func (p *GSPath) String() string + func (p *GSPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *GSPath) WriteTo(out io.Writer) (int64, error) + type HasClusterReadable interface + IsClusterReadable func() bool + type HasHash interface + Hash func(algorithm hashing.HashAlgorithm) (*hashing.Hash, error) + PreferredHash func() (*hashing.Hash, error) + type KubernetesContext struct + func NewKubernetesContext() *KubernetesContext + type KubernetesPath struct + func (p *KubernetesPath) Base() string + func (p *KubernetesPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *KubernetesPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *KubernetesPath) Host() string + func (p *KubernetesPath) Join(relativePath ...string) Path + func (p *KubernetesPath) Key() string + func (p *KubernetesPath) Path() string + func (p *KubernetesPath) PreferredHash() (*hashing.Hash, error) + func (p *KubernetesPath) ReadDir() ([]Path, error) + func (p *KubernetesPath) ReadFile() ([]byte, error) + func (p *KubernetesPath) ReadTree() ([]Path, error) + func (p *KubernetesPath) Remove() error + func (p *KubernetesPath) String() string + func (p *KubernetesPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *KubernetesPath) WriteTo(out io.Writer) (int64, error) + type MemFSContext struct + func NewMemFSContext() *MemFSContext + func (c *MemFSContext) MarkClusterReadable() + type MemFSPath struct + func NewMemFSPath(context *MemFSContext, location string) *MemFSPath + func (c *MemFSPath) HasChildren() bool + func (c *MemFSPath) IsClusterReadable() bool + func (p *MemFSPath) Base() string + func (p *MemFSPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *MemFSPath) Join(relativePath ...string) Path + func (p *MemFSPath) Path() string + func (p *MemFSPath) ReadDir() ([]Path, error) + func (p *MemFSPath) ReadFile() ([]byte, error) + func (p *MemFSPath) ReadTree() ([]Path, error) + func (p *MemFSPath) Remove() error + func (p *MemFSPath) String() string + func (p *MemFSPath) WriteFile(r io.ReadSeeker, acl ACL) error + func (p *MemFSPath) WriteTo(out io.Writer) (int64, error) + type OSSPath struct + func NewOSSPath(client *oss.Client, bucket string, key string) (*OSSPath, error) + func (p *OSSPath) Base() string + func (p *OSSPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *OSSPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *OSSPath) Join(relativePath ...string) Path + func (p *OSSPath) Path() string + func (p *OSSPath) PreferredHash() (*hashing.Hash, error) + func (p *OSSPath) ReadDir() ([]Path, error) + func (p *OSSPath) ReadFile() ([]byte, error) + func (p *OSSPath) ReadTree() ([]Path, error) + func (p *OSSPath) Remove() error + func (p *OSSPath) String() string + func (p *OSSPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *OSSPath) WriteTo(out io.Writer) (int64, error) + type OpenstackConfig struct + func (oc OpenstackConfig) GetCredential() (gophercloud.AuthOptions, error) + func (oc OpenstackConfig) GetRegion() (string, error) + func (oc OpenstackConfig) GetServiceConfig(name string) (gophercloud.EndpointOpts, error) + type Path interface + Base func() string + CreateFile func(data io.ReadSeeker, acl ACL) error + Join func(relativePath ...string) Path + Path func() string + ReadDir func() ([]Path, error) + ReadFile func() ([]byte, error) + ReadTree func() ([]Path, error) + Remove func() error + WriteFile func(data io.ReadSeeker, acl ACL) error + type S3Acl struct + RequestACL *string + type S3BucketDetails struct + type S3Context struct + func NewS3Context() *S3Context + type S3Path struct + func (p *S3Path) Base() string + func (p *S3Path) Bucket() string + func (p *S3Path) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *S3Path) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *S3Path) Join(relativePath ...string) Path + func (p *S3Path) Key() string + func (p *S3Path) Path() string + func (p *S3Path) PreferredHash() (*hashing.Hash, error) + func (p *S3Path) ReadDir() ([]Path, error) + func (p *S3Path) ReadFile() ([]byte, error) + func (p *S3Path) ReadTree() ([]Path, error) + func (p *S3Path) Remove() error + func (p *S3Path) String() string + func (p *S3Path) WriteFile(data io.ReadSeeker, aclObj ACL) error + func (p *S3Path) WriteTo(out io.Writer) (int64, error) + type SSHAcl struct + Mode os.FileMode + type SSHPath struct + func NewSSHPath(client *ssh.Client, server string, path string, sudo bool) *SSHPath + func (p *SSHPath) Base() string + func (p *SSHPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *SSHPath) Join(relativePath ...string) Path + func (p *SSHPath) Path() string + func (p *SSHPath) ReadDir() ([]Path, error) + func (p *SSHPath) ReadFile() ([]byte, error) + func (p *SSHPath) ReadTree() ([]Path, error) + func (p *SSHPath) Remove() error + func (p *SSHPath) String() string + func (p *SSHPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *SSHPath) WriteTo(out io.Writer) (int64, error) + type SwiftPath struct + func NewSwiftPath(client *gophercloud.ServiceClient, bucket string, key string) (*SwiftPath, error) + func (p *SwiftPath) Base() string + func (p *SwiftPath) Bucket() string + func (p *SwiftPath) CreateFile(data io.ReadSeeker, acl ACL) error + func (p *SwiftPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error) + func (p *SwiftPath) Join(relativePath ...string) Path + func (p *SwiftPath) Path() string + func (p *SwiftPath) PreferredHash() (*hashing.Hash, error) + func (p *SwiftPath) ReadDir() ([]Path, error) + func (p *SwiftPath) ReadFile() ([]byte, error) + func (p *SwiftPath) ReadTree() ([]Path, error) + func (p *SwiftPath) Remove() error + func (p *SwiftPath) String() string + func (p *SwiftPath) WriteFile(data io.ReadSeeker, acl ACL) error + func (p *SwiftPath) WriteTo(out io.Writer) (int64, error) + type VFS interface + type VFSContext struct + func (c *VFSContext) BuildVfsPath(p string) (Path, error) + func (c *VFSContext) ReadFile(location string, options ...VFSOption) ([]byte, error) + func (c *VFSContext) ResetMemfsContext(clusterReadable bool) + type VFSOption func(options *vfsOptions) + func WithBackoff(backoff wait.Backoff) VFSOption + type VFSScan struct + Base Path + func NewVFSScan(base Path) *VFSScan + func (v *VFSScan) Scan() ([]Change, error) + type WriteOption string + const WriteOptionCreate + const WriteOptionOnlyIfExists