fs

Documentation

Index

• func IsRetryableError(err error) bool
• type Config
  • func (cfg *Config) Cast() error
  • func (cfg *Config) Clone() *Config
  • func (cfg *Config) Equal(other *Config) bool
• type FS
  • func New(opts *Config) (*FS, error)
  • func (fs *FS) Copy(src, dst string) error
  • func (fs *FS) Delete(name string) error
  • func (fs *FS) FileStat(name string) (storage.FileInfo, error)
  • func (fs *FS) List(prefix, suffix string) ([]storage.FileInfo, error)
  • func (fs *FS) Save(name string, data io.Reader, _ int64) error
  • func (fs *FS) SourceReader(name string) (io.ReadCloser, error)
  • func (*FS) Type() storage.Type
• type RetryableError
  • func (e *RetryableError) Error() string

Functions

func IsRetryableError

func IsRetryableError(err error) bool

Types

type Config

type Config struct {
	Path string `bson:"path" json:"path" yaml:"path"`
}

func (*Config) Cast

func (cfg *Config) Cast() error

func (*Config) Clone

func (cfg *Config) Clone() *Config

func (*Config) Equal

func (cfg *Config) Equal(other *Config) bool

type FS

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

func New

func New(opts *Config) (*FS, error)

func (*FS) Copy

func (fs *FS) Copy(src, dst string) error

func (*FS) Delete

func (fs *FS) Delete(name string) error

Delete deletes given file from FS. It returns storage.ErrNotExist if a file isn't exists

func (*FS) FileStat

func (fs *FS) FileStat(name string) (storage.FileInfo, error)

func (*FS) List

func (fs *FS) List(prefix, suffix string) ([]storage.FileInfo, error)

func (*FS) Save

func (fs *FS) Save(name string, data io.Reader, _ int64) error

func (*FS) SourceReader

func (fs *FS) SourceReader(name string) (io.ReadCloser, error)

func (*FS) Type

func (*FS) Type() storage.Type

type RetryableError

type RetryableError struct {
	Err error
}

func (*RetryableError) Error

func (e *RetryableError) Error() string