s3

Documentation

Index

• type Config
  • func (c *Config) Validate() error
• type S3Uploader
  • func NewUploader(config *Config) (*S3Uploader, error)
  • func (u *S3Uploader) SetDispatcher(d *events.Dispatcher)
  • func (u *S3Uploader) Upload(file, fileName string) error
  • func (u *S3Uploader) Write(r io.ReadCloser, fileName string, fileSize int64) error

Types

type Config

type Config struct {
	Secret *katana.Secret

	Host        string
	Region      string
	AccessKeyID string
	SecretKey   string
	Bucket      string
	Path        string
	PartSize    int64
}

Config is configuration for S3 uploader

func (*Config) Validate

func (c *Config) Validate() error

Validate validates configuration

type S3Uploader

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

S3Uploader is S3 uploader instance

func NewUploader

func NewUploader(config *Config) (*S3Uploader, error)

NewUploader creates new S3 uploader instance

func (*S3Uploader) SetDispatcher

func (u *S3Uploader) SetDispatcher(d *events.Dispatcher)

SetDispatcher sets events dispatcher

func (*S3Uploader) Upload

func (u *S3Uploader) Upload(file, fileName string) error

Upload uploads given file to S3 storage

func (*S3Uploader) Write

func (u *S3Uploader) Write(r io.ReadCloser, fileName string, fileSize int64) error

Write writes data from given reader to given file