storage

Documentation

Index

• type LocalFileDriver
  • func NewLocalFileDriver(config *types.StorageConfig) *LocalFileDriver
  • func (d *LocalFileDriver) Download(bucket string, key string, dist string) error
  • func (d *LocalFileDriver) Get(bucket string, key string) ([]byte, error)
  • func (d *LocalFileDriver) GetByStream(bucket string, key string) (io.ReadCloser, error)
  • func (d *LocalFileDriver) GetConfig() *types.StorageConfig
  • func (d *LocalFileDriver) List(root string, prefix string) (list []string, err error, next func() ([]string, error))
  • func (d *LocalFileDriver) Put(bucket string, key string, data []byte) error
• type S3Driver
  • func NewS3Driver(s *s3.Client, config *types.StorageConfig) *S3Driver
  • func (d *S3Driver) Download(bucket string, key string, dist string) error
  • func (d *S3Driver) Get(bucket string, key string) ([]byte, error)
  • func (d *S3Driver) GetByStream(bucket string, key string) (io.ReadCloser, error)
  • func (d *S3Driver) GetConfig() *types.StorageConfig
  • func (d *S3Driver) List(bucket string, prefix string) (list []string, err error, next func() ([]string, error))
  • func (d *S3Driver) Put(bucket string, key string, data []byte) error

Types

type LocalFileDriver

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

func NewLocalFileDriver

func NewLocalFileDriver(config *types.StorageConfig) *LocalFileDriver

func (*LocalFileDriver) Download

func (d *LocalFileDriver) Download(bucket string, key string, dist string) error

func (*LocalFileDriver) Get

func (d *LocalFileDriver) Get(bucket string, key string) ([]byte, error)

func (*LocalFileDriver) GetByStream

func (d *LocalFileDriver) GetByStream(bucket string, key string) (io.ReadCloser, error)

func (*LocalFileDriver) GetConfig

func (d *LocalFileDriver) GetConfig() *types.StorageConfig

func (*LocalFileDriver) List

func (d *LocalFileDriver) List(root string, prefix string) (list []string, err error, next func() ([]string, error))

func (*LocalFileDriver) Put

func (d *LocalFileDriver) Put(bucket string, key string, data []byte) error

type S3Driver

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

func NewS3Driver

func NewS3Driver(s *s3.Client, config *types.StorageConfig) *S3Driver

func (*S3Driver) Download

func (d *S3Driver) Download(bucket string, key string, dist string) error

func (*S3Driver) Get

func (d *S3Driver) Get(bucket string, key string) ([]byte, error)

func (*S3Driver) GetByStream

func (d *S3Driver) GetByStream(bucket string, key string) (io.ReadCloser, error)

func (*S3Driver) GetConfig

func (d *S3Driver) GetConfig() *types.StorageConfig

func (*S3Driver) List

func (d *S3Driver) List(bucket string, prefix string) (list []string, err error, next func() ([]string, error))

func (*S3Driver) Put

func (d *S3Driver) Put(bucket string, key string, data []byte) error