storage

Documentation

Index

• Constants
• func CreateDirIfNotExist(dir string) error
• type File
  • func (f File) DeleteObject(identifier string) error
  • func (f File) GetObject(identifier string) (Object, error)
  • func (f File) ListObject(prefix string) ([]Object, error)
  • func (f File) PutObject(identifier string, data []byte) error
• type Object
• type S3
  • func New(endpoint, bucket, region, accessKeyID, secretAccessKey string) (*S3, error)
  • func (s S3) DeleteObject(identifier string) error
  • func (s S3) GetObject(identifier string) (Object, error)
  • func (s S3) ListObject(prefix string) ([]Object, error)
  • func (s S3) PutObject(identifier string, data []byte) error
• type Storage
  • func GetStorage(storage typedef.MultiStorage) (Storage, error)

Constants

const (
	FileStorage = "file"
	S3Storage   = "s3"
)

Functions

func CreateDirIfNotExist

func CreateDirIfNotExist(dir string) error

CreateDirIfNotExist creates the directory for the given file path if it does not exist.

Types

type File

type File struct {
}

func (File) DeleteObject

func (f File) DeleteObject(identifier string) error

func (File) GetObject

func (f File) GetObject(identifier string) (Object, error)

func (File) ListObject

func (f File) ListObject(prefix string) ([]Object, error)

func (File) PutObject

func (f File) PutObject(identifier string, data []byte) error

type Object

type Object struct {
	Path         string
	Content      []byte
	LastModified time.Time
}

type S3

type S3 struct {
	Endpoint        string
	Bucket          string
	Region          string
	AccessKeyID     string
	SecretAccessKey string
	// contains filtered or unexported fields
}

func New

func New(endpoint, bucket, region, accessKeyID, secretAccessKey string) (*S3, error)

func (S3) DeleteObject

func (s S3) DeleteObject(identifier string) error

func (S3) GetObject

func (s S3) GetObject(identifier string) (Object, error)

func (S3) ListObject

func (s S3) ListObject(prefix string) ([]Object, error)

func (S3) PutObject

func (s S3) PutObject(identifier string, data []byte) error

type Storage

type Storage interface {
	// ListObject returns a list of all objects in the storage backend.
	ListObject(prefix string) ([]Object, error)
	// GetObject returns the object identified by the given identifier.
	GetObject(identifier string) (Object, error)
	// PutObject stores the data in the storage backend identified by the given identifier.
	PutObject(identifier string, data []byte) error
	// DeleteObject deletes the object identified by the given identifier.
	DeleteObject(identifier string) error
}

func GetStorage

func GetStorage(storage typedef.MultiStorage) (Storage, error)