s3

Documentation

Index

• Constants
• type Bucket
  • func New(l *slog.Logger, c *Config) (*Bucket, error)
  • func (bucket *Bucket) Name() string
  • func (bucket *Bucket) Type() string
  • func (bucket *Bucket) Upload(workU *domain.WorkUnit) (*domain.UploadResult, error)
• type Config
  • func ParseConfig(confData []byte) (*Config, error)

Constants

const TYPE string = "s3"

Types

type Bucket

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

func New

func New(l *slog.Logger, c *Config) (*Bucket, error)

func (*Bucket) Name

func (bucket *Bucket) Name() string

func (*Bucket) Type

func (bucket *Bucket) Type() string

func (*Bucket) Upload

func (bucket *Bucket) Upload(workU *domain.WorkUnit) (*domain.UploadResult, error)

type Config

type Config struct {
	TimeoutInMillis int64  `yaml:"timeout_milliseconds"`
	Bucket          string `yaml:"bucket"`
	Region          string `yaml:"region"`
	Endpoint        string `yaml:"endpoint"`
	AccessKey       string `yaml:"access_key"`
	SecretKey       string `yaml:"secret_key"`
	Prefix          string `yaml:"prefix"`
	ForcePathStyle  bool   `yaml:"force_path_style"`
}

func ParseConfig

func ParseConfig(confData []byte) (*Config, error)