vfs

Sep 23, 2023

Changes in this version

type AzureBlobPath

+ func (p *AzureBlobPath) RemoveAll() error

type FSPath

+ func (p *FSPath) RemoveAll() error

type GSPath

+ func (p *GSPath) RemoveAll() error

type KubernetesPath

+ func (p *KubernetesPath) RemoveAll() error

type MemFSPath

+ func (p *MemFSPath) RemoveAll() error

type Path

+ RemoveAll func() error

type S3Path

+ func (p *S3Path) RemoveAll() error

type SSHPath

+ func (p *SSHPath) RemoveAll() error

type SwiftPath

+ func (p *SwiftPath) RemoveAll() error

type VFSContext

+ func NewTestingVFSContext() *VFSContext

Mar 8, 2023

Changes in this version

+ func WithContext(parent context.Context, vfsContext *VFSContext) context.Context

type S3Path

+ func (p *S3Path) IsBucketPublic(ctx context.Context) (bool, error)

type VFSContext

+ func FromContext(ctx context.Context) *VFSContext

+ func NewVFSContext() *VFSContext

+ func (v *VFSContext) WithGCSClient(gcsClient *storage.Service) *VFSContext

Jul 8, 2022

Changes in this version

type MemFSPath

+ func (p *MemFSPath) IsPublic() (bool, error)

Mar 6, 2022

Changes in this version

type GSPath

+ func (p *GSPath) RenderTerraform(w *terraformWriter.TerraformWriter, name string, data io.Reader, acl ACL) error

+ func (p *GSPath) TerraformProvider() (*TerraformProvider, error)

+ func (s *GSPath) TerraformLink(name string) *terraformWriter.Literal

Nov 20, 2021

Changes in this version

type MemFSPath

+ func (p *MemFSPath) Location() string

+ func (p *MemFSPath) RenderTerraform(w *terraformWriter.TerraformWriter, name string, data io.Reader, acl ACL) error

+ func (p *MemFSPath) TerraformProvider() (*TerraformProvider, error)

type S3Path

+ func (p *S3Path) RenderTerraform(w *terraformWriter.TerraformWriter, name string, data io.Reader, acl ACL) error

+ func (p *S3Path) TerraformProvider() (*TerraformProvider, error)

+ type TerraformPath interface

+ RenderTerraform func(writer *terraformWriter.TerraformWriter, name string, data io.Reader, acl ACL) error

+ TerraformProvider func() (*TerraformProvider, error)

+ type TerraformProvider struct

+ Arguments map[string]string

+ Name string

Aug 22, 2021

Changes in this version

type S3Path

+ func (p *S3Path) IsPublic() (bool, error)

Jul 2, 2021

Changes in this version

type S3Path

+ func (p *S3Path) GetHTTPsUrl() (string, error)

Apr 9, 2021

Changes in this version

+ type AzureBlobPath struct

+ func NewAzureBlobPath(client *azureClient, container string, key string) *AzureBlobPath

+ func (p *AzureBlobPath) Base() string

+ func (p *AzureBlobPath) CreateFile(data io.ReadSeeker, acl ACL) error

+ func (p *AzureBlobPath) Hash(a hashing.HashAlgorithm) (*hashing.Hash, error)

+ func (p *AzureBlobPath) Join(relativePath ...string) Path

+ func (p *AzureBlobPath) Path() string

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

+ func (p *AzureBlobPath) ReadDir() ([]Path, error)

+ func (p *AzureBlobPath) ReadFile() ([]byte, error)

+ func (p *AzureBlobPath) ReadTree() ([]Path, error)

+ func (p *AzureBlobPath) Remove() error

+ func (p *AzureBlobPath) RemoveAllVersions() error

+ func (p *AzureBlobPath) WriteFile(data io.ReadSeeker, acl ACL) error

+ func (p *AzureBlobPath) WriteTo(w io.Writer) (n int64, err error)

Jan 29, 2021

Changes in this version

+ type VaultPath struct

+ func (p *VaultPath) Base() string

+ func (p *VaultPath) CreateFile(data io.ReadSeeker, acl ACL) error

+ func (p *VaultPath) Join(relativePath ...string) Path

+ func (p *VaultPath) Path() string

+ func (p *VaultPath) ReadDir() ([]Path, error)

+ func (p *VaultPath) ReadFile() ([]byte, error)

+ func (p *VaultPath) ReadTree() ([]Path, error)

+ func (p *VaultPath) Remove() error

+ func (p *VaultPath) RemoveAllVersions() error

+ func (p *VaultPath) String() string

+ func (p *VaultPath) WriteFile(data io.ReadSeeker, acl ACL) error

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

+ func (p VaultPath) SetClientToken(token string)

Aug 2, 2020

Changes in this version

type GSAcl

+ func (a *GSAcl) String() string

type OSSPath

+ func (p *OSSPath) Bucket() string

+ func (p *OSSPath) Key() string

May 30, 2020

Changes in this version

type FSPath

+ func (p *FSPath) RemoveAllVersions() error

type GSPath

+ func (p *GSPath) RemoveAllVersions() error

type KubernetesPath

+ func (p *KubernetesPath) RemoveAllVersions() error

type MemFSPath

+ func (p *MemFSPath) RemoveAllVersions() error

type OSSPath

+ func (p *OSSPath) RemoveAllVersions() error

type Path

+ RemoveAllVersions func() error

type S3Path

+ func (p *S3Path) RemoveAllVersions() error

type SSHPath

+ func (p *SSHPath) RemoveAllVersions() error

type SwiftPath

+ func (p *SwiftPath) RemoveAllVersions() error

Feb 27, 2020

Changes in this version

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) Read(p Path, ttl time.Duration) ([]byte, error)

Jan 30, 2020

Changes in this version

type OpenstackConfig

+ func (oc OpenstackConfig) GetRegion() (string, error)

+ type VFSOption func(options *vfsOptions)

+ func WithBackoff(backoff wait.Backoff) VFSOption

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)

Oct 10, 2016

Changes in this version

+ type S3Context struct

+ func NewS3Context() *S3Context

+ type WriteOption string

+ const WriteOptionCreate

+ const WriteOptionOnlyIfExists

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)