gcsfs

package
v1.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2023 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrNoBucketInName     = errors.New("no bucket name found in the name")
	ErrFileClosed         = errors.New("file is closed")
	ErrOutOfRange         = errors.New("out of range")
	ErrObjectDoesNotExist = errors.New("storage: object doesn't exist")
	ErrEmptyObjectName    = errors.New("storage: object name is empty")
	ErrFileNotFound       = syscall.ENOENT
)

Functions

func NewGcsFS added in v1.7.1 

func NewGcsFS(ctx context.Context, opts ...option.ClientOption) (afero.Fs, error)

NewGcsFS creates a GCS file system, automatically instantiating and decorating the storage client. You can provide additional options to be passed to the client creation, as per cloud.google.com/go/storage documentation

func NewGcsFSFromClient added in v1.7.1 

func NewGcsFSFromClient(ctx context.Context, client *storage.Client) (afero.Fs, error)

NewGcsFSFromClient creates a GCS file system from a given storage client

func NewGcsFSFromClientWithSeparator added in v1.7.1 

func NewGcsFSFromClientWithSeparator(ctx context.Context, client *storage.Client, folderSeparator string) (afero.Fs, error)

NewGcsFSFromClientWithSeparator is the same as NewGcsFSFromClient, but the file system will use the provided folder separator.

func NewGcsFSWithSeparator added in v1.7.1 

func NewGcsFSWithSeparator(ctx context.Context, folderSeparator string, opts ...option.ClientOption) (afero.Fs, error)

NewGcsFSWithSeparator is the same as NewGcsFS, but the files system will use the provided folder separator.

Types

type ByName 

type ByName []*FileInfo

func (ByName) Len 

func (a ByName) Len() int

func (ByName) Less 

func (a ByName) Less(i, j int) bool

func (ByName) Swap 

func (a ByName) Swap(i, j int)

type FileInfo 

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

func (*FileInfo) IsDir 

func (fi *FileInfo) IsDir() bool

func (*FileInfo) ModTime 

func (fi *FileInfo) ModTime() time.Time

func (*FileInfo) Mode 

func (fi *FileInfo) Mode() os.FileMode

func (*FileInfo) Name 

func (fi *FileInfo) Name() string

func (*FileInfo) Size 

func (fi *FileInfo) Size() int64

func (*FileInfo) Sys 

func (fi *FileInfo) Sys() interface{}

type Fs added in v1.7.1 

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

Fs is a Fs implementation that uses functions provided by google cloud storage

func NewGcsFs 

func NewGcsFs(ctx context.Context, client stiface.Client) *Fs

func NewGcsFsWithSeparator 

func NewGcsFsWithSeparator(ctx context.Context, client stiface.Client, folderSep string) *Fs

func (*Fs) Chmod added in v1.7.1 

func (fs *Fs) Chmod(_ string, _ os.FileMode) error

func (*Fs) Chown added in v1.7.1 

func (fs *Fs) Chown(_ string, _, _ int) error

func (*Fs) Chtimes added in v1.7.1 

func (fs *Fs) Chtimes(_ string, _, _ time.Time) error

func (*Fs) Create added in v1.7.1 

func (fs *Fs) Create(name string) (*GcsFile, error)

func (*Fs) Mkdir added in v1.7.1 

func (fs *Fs) Mkdir(name string, _ os.FileMode) error

func (*Fs) MkdirAll added in v1.7.1 

func (fs *Fs) MkdirAll(path string, perm os.FileMode) error

func (*Fs) Name added in v1.7.1 

func (fs *Fs) Name() string

func (*Fs) Open added in v1.7.1 

func (fs *Fs) Open(name string) (*GcsFile, error)

func (*Fs) OpenFile added in v1.7.1 

func (fs *Fs) OpenFile(name string, flag int, fileMode os.FileMode) (*GcsFile, error)

func (*Fs) Remove added in v1.7.1 

func (fs *Fs) Remove(name string) error

func (*Fs) RemoveAll added in v1.7.1 

func (fs *Fs) RemoveAll(path string) error

func (*Fs) Rename added in v1.7.1 

func (fs *Fs) Rename(oldName, newName string) error

func (*Fs) Stat added in v1.7.1 

func (fs *Fs) Stat(name string) (os.FileInfo, error)

type GcsFile 

type GcsFile struct {
	ReadDirIt stiface.ObjectIterator
	// contains filtered or unexported fields
}

GcsFs is the Afero version adapted for GCS

func NewGcsFile 

func NewGcsFile(
	ctx context.Context,
	fs *Fs,
	obj stiface.ObjectHandle,
	openFlags int,

	fileMode os.FileMode,
	name string,
) *GcsFile

func NewGcsFileFromOldFH 

func NewGcsFileFromOldFH(
	openFlags int,
	fileMode os.FileMode,
	oldFile *gcsFileResource,
) *GcsFile

func (*GcsFile) Close 

func (o *GcsFile) Close() error

func (*GcsFile) Name 

func (o *GcsFile) Name() string

func (*GcsFile) Read 

func (o *GcsFile) Read(p []byte) (n int, err error)

func (*GcsFile) ReadAt 

func (o *GcsFile) ReadAt(p []byte, off int64) (n int, err error)

func (*GcsFile) Readdir 

func (o *GcsFile) Readdir(count int) ([]os.FileInfo, error)

func (*GcsFile) Readdirnames 

func (o *GcsFile) Readdirnames(n int) ([]string, error)

func (*GcsFile) Seek 

func (o *GcsFile) Seek(newOffset int64, whence int) (int64, error)

func (*GcsFile) Stat 

func (o *GcsFile) Stat() (os.FileInfo, error)

func (*GcsFile) Sync 

func (o *GcsFile) Sync() error

func (*GcsFile) Truncate 

func (o *GcsFile) Truncate(wantedSize int64) error

func (*GcsFile) Write 

func (o *GcsFile) Write(p []byte) (n int, err error)

func (*GcsFile) WriteAt 

func (o *GcsFile) WriteAt(b []byte, off int64) (n int, err error)

func (*GcsFile) WriteString 

func (o *GcsFile) WriteString(s string) (ret int, err error)

type GcsFs 

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

func (*GcsFs) Chmod 

func (fs *GcsFs) Chmod(name string, mode os.FileMode) error

func (*GcsFs) Chown 

func (fs *GcsFs) Chown(name string, uid, gid int) error

func (*GcsFs) Chtimes 

func (fs *GcsFs) Chtimes(name string, atime time.Time, mtime time.Time) error

func (*GcsFs) Create 

func (fs *GcsFs) Create(name string) (afero.File, error)

func (*GcsFs) Mkdir 

func (fs *GcsFs) Mkdir(name string, perm os.FileMode) error

func (*GcsFs) MkdirAll 

func (fs *GcsFs) MkdirAll(path string, perm os.FileMode) error

func (*GcsFs) Name 

func (fs *GcsFs) Name() string

func (*GcsFs) Open 

func (fs *GcsFs) Open(name string) (afero.File, error)

func (*GcsFs) OpenFile 

func (fs *GcsFs) OpenFile(name string, flag int, perm os.FileMode) (afero.File, error)

func (*GcsFs) Remove 

func (fs *GcsFs) Remove(name string) error

func (*GcsFs) RemoveAll 

func (fs *GcsFs) RemoveAll(path string) error

func (*GcsFs) Rename 

func (fs *GcsFs) Rename(oldname, newname string) error

func (*GcsFs) Stat 

func (fs *GcsFs) Stat(name string) (os.FileInfo, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.