vfs

package

Go to main page

Versions in this module

v1

v1.10.0

Aug 16, 2018

Changes in this version

+ func CopyFile(src, dest Path, acl ACL) error

+ func CopyTree(src Path, dest Path, aclOracle ACLOracle) error

+ func NewAliOSSClient() (*oss.Client, error)

+ func NewSwiftClient() (*gophercloud.ServiceClient, error)

+ func RetryWithBackoff(backoff wait.Backoff, condition func() (bool, error)) (bool, error)

+ func VFSPath(url string) (string, error)

+ type ACL interface

+ type ACLOracle func(Path) (ACL, error)

type FSPath

+ 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 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 MemFSPath

+ func (c *MemFSPath) HasChildren() bool

+ 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) GetServiceConfig(name string) (gophercloud.EndpointOpts, error)

+ type S3Acl struct

+ RequestACL *string

+ type S3BucketDetails struct

type S3Path

+ func (p *S3Path) WriteTo(out io.Writer) (int64, error)

+ type SSHAcl struct

+ Mode os.FileMode

type SSHPath

+ 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 VFSContext

+ func (c *VFSContext) ResetMemfsContext(clusterReadable bool)

v1.4.4

Dec 21, 2016

v1.4.3

Dec 14, 2016

v1.4.2

Dec 13, 2016

v1.4.1

Oct 10, 2016

Changes in this version

+ type S3Context struct

+ func NewS3Context() *S3Context

+ type WriteOption string

+ const WriteOptionCreate

+ const WriteOptionOnlyIfExists

v1.4.0

Oct 2, 2016

Changes in this version

+ func AWSErrorCode(err error) string

+ func IsClusterReadable(p Path) bool

+ func IsDirectory(p Path) bool

+ func RelativePath(base Path, child Path) (string, error)

+ func SyncDir(src *VFSScan, destBase Path) 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 []byte) 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 []byte) error

+ type HasClusterReadable interface

+ IsClusterReadable func() bool

+ type HasHash interface

+ Hash func(algorithm hashing.HashAlgorithm) (*hashing.Hash, error)

+ PreferredHash func() (*hashing.Hash, error)

+ type MemFSContext struct

+ func NewMemFSContext() *MemFSContext

+ func (c *MemFSContext) MarkClusterReadable()

+ type MemFSPath struct

+ func NewMemFSPath(context *MemFSContext, location string) *MemFSPath

+ func (c *MemFSPath) IsClusterReadable() bool

+ func (p *MemFSPath) Base() string

+ func (p *MemFSPath) CreateFile(data []byte) 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(data []byte) error

+ type Path interface

+ Base func() string

+ CreateFile func(data []byte) 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 []byte) error

+ type S3Path struct

+ func NewS3Path(client *s3.S3, bucket string, key string) *S3Path

+ func (p *S3Path) Base() string

+ func (p *S3Path) Bucket() string

+ func (p *S3Path) CreateFile(data []byte) 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 []byte) error

+ 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 []byte) 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 []byte) error

+ type VFS interface

+ type VFSContext struct

+ var Context VFSContext

+ func (c *VFSContext) BuildVfsPath(p string) (Path, error)

+ func (c *VFSContext) ReadFile(location string) ([]byte, error)

+ type VFSScan struct

+ Base Path

+ func NewVFSScan(base Path) *VFSScan

+ func (v *VFSScan) Scan() ([]Change, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL