storage

Documentation

Index

• Variables
• func AddDelimiterToPath(path string) string
• func DeleteObjectsWhere(folder Folder, confirm bool, objFilter func(object1 Object) bool, ...) error
• func GetPathFromPrefix(prefix string) (bucket, server string, err error)
• func JoinPath(elem ...string) string
• func ParsePrefixAsURL(prefix string) (bucket, server string, err error)
• func RunFolderTest(storageFolder Folder, t *testing.T)
• type Error
  • func NewError(err error, storageName, format string, args ...interface{}) Error
  • func (err Error) Error() string
• type Folder
• type LocalObject
  • func NewLocalObject(name string, lastModified time.Time, size int64) *LocalObject
  • func (object LocalObject) GetLastModified() time.Time
  • func (object LocalObject) GetName() string
  • func (object LocalObject) GetSize() int64
• type Object
  • func ListFolderRecursively(folder Folder) (relativePathObjects []Object, err error)
  • func ListFolderRecursivelyWithFilter(folder Folder, selector func(path string) bool) (relativePathObjects []Object, err error)
• type ObjectNotFoundError
  • func NewObjectNotFoundError(path string) ObjectNotFoundError
  • func (err ObjectNotFoundError) Error() string
• type ObjectProvider
  • func NewObjectProvider() *ObjectProvider
  • func (p *ObjectProvider) AddErrorToProvider(err error) bool
  • func (p *ObjectProvider) AddObjectToProvider(o Object) error
  • func (p *ObjectProvider) Close()
  • func (p *ObjectProvider) GetObject() (Object, error)
  • func (p *ObjectProvider) ObjectsCount() int

Variables

var (
	ErrNoMoreObjects  = errors.New("no more objects")
	ErrProviderClosed = errors.New("provider closed")
)

Functions

func AddDelimiterToPath

func AddDelimiterToPath(path string) string

func DeleteObjectsWhere

func DeleteObjectsWhere(folder Folder, confirm bool, objFilter func(object1 Object) bool, folderFilter func(name string) bool) error

func GetPathFromPrefix

func GetPathFromPrefix(prefix string) (bucket, server string, err error)

func JoinPath

func JoinPath(elem ...string) string

func ParsePrefixAsURL

func ParsePrefixAsURL(prefix string) (bucket, server string, err error)

func RunFolderTest

func RunFolderTest(storageFolder Folder, t *testing.T)

nolint: funlen

Types

type Error

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

func NewError

func NewError(err error, storageName, format string, args ...interface{}) Error

func (Error) Error

func (err Error) Error() string

type Folder

type Folder interface {
	// Path should always ends with '/'
	GetPath() string

	// Should return objects with relative paths
	ListFolder() (objects []Object, subFolders []Folder, err error)

	// Delete object, if exists
	DeleteObjects(objectRelativePaths []string) error

	Exists(objectRelativePath string) (bool, error)

	// Returns handle to subfolder. Does not have to instantiate subfolder in any material form
	GetSubFolder(subFolderRelativePath string) Folder

	// Should return ObjectNotFoundError in case, there is no such object
	ReadObject(objectRelativePath string) (io.ReadCloser, error)

	PutObject(name string, content io.Reader) error

	CopyObject(srcPath string, dstPath string) error
}

type LocalObject

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

func NewLocalObject

func NewLocalObject(name string, lastModified time.Time, size int64) *LocalObject

func (LocalObject) GetLastModified

func (object LocalObject) GetLastModified() time.Time

func (LocalObject) GetName

func (object LocalObject) GetName() string

func (LocalObject) GetSize

func (object LocalObject) GetSize() int64

type Object

type Object interface {
	GetName() string
	GetLastModified() time.Time
	GetSize() int64
}

func ListFolderRecursively

func ListFolderRecursively(folder Folder) (relativePathObjects []Object, err error)

func ListFolderRecursivelyWithFilter

func ListFolderRecursivelyWithFilter(folder Folder, selector func(path string) bool) (relativePathObjects []Object, err error)

type ObjectNotFoundError

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

func NewObjectNotFoundError

func NewObjectNotFoundError(path string) ObjectNotFoundError

func (ObjectNotFoundError) Error

func (err ObjectNotFoundError) Error() string

type ObjectProvider

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

func NewObjectProvider

func NewObjectProvider() *ObjectProvider

func (*ObjectProvider) AddErrorToProvider

func (p *ObjectProvider) AddErrorToProvider(err error) bool

func (*ObjectProvider) AddObjectToProvider

func (p *ObjectProvider) AddObjectToProvider(o Object) error

func (*ObjectProvider) Close

func (p *ObjectProvider) Close()

func (*ObjectProvider) GetObject

func (p *ObjectProvider) GetObject() (Object, error)

func (*ObjectProvider) ObjectsCount

func (p *ObjectProvider) ObjectsCount() int