objectstorage

Documentation

Index

• func IsNotExist(err error) bool
• func NewErrNotExist(err error, format string, args ...interface{}) error
• type ErrNotExist
• type EscapeError
  • func (e EscapeError) Error() string
• type ObjStorage
  • func NewObjStorage(s Storage, delimiter string) *ObjStorage
  • func (s *ObjStorage) Delimiter() string
  • func (s *ObjStorage) List(prefix, startWith string, recursive bool, doneCh <-chan struct{}) <-chan ObjectInfo
• type ObjectInfo
• type PosixFlatStorage
  • func NewPosixFlat(baseDir string) (*PosixFlatStorage, error)
  • func (s *PosixFlatStorage) DeleteObject(p string) error
  • func (s *PosixFlatStorage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo
  • func (s *PosixFlatStorage) ReadObject(p string) (ReadSeekCloser, error)
  • func (s *PosixFlatStorage) Stat(p string) (*ObjectInfo, error)
  • func (s *PosixFlatStorage) WriteObject(p string, data io.Reader, size int64, persist bool) error
• type PosixStorage
  • func NewPosix(baseDir string) (*PosixStorage, error)
  • func (s *PosixStorage) DeleteObject(p string) error
  • func (s *PosixStorage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo
  • func (s *PosixStorage) ReadObject(p string) (ReadSeekCloser, error)
  • func (s *PosixStorage) Stat(p string) (*ObjectInfo, error)
  • func (s *PosixStorage) WriteObject(p string, data io.Reader, size int64, persist bool) error
• type ReadSeekCloser
• type S3Storage
  • func NewS3(bucket, location, endpoint, accessKeyID, secretAccessKey string, secure bool) (*S3Storage, error)
  • func (s *S3Storage) DeleteObject(filepath string) error
  • func (s *S3Storage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo
  • func (s *S3Storage) ReadObject(filepath string) (ReadSeekCloser, error)
  • func (s *S3Storage) Stat(p string) (*ObjectInfo, error)
  • func (s *S3Storage) WriteObject(filepath string, data io.Reader, size int64, persist bool) error
• type Storage

Functions

func IsNotExist

func IsNotExist(err error) bool

func NewErrNotExist

func NewErrNotExist(err error, format string, args ...interface{}) error

Types

type ErrNotExist

type ErrNotExist struct {
	*util.WrapperError
}

type EscapeError

type EscapeError string

func (EscapeError) Error

func (e EscapeError) Error() string

type ObjStorage

type ObjStorage struct {
	Storage
	// contains filtered or unexported fields
}

ObjStorage wraps a Storage providing additional helper functions

func NewObjStorage

func NewObjStorage(s Storage, delimiter string) *ObjStorage

func (*ObjStorage) Delimiter

func (s *ObjStorage) Delimiter() string

func (*ObjStorage) List

func (s *ObjStorage) List(prefix, startWith string, recursive bool, doneCh <-chan struct{}) <-chan ObjectInfo

type ObjectInfo

type ObjectInfo struct {
	Path         string
	LastModified time.Time
	Size         int64

	Err error
}

type PosixFlatStorage

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

func NewPosixFlat

func NewPosixFlat(baseDir string) (*PosixFlatStorage, error)

func (*PosixFlatStorage) DeleteObject

func (s *PosixFlatStorage) DeleteObject(p string) error

func (*PosixFlatStorage) List

func (s *PosixFlatStorage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo

func (*PosixFlatStorage) ReadObject

func (s *PosixFlatStorage) ReadObject(p string) (ReadSeekCloser, error)

func (*PosixFlatStorage) Stat

func (s *PosixFlatStorage) Stat(p string) (*ObjectInfo, error)

func (*PosixFlatStorage) WriteObject

func (s *PosixFlatStorage) WriteObject(p string, data io.Reader, size int64, persist bool) error

type PosixStorage

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

func NewPosix

func NewPosix(baseDir string) (*PosixStorage, error)

func (*PosixStorage) DeleteObject

func (s *PosixStorage) DeleteObject(p string) error

func (*PosixStorage) List

func (s *PosixStorage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo

func (*PosixStorage) ReadObject

func (s *PosixStorage) ReadObject(p string) (ReadSeekCloser, error)

func (*PosixStorage) Stat

func (s *PosixStorage) Stat(p string) (*ObjectInfo, error)

func (*PosixStorage) WriteObject

func (s *PosixStorage) WriteObject(p string, data io.Reader, size int64, persist bool) error

type ReadSeekCloser

type ReadSeekCloser interface {
	io.Reader
	io.Seeker
	io.Closer
}

type S3Storage

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

func NewS3

func NewS3(bucket, location, endpoint, accessKeyID, secretAccessKey string, secure bool) (*S3Storage, error)

func (*S3Storage) DeleteObject

func (s *S3Storage) DeleteObject(filepath string) error

func (*S3Storage) List

func (s *S3Storage) List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo

func (*S3Storage) ReadObject

func (s *S3Storage) ReadObject(filepath string) (ReadSeekCloser, error)

func (*S3Storage) Stat

func (s *S3Storage) Stat(p string) (*ObjectInfo, error)

func (*S3Storage) WriteObject

func (s *S3Storage) WriteObject(filepath string, data io.Reader, size int64, persist bool) error

type Storage

type Storage interface {
	Stat(filepath string) (*ObjectInfo, error)
	ReadObject(filepath string) (ReadSeekCloser, error)
	// WriteObject atomically writes an object. If size is greater or equal to
	// zero then only size bytes will be read from data and wrote. If size is
	// less than zero data will be wrote until EOF. When persist is true the
	// implementation must ensure that data is persisted to the underlying
	// storage.
	WriteObject(filepath string, data io.Reader, size int64, persist bool) error
	DeleteObject(filepath string) error
	List(prefix, startWith, delimiter string, doneCh <-chan struct{}) <-chan ObjectInfo
}