objectstorage

Documentation

Index

• func IsNotExist(err error) bool
• func NewErrNotExist(err error, format string, args ...interface{}) error
• type ErrNotExist
• type ObjStorage
• type ObjectInfo
• type PosixStorage
  • func NewPosix(baseDir string) (*PosixStorage, error)
  • func (s *PosixStorage) DeleteObject(ctx context.Context, p string) error
  • func (s *PosixStorage) List(ctx context.Context, prefix, startAfter string, recursive bool) <-chan ObjectInfo
  • func (s *PosixStorage) ReadObject(ctx context.Context, p string) (ReadSeekCloser, error)
  • func (s *PosixStorage) Stat(ctx context.Context, p string) (*ObjectInfo, error)
  • func (s *PosixStorage) WriteObject(ctx context.Context, p string, data io.Reader, size int64, persist bool) error
• type ReadSeekCloser
• type S3Storage
  • func NewS3(ctx context.Context, ...) (*S3Storage, error)
  • func (s *S3Storage) DeleteObject(ctx context.Context, filepath string) error
  • func (s *S3Storage) List(ctx context.Context, prefix, startAfter string, recursive bool) <-chan ObjectInfo
  • func (s *S3Storage) ReadObject(ctx context.Context, filepath string) (ReadSeekCloser, error)
  • func (s *S3Storage) Stat(ctx context.Context, p string) (*ObjectInfo, error)
  • func (s *S3Storage) WriteObject(ctx context.Context, filepath string, data io.Reader, size int64, persist bool) error

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 ObjStorage

type ObjStorage interface {
	Stat(ctx context.Context, filepath string) (*ObjectInfo, error)
	ReadObject(ctx context.Context, 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(ctx context.Context, filepath string, data io.Reader, size int64, persist bool) error
	DeleteObject(ctx context.Context, filepath string) error
	List(ctx context.Context, prefix, startAfter string, recursive bool) <-chan ObjectInfo
}

type ObjectInfo

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

	Err 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(ctx context.Context, p string) error

func (*PosixStorage) List

func (s *PosixStorage) List(ctx context.Context, prefix, startAfter string, recursive bool) <-chan ObjectInfo

func (*PosixStorage) ReadObject

func (s *PosixStorage) ReadObject(ctx context.Context, p string) (ReadSeekCloser, error)

func (*PosixStorage) Stat

func (s *PosixStorage) Stat(ctx context.Context, p string) (*ObjectInfo, error)

func (*PosixStorage) WriteObject

func (s *PosixStorage) WriteObject(ctx context.Context, 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(ctx context.Context, bucket, location, endpoint, accessKeyID, secretAccessKey string, secure bool) (*S3Storage, error)

func (*S3Storage) DeleteObject

func (s *S3Storage) DeleteObject(ctx context.Context, filepath string) error

func (*S3Storage) List

func (s *S3Storage) List(ctx context.Context, prefix, startAfter string, recursive bool) <-chan ObjectInfo

func (*S3Storage) ReadObject

func (s *S3Storage) ReadObject(ctx context.Context, filepath string) (ReadSeekCloser, error)

func (*S3Storage) Stat

func (s *S3Storage) Stat(ctx context.Context, p string) (*ObjectInfo, error)

func (*S3Storage) WriteObject

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