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)

Jump to

Keyboard shortcuts

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